summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAmitay Isaacs <amitay@gmail.com>2012-05-09 12:56:53 +1000
committerAmitay Isaacs <amitay@gmail.com>2012-10-20 02:48:44 +1100
commitef79dc012e8867116ea71880940fe531d41d2649 (patch)
treed3671d6f9674af6c2a5d02364d1f3f272856cdf0
parent9f6b30a517fd813bb81fa867632527150153fe43 (diff)
downloadsamba-ef79dc012e8867116ea71880940fe531d41d2649.tar.gz
samba-ef79dc012e8867116ea71880940fe531d41d2649.tar.xz
samba-ef79dc012e8867116ea71880940fe531d41d2649.zip
header: Added DB statistics update macros
Signed-off-by: Amitay Isaacs <amitay@gmail.com> (This used to be ctdb commit a0cdfae7438092f5c605f0608daa536be860b7fe)
-rw-r--r--ctdb/include/ctdb_private.h65
1 files changed, 49 insertions, 16 deletions
diff --git a/ctdb/include/ctdb_private.h b/ctdb/include/ctdb_private.h
index 6f6d898167..7e86b10528 100644
--- a/ctdb/include/ctdb_private.h
+++ b/ctdb/include/ctdb_private.h
@@ -316,11 +316,6 @@ struct ctdb_daemon_data {
ctdb->statistics_current.counter++; \
}
-#define CTDB_INCREMENT_DB_STAT(ctdb_db, counter) \
- { \
- ctdb_db->statistics.counter++; \
- }
-
#define CTDB_DECREMENT_STAT(ctdb, counter) \
{ \
if (ctdb->statistics.counter > 0) \
@@ -329,31 +324,65 @@ struct ctdb_daemon_data {
ctdb->statistics_current.counter--; \
}
+#define CTDB_INCREMENT_DB_STAT(ctdb_db, counter) \
+ { \
+ ctdb_db->statistics.counter++; \
+ }
+
+#define CTDB_DECREMENT_DB_STAT(ctdb_db, counter) \
+ { \
+ if (ctdb_db->statistics.counter > 0) \
+ ctdb_db->statistics.counter--; \
+ }
+
#define CTDB_UPDATE_RECLOCK_LATENCY(ctdb, name, counter, value) \
{ \
- if (value > ctdb->statistics.counter.max) \
+ if (value > ctdb->statistics.counter.max) \
ctdb->statistics.counter.max = value; \
- if (value > ctdb->statistics_current.counter.max) \
+ if (value > ctdb->statistics_current.counter.max) \
ctdb->statistics_current.counter.max = value; \
\
- if (ctdb->statistics.counter.num == 0 || value < ctdb->statistics.counter.min) \
+ if (ctdb->statistics.counter.num == 0 || \
+ value < ctdb->statistics.counter.min) \
ctdb->statistics.counter.min = value; \
- if (ctdb->statistics_current.counter.num == 0 || value < ctdb->statistics_current.counter.min) \
+ if (ctdb->statistics_current.counter.num == 0 || \
+ value < ctdb->statistics_current.counter.min) \
ctdb->statistics_current.counter.min = value; \
\
- ctdb->statistics.counter.total += value; \
- ctdb->statistics_current.counter.total += value; \
+ ctdb->statistics.counter.total += value; \
+ ctdb->statistics_current.counter.total += value; \
\
ctdb->statistics.counter.num++; \
ctdb->statistics_current.counter.num++; \
\
if (ctdb->tunable.reclock_latency_ms != 0) { \
if (value*1000 > ctdb->tunable.reclock_latency_ms) { \
- DEBUG(DEBUG_ERR, ("High RECLOCK latency %fs for operation %s\n", value, name)); \
+ DEBUG(DEBUG_ERR, \
+ ("High RECLOCK latency %fs for operation %s\n", \
+ value, name)); \
} \
} \
}
+#define CTDB_UPDATE_DB_RECLOCK_LATENCY(ctdb_db, name, counter, value) \
+ { \
+ if (value > ctdb_db->statistics.counter.max) \
+ ctdb_db->statistics.counter.max = value; \
+ if (ctdb_db->statistics.counter.num == 0 || \
+ value < ctdb_db->statistics.counter.min) \
+ ctdb_db->statistics.counter.min = value; \
+ \
+ ctdb_db->statistics.counter.total += value; \
+ ctdb_db->statistics.counter.num++; \
+ \
+ if (ctdb_db->ctdb->tunable.reclock_latency_ms != 0) { \
+ if (value*1000 > ctdb_db->ctdb->tunable.reclock_latency_ms) { \
+ DEBUG(DEBUG_ERR, \
+ ("High RECLOCK latency %fs for operation %s\n", \
+ value, name)); \
+ } \
+ } \
+ }
#define CTDB_UPDATE_LATENCY(ctdb, db, operation, counter, t) \
{ \
@@ -364,9 +393,11 @@ struct ctdb_daemon_data {
if (l > ctdb->statistics_current.counter.max) \
ctdb->statistics_current.counter.max = l; \
\
- if (ctdb->statistics.counter.num == 0 || l < ctdb->statistics.counter.min) \
+ if (ctdb->statistics.counter.num == 0 || \
+ l < ctdb->statistics.counter.min) \
ctdb->statistics.counter.min = l; \
- if (ctdb->statistics_current.counter.num == 0 || l < ctdb->statistics_current.counter.min) \
+ if (ctdb->statistics_current.counter.num == 0 || \
+ l < ctdb->statistics_current.counter.min) \
ctdb->statistics_current.counter.min = l; \
\
ctdb->statistics.counter.total += l; \
@@ -375,9 +406,11 @@ struct ctdb_daemon_data {
ctdb->statistics.counter.num++; \
ctdb->statistics_current.counter.num++; \
\
- if (ctdb->tunable.log_latency_ms !=0) { \
+ if (ctdb->tunable.log_latency_ms != 0) { \
if (l*1000 > ctdb->tunable.log_latency_ms) { \
- DEBUG(DEBUG_WARNING, ("High latency %.6fs for operation %s on database %s\n", l, operation, db->db_name));\
+ DEBUG(DEBUG_WARNING, \
+ ("High latency %.6fs for operation %s on database %s\n",\
+ l, operation, db->db_name)); \
} \
} \
}