Rev 484: update flags in parent daemon too in http://samba.org/~tridge/ctdb

[tridge]

------------------------------------------------------------
revno: 484
revision-id: [EMAIL PROTECTED]
parent: [EMAIL PROTECTED]
committer: Andrew Tridgell <[EMAIL PROTECTED]>
branch nick: tridge
timestamp: Wed 2007-06-06 21:34:36 +1000
message:
  update flags in parent daemon too
modified:
  common/ctdb_daemon.c           ctdb_daemon.c-20070409200331-3el1kqgdb9m4ib0g-1
=== modified file 'common/ctdb_daemon.c'
--- a/common/ctdb_daemon.c      2007-06-06 03:45:12 +0000
+++ b/common/ctdb_daemon.c      2007-06-06 11:34:36 +0000
@@ -31,6 +31,25 @@
 
 static void daemon_incoming_packet(void *, struct ctdb_req_header *);
 
+/*
+  handler for when a node changes its flags
+*/
+static void flag_change_handler(struct ctdb_context *ctdb, uint64_t srvid, 
+                               TDB_DATA data, void *private_data)
+{
+       struct ctdb_node_flag_change *c = (struct ctdb_node_flag_change 
*)data.dptr;
+
+       if (data.dsize != sizeof(*c) || !ctdb_validate_vnn(ctdb, c->vnn)) {
+               DEBUG(0,(__location__ "Invalid data in 
ctdb_node_flag_change\n"));
+               return;
+       }
+
+       /* don't get the connected flag from the other node */
+       ctdb->nodes[c->vnn]->flags = 
+               (ctdb->nodes[c->vnn]->flags&NODE_FLAGS_CONNECTED) 
+               | (c->flags & ~NODE_FLAGS_CONNECTED);   
+}
+
 /* called when the "startup" event script has finished */
 static void ctdb_start_transport(struct ctdb_context *ctdb, int status, void 
*p)
 {
@@ -51,6 +70,10 @@
                exit(11);
        }
 
+       /* a handler for when nodes are disabled/enabled */
+       ctdb_register_message_handler(ctdb, ctdb, 
CTDB_SRVID_NODE_FLAGS_CHANGED, 
+                                     flag_change_handler, NULL);
+
        /* start monitoring for dead nodes */
        ctdb_start_monitoring(ctdb);
 }