int ctdb_daemon_call_recv(struct ctdb_call_state *state,
struct ctdb_call *call);
-void ctdb_send_keepalive(struct ctdb_context *ctdb, uint32_t destnode);
-
int ctdb_start_revoke_ro_record(struct ctdb_context *ctdb,
struct ctdb_db_context *ctdb_db,
TDB_DATA key, struct ctdb_ltdb_header *header,
}
-/*
- send a keepalive packet to the other node
-*/
-void ctdb_send_keepalive(struct ctdb_context *ctdb, uint32_t destnode)
-{
- struct ctdb_req_keepalive_old *r;
-
- if (ctdb->methods == NULL) {
- DEBUG(DEBUG_INFO,(__location__ " Failed to send keepalive. Transport is DOWN\n"));
- return;
- }
-
- r = ctdb_transport_allocate(ctdb, ctdb, CTDB_REQ_KEEPALIVE,
- sizeof(struct ctdb_req_keepalive_old),
- struct ctdb_req_keepalive_old);
- CTDB_NO_MEMORY_FATAL(ctdb, r);
- r->hdr.destnode = destnode;
- r->hdr.reqid = 0;
-
- CTDB_INCREMENT_STAT(ctdb, keepalive_packets_sent);
-
- ctdb_queue_packet(ctdb, &r->hdr);
-
- talloc_free(r);
-}
-
-
-
struct revokechild_deferred_call {
struct revokechild_deferred_call *prev, *next;
struct ctdb_context *ctdb;
#include "common/logging.h"
+/*
+ send a keepalive packet to the other node
+*/
+static void ctdb_send_keepalive(struct ctdb_context *ctdb, uint32_t destnode)
+{
+ struct ctdb_req_keepalive_old *r;
+
+ if (ctdb->methods == NULL) {
+ DEBUG(DEBUG_INFO,
+ ("Failed to send keepalive. Transport is DOWN\n"));
+ return;
+ }
+
+ r = ctdb_transport_allocate(ctdb, ctdb, CTDB_REQ_KEEPALIVE,
+ sizeof(struct ctdb_req_keepalive_old),
+ struct ctdb_req_keepalive_old);
+ CTDB_NO_MEMORY_FATAL(ctdb, r);
+ r->hdr.destnode = destnode;
+ r->hdr.reqid = 0;
+
+ CTDB_INCREMENT_STAT(ctdb, keepalive_packets_sent);
+
+ ctdb_queue_packet(ctdb, &r->hdr);
+
+ talloc_free(r);
+}
+
/*
see if any nodes are dead
*/