diff options
| author | unknown <tomas@poseidon.ndb.mysql.com> | 2006-02-02 16:12:18 +0100 |
|---|---|---|
| committer | unknown <tomas@poseidon.ndb.mysql.com> | 2006-02-02 16:12:18 +0100 |
| commit | eaf466d26a4b84803998bbbb0f6454b6f4e258fd (patch) | |
| tree | e70a490ffe3d2e32314b897e1c01f5dfe287f1fc /sql/ha_ndbcluster_binlog.cc | |
| parent | d588ef9b550e35976c2ba0428cf6dcfa3f0de3cf (diff) | |
| download | mariadb-git-eaf466d26a4b84803998bbbb0f6454b6f4e258fd.tar.gz | |
added more logging in ndb handler
enable extra logging in ndb handler during test runs
mysql-test/mysql-test-run.pl:
enable extra logging in ndb handler during test runs
sql/ha_ndbcluster_binlog.cc:
added more logging in ndb handler
Diffstat (limited to 'sql/ha_ndbcluster_binlog.cc')
| -rw-r--r-- | sql/ha_ndbcluster_binlog.cc | 26 |
1 files changed, 26 insertions, 0 deletions
diff --git a/sql/ha_ndbcluster_binlog.cc b/sql/ha_ndbcluster_binlog.cc index 5a8ff8cb338..8d1c7d6cc4b 100644 --- a/sql/ha_ndbcluster_binlog.cc +++ b/sql/ha_ndbcluster_binlog.cc @@ -1464,6 +1464,14 @@ ndb_binlog_thread_handle_schema_event(THD *thd, Ndb *ndb, (void) pthread_mutex_lock(&share->mutex); bitmap_clear_all(&share->subscriber_bitmap[node_id]); DBUG_PRINT("info",("NODE_FAILURE UNSUBSCRIBE[%d]", node_id)); + if (ndb_extra_logging) + { + sql_print_information("NDB Binlog: Node: %d, down," + " Subscriber bitmask %x%x", + pOp->getNdbdNodeId(), + share->subscriber_bitmap[node_id].bitmap[1], + share->subscriber_bitmap[node_id].bitmap[0]); + } (void) pthread_mutex_unlock(&share->mutex); (void) pthread_cond_signal(&injector_cond); break; @@ -1476,6 +1484,15 @@ ndb_binlog_thread_handle_schema_event(THD *thd, Ndb *ndb, (void) pthread_mutex_lock(&share->mutex); bitmap_set_bit(&share->subscriber_bitmap[node_id], req_id); DBUG_PRINT("info",("SUBSCRIBE[%d] %d", node_id, req_id)); + if (ndb_extra_logging) + { + sql_print_information("NDB Binlog: Node: %d, subscribe from node %d," + " Subscriber bitmask %x%x", + pOp->getNdbdNodeId(), + req_id, + share->subscriber_bitmap[node_id].bitmap[1], + share->subscriber_bitmap[node_id].bitmap[0]); + } (void) pthread_mutex_unlock(&share->mutex); (void) pthread_cond_signal(&injector_cond); break; @@ -1488,6 +1505,15 @@ ndb_binlog_thread_handle_schema_event(THD *thd, Ndb *ndb, (void) pthread_mutex_lock(&share->mutex); bitmap_clear_bit(&share->subscriber_bitmap[node_id], req_id); DBUG_PRINT("info",("UNSUBSCRIBE[%d] %d", node_id, req_id)); + if (ndb_extra_logging) + { + sql_print_information("NDB Binlog: Node: %d, unsubscribe from node %d," + " Subscriber bitmask %x%x", + pOp->getNdbdNodeId(), + req_id, + share->subscriber_bitmap[node_id].bitmap[1], + share->subscriber_bitmap[node_id].bitmap[0]); + } (void) pthread_mutex_unlock(&share->mutex); (void) pthread_cond_signal(&injector_cond); break; |