]> git.ipfire.org Git - thirdparty/samba.git/commitdiff
change ctdb_validate_vnn to ctdb_validate_pnn
authorRonnie Sahlberg <sahlberg@ronnie>
Tue, 4 Sep 2007 00:09:58 +0000 (10:09 +1000)
committerRonnie Sahlberg <sahlberg@ronnie>
Tue, 4 Sep 2007 00:09:58 +0000 (10:09 +1000)
(This used to be ctdb commit a4a1f41b69475b9dc16d8fd7f8965c32e96c32f0)

ctdb/include/ctdb_private.h
ctdb/server/ctdb_control.c
ctdb/server/ctdb_daemon.c
ctdb/server/ctdb_recoverd.c
ctdb/server/ctdb_server.c
ctdb/server/ctdbd.c

index df3141a26691d301d38d9a76be7fa23c67c421eb..5e860ab6d0d2388a0997496b39c57eb924b7adf3 100644 (file)
@@ -107,9 +107,9 @@ struct ctdb_address {
 };
 
 /*
-  check a vnn is valid
+  check that a pnn is valid
  */
-#define ctdb_validate_vnn(ctdb, vnn) (((uint32_t)(vnn)) < (ctdb)->num_nodes)
+#define ctdb_validate_pnn(ctdb, pnn) (((uint32_t)(pnn)) < (ctdb)->num_nodes)
 
 
 /* called from the queue code when a packet comes in. Called with data==NULL
index 09276cd3de421ac38f90b499fca3b5fbb5c024b5..ca0ea9a937fb74fc965fbb33126eb804baaef77f 100644 (file)
@@ -469,7 +469,7 @@ int ctdb_daemon_send_control(struct ctdb_context *ctdb, uint32_t destnode,
        if (destnode != CTDB_BROADCAST_VNNMAP && 
            destnode != CTDB_BROADCAST_ALL && 
            destnode != CTDB_BROADCAST_CONNECTED && 
-           (!ctdb_validate_vnn(ctdb, destnode) || 
+           (!ctdb_validate_pnn(ctdb, destnode) || 
             (ctdb->nodes[destnode]->flags & NODE_FLAGS_DISCONNECTED))) {
                if (!(flags & CTDB_CTRL_FLAG_NOREPLY)) {
                        callback(ctdb, -1, tdb_null, "ctdb_control to disconnected node", private_data);
index f487434a9bbe2287deba3d449e7d8893ec1af488..0112fd61d11da8b5d68d86cdb28a18a5220531e9 100644 (file)
@@ -38,12 +38,12 @@ static void flag_change_handler(struct ctdb_context *ctdb, uint64_t srvid,
 {
        struct ctdb_node_flag_change *c = (struct ctdb_node_flag_change *)data.dptr;
 
-       if (data.dsize != sizeof(*c) || !ctdb_validate_vnn(ctdb, c->vnn)) {
+       if (data.dsize != sizeof(*c) || !ctdb_validate_pnn(ctdb, c->vnn)) {
                DEBUG(0,(__location__ "Invalid data in ctdb_node_flag_change\n"));
                return;
        }
 
-       if (!ctdb_validate_vnn(ctdb, c->vnn)) {
+       if (!ctdb_validate_pnn(ctdb, c->vnn)) {
                DEBUG(0,("Bad vnn %u in flag_change_handler\n", c->vnn));
                return;
        }
@@ -809,7 +809,7 @@ static void daemon_request_control_from_client(struct ctdb_client *client,
        state->client = client;
        state->c = talloc_steal(state, c);
        state->reqid = c->hdr.reqid;
-       if (ctdb_validate_vnn(client->ctdb, c->hdr.destnode)) {
+       if (ctdb_validate_pnn(client->ctdb, c->hdr.destnode)) {
                state->node = client->ctdb->nodes[c->hdr.destnode];
                DLIST_ADD(state->node->pending_controls, state);
        } else {
index a8097a6387f886890d4c967af27a02e634870349..e687fe81048bba79eda37b7b2635d57cdcb17c71 100644 (file)
@@ -54,8 +54,8 @@ static void ctdb_unban_node(struct ctdb_recoverd *rec, uint32_t vnn)
 {
        struct ctdb_context *ctdb = rec->ctdb;
 
-       if (!ctdb_validate_vnn(ctdb, vnn)) {
-               DEBUG(0,("Bad vnn %u in ctdb_ban_node\n", vnn));
+       if (!ctdb_validate_pnn(ctdb, vnn)) {
+               DEBUG(0,("Bad pnn %u in ctdb_ban_node\n", vnn));
                return;
        }
 
@@ -90,8 +90,8 @@ static void ctdb_ban_node(struct ctdb_recoverd *rec, uint32_t vnn, uint32_t ban_
 {
        struct ctdb_context *ctdb = rec->ctdb;
 
-       if (!ctdb_validate_vnn(ctdb, vnn)) {
-               DEBUG(0,("Bad vnn %u in ctdb_ban_node\n", vnn));
+       if (!ctdb_validate_pnn(ctdb, vnn)) {
+               DEBUG(0,("Bad pnn %u in ctdb_ban_node\n", vnn));
                return;
        }
 
index 8dabcd595d95d1eb1ea3c78e23da9bacd259b39c..a9ae79bc7ec2e5c28d2d274feaf4a2a633e39d86 100644 (file)
@@ -455,7 +455,7 @@ void ctdb_queue_packet(struct ctdb_context *ctdb, struct ctdb_req_header *hdr)
 
        ctdb->statistics.node_packets_sent++;
 
-       if (!ctdb_validate_vnn(ctdb, hdr->destnode)) {
+       if (!ctdb_validate_pnn(ctdb, hdr->destnode)) {
                DEBUG(0,(__location__ " cant send to node %u that does not exist\n", 
                         hdr->destnode));
                return;
index 4083d1539cbf503f80bd4a43c3ca9b7188edc167..218c6582907fca7e196f8bf4e3670bf32cec3c31 100644 (file)
@@ -66,7 +66,7 @@ static void ctdb_recv_pkt(struct ctdb_context *ctdb, uint8_t *data, uint32_t len
        ctdb->statistics.node_packets_recv++;
 
        /* up the counter for this source node, so we know its alive */
-       if (ctdb_validate_vnn(ctdb, hdr->srcnode)) {
+       if (ctdb_validate_pnn(ctdb, hdr->srcnode)) {
                /* as a special case, redirected calls don't increment the rx_cnt */
                if (hdr->operation != CTDB_REQ_CALL ||
                    ((struct ctdb_req_call *)hdr)->hopcount == 0) {