ctdb-daemon: Separate prototypes for common client/server functions
authorAmitay Isaacs <amitay@gmail.com>
Fri, 23 Oct 2015 03:17:34 +0000 (14:17 +1100)
committerMartin Schwenke <martins@samba.org>
Fri, 30 Oct 2015 01:00:27 +0000 (02:00 +0100)
This groups function prototypes for common client/server functions in
common/common.h and removes them from ctdb_private.h.

Signed-off-by: Amitay Isaacs <amitay@gmail.com>
Reviewed-by: Martin Schwenke <martin@meltin.net>
54 files changed:
ctdb/client/ctdb_client.c
ctdb/common/cmdline.c
ctdb/common/common.h [new file with mode: 0644]
ctdb/common/ctdb_fork.c
ctdb/common/ctdb_io.c
ctdb/common/ctdb_ltdb.c
ctdb/common/ctdb_util.c
ctdb/ib/ibw_ctdb.c
ctdb/ib/ibw_ctdb_init.c
ctdb/include/ctdb_client.h
ctdb/include/ctdb_private.h
ctdb/server/ctdb_banning.c
ctdb/server/ctdb_call.c
ctdb/server/ctdb_control.c
ctdb/server/ctdb_daemon.c
ctdb/server/ctdb_freeze.c
ctdb/server/ctdb_keepalive.c
ctdb/server/ctdb_lock.c
ctdb/server/ctdb_logging.c
ctdb/server/ctdb_ltdb_server.c
ctdb/server/ctdb_monitor.c
ctdb/server/ctdb_persistent.c
ctdb/server/ctdb_recover.c
ctdb/server/ctdb_recoverd.c
ctdb/server/ctdb_server.c
ctdb/server/ctdb_serverids.c
ctdb/server/ctdb_takeover.c
ctdb/server/ctdb_traverse.c
ctdb/server/ctdb_tunables.c
ctdb/server/ctdb_update_record.c
ctdb/server/ctdb_uptime.c
ctdb/server/ctdb_vacuum.c
ctdb/server/ctdbd.c
ctdb/server/eventscript.c
ctdb/tcp/tcp_connect.c
ctdb/tcp/tcp_init.c
ctdb/tcp/tcp_io.c
ctdb/tests/src/ctdb_bench.c
ctdb/tests/src/ctdb_fetch.c
ctdb/tests/src/ctdb_fetch_one.c
ctdb/tests/src/ctdb_fetch_readonly_loop.c
ctdb/tests/src/ctdb_fetch_readonly_once.c
ctdb/tests/src/ctdb_persistent.c
ctdb/tests/src/ctdb_porting_tests.c
ctdb/tests/src/ctdb_randrec.c
ctdb/tests/src/ctdb_store.c
ctdb/tests/src/ctdb_trackingdb_test.c
ctdb/tests/src/ctdb_transaction.c
ctdb/tests/src/ctdb_traverse.c
ctdb/tests/src/ctdb_update_record.c
ctdb/tests/src/ctdb_update_record_persistent.c
ctdb/tests/src/rb_test.c
ctdb/tools/ctdb.c
ctdb/utils/pmda/pmda_ctdb.c

index 73c2e65ecdcdf3fbb5837d14657d1e5c056d9b1a..28f4358fcb721e5fe3bd28092ca9cf3c7083f750 100644 (file)
@@ -41,6 +41,7 @@
 
 #include "common/reqid.h"
 #include "common/system.h"
+#include "common/common.h"
 
 /*
   allocate a packet for use in client<->daemon communication
index fa7221d571e03b03a65c39c84a75395566093f7a..69e82314dd79dc8477ace8fabc8496ab46d59058 100644 (file)
@@ -32,6 +32,7 @@
 #include "ctdb_client.h"
 
 #include "common/rb_tree.h"
+#include "common/common.h"
 #include "common/cmdline.h"
 
 
diff --git a/ctdb/common/common.h b/ctdb/common/common.h
new file mode 100644 (file)
index 0000000..49c5faf
--- /dev/null
@@ -0,0 +1,156 @@
+/*
+   ctdb database library
+
+   Copyright (C) Amitay Isaacs  2015
+
+   This program is free software; you can redistribute it and/or modify
+   it under the terms of the GNU General Public License as published by
+   the Free Software Foundation; either version 3 of the License, or
+   (at your option) any later version.
+
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, see <http://www.gnu.org/licenses/>.
+*/
+
+#ifndef __CTDB_COMMON_H__
+#define __CTDB_COMMON_H__
+
+/* From common/ctdb_fork.c */
+
+void ctdb_set_child_info(TALLOC_CTX *mem_ctx, const char *child_name_fmt, ...);
+
+void ctdb_track_child(struct ctdb_context *ctdb, pid_t pid);
+
+pid_t ctdb_fork(struct ctdb_context *ctdb);
+
+struct tevent_signal *ctdb_init_sigchld(struct ctdb_context *ctdb);
+
+int ctdb_kill(struct ctdb_context *ctdb, pid_t pid, int signum);
+
+/* From common/ctdb_io.c */
+
+int ctdb_queue_length(struct ctdb_queue *queue);
+
+int ctdb_queue_send(struct ctdb_queue *queue, uint8_t *data, uint32_t length);
+
+int ctdb_queue_set_fd(struct ctdb_queue *queue, int fd);
+
+struct ctdb_queue *ctdb_queue_setup(struct ctdb_context *ctdb,
+                                   TALLOC_CTX *mem_ctx, int fd, int alignment,
+                                   ctdb_queue_cb_fn_t callback,
+                                   void *private_data, const char *fmt, ...)
+                                   PRINTF_ATTRIBUTE(7,8);
+
+/* From common/ctdb_ltdb.c */
+
+struct ctdb_db_context *ctdb_db_handle(struct ctdb_context *ctdb,
+                                      const char *name);
+
+uint32_t ctdb_lmaster(struct ctdb_context *ctdb, const TDB_DATA *key);
+
+int ctdb_ltdb_fetch(struct ctdb_db_context *ctdb_db,
+                   TDB_DATA key, struct ctdb_ltdb_header *header,
+                   TALLOC_CTX *mem_ctx, TDB_DATA *data);
+
+int ctdb_ltdb_fetch_with_header(struct ctdb_db_context *ctdb_db,
+                               TDB_DATA key, struct ctdb_ltdb_header *header,
+                               TALLOC_CTX *mem_ctx, TDB_DATA *data);
+
+int ctdb_ltdb_store(struct ctdb_db_context *ctdb_db, TDB_DATA key,
+                   struct ctdb_ltdb_header *header, TDB_DATA data);
+
+int ctdb_ltdb_lock(struct ctdb_db_context *ctdb_db, TDB_DATA key);
+
+int ctdb_ltdb_unlock(struct ctdb_db_context *ctdb_db, TDB_DATA key);
+
+int ctdb_ltdb_delete(struct ctdb_db_context *ctdb_db, TDB_DATA key);
+
+int ctdb_trackingdb_add_pnn(struct ctdb_context *ctdb, TDB_DATA *data, uint32_t pnn);
+
+typedef void (*ctdb_trackingdb_cb)(struct ctdb_context *ctdb, uint32_t pnn,
+                                  void *private_data);
+
+void ctdb_trackingdb_traverse(struct ctdb_context *ctdb, TDB_DATA data,
+                             ctdb_trackingdb_cb cb, void *private_data);
+
+int ctdb_null_func(struct ctdb_call_info *call);
+
+int ctdb_fetch_func(struct ctdb_call_info *call);
+
+int ctdb_fetch_with_header_func(struct ctdb_call_info *call);
+
+/* from common/ctdb_util.c */
+
+const char *ctdb_errstr(struct ctdb_context *ctdb);
+
+void ctdb_set_error(struct ctdb_context *ctdb, const char *fmt, ...);
+
+void ctdb_fatal(struct ctdb_context *ctdb, const char *msg);
+
+void ctdb_die(struct ctdb_context *ctdb, const char *msg);
+
+bool ctdb_set_helper(const char *type, char *helper, size_t size,
+                    const char *envvar,
+                    const char *dir, const char *file);
+
+void ctdb_external_trace(void);
+
+int ctdb_parse_address(TALLOC_CTX *mem_ctx, const char *str,
+                      ctdb_sock_addr *address);
+
+bool ctdb_same_address(ctdb_sock_addr *a1, ctdb_sock_addr *a2);
+
+uint32_t ctdb_hash(const TDB_DATA *key);
+
+struct ctdb_rec_data *ctdb_marshall_record(TALLOC_CTX *mem_ctx, uint32_t reqid,
+                                          TDB_DATA key,
+                                          struct ctdb_ltdb_header *header,
+                                          TDB_DATA data);
+
+struct ctdb_marshall_buffer *ctdb_marshall_add(TALLOC_CTX *mem_ctx,
+                                              struct ctdb_marshall_buffer *m,
+                                              uint64_t db_id,
+                                              uint32_t reqid,
+                                              TDB_DATA key,
+                                              struct ctdb_ltdb_header *header,
+                                              TDB_DATA data);
+
+TDB_DATA ctdb_marshall_finish(struct ctdb_marshall_buffer *m);
+
+struct ctdb_rec_data *ctdb_marshall_loop_next(struct ctdb_marshall_buffer *m,
+                                             struct ctdb_rec_data *r,
+                                             uint32_t *reqid,
+                                             struct ctdb_ltdb_header *header,
+                                             TDB_DATA *key, TDB_DATA *data);
+
+void ctdb_canonicalize_ip(const ctdb_sock_addr *ip, ctdb_sock_addr *cip);
+
+bool ctdb_same_ip(const ctdb_sock_addr *tip1, const ctdb_sock_addr *tip2);
+
+bool ctdb_same_sockaddr(const ctdb_sock_addr *ip1, const ctdb_sock_addr *ip2);
+
+char *ctdb_addr_to_str(ctdb_sock_addr *addr);
+
+unsigned ctdb_addr_to_port(ctdb_sock_addr *addr);
+
+struct ctdb_node_map *ctdb_read_nodes_file(TALLOC_CTX *mem_ctx,
+                                          const char *nlist);
+
+struct ctdb_node_map *ctdb_node_list_to_map(struct ctdb_node **nodes,
+                                           uint32_t num_nodes,
+                                           TALLOC_CTX *mem_ctx);
+
+const char *runstate_to_string(enum ctdb_runstate runstate);
+
+enum ctdb_runstate runstate_from_string(const char *label);
+
+void ctdb_set_runstate(struct ctdb_context *ctdb, enum ctdb_runstate runstate);
+
+uint32_t *ctdb_key_to_idkey(TALLOC_CTX *mem_ctx, TDB_DATA key);
+
+#endif /* __CTDB_COMMON_H__ */
index c6673eb8661510e40c97e08681e852245ef523b6..46b0a13a7d99f144d3b7422f945982ad582169ba 100644 (file)
@@ -32,6 +32,7 @@
 
 #include "common/rb_tree.h"
 #include "common/system.h"
+#include "common/common.h"
 
 void ctdb_set_child_info(TALLOC_CTX *mem_ctx, const char *child_name_fmt, ...)
 {
index 46199b8c015f1f13217b3fa5bee1191357783092..fca9be050215efc834748463f9afb2c53ea9c2fc 100644 (file)
@@ -36,6 +36,7 @@
 #include "ctdb_client.h"
 
 #include "common/system.h"
+#include "common/common.h"
 
 #define QUEUE_BUFFER_SIZE      (16*1024)
 
index 4e7fcafb54f2184da0a8e6296d0893c3a424b788..39775be706e527708513f0320af75ec111d2ea72 100644 (file)
@@ -31,6 +31,8 @@
 #include "ctdb_logging.h"
 #include "ctdb_private.h"
 
+#include "common/common.h"
+
 /*
   find an attached ctdb_db handle given a name
  */
index d158143f920ad4414edd9815aadb4b34cd545823..90907081bdda1a9595be68f6c6238e7a043f4fa3 100644 (file)
@@ -32,6 +32,7 @@
 
 #include "common/reqid.h"
 #include "common/system.h"
+#include "common/common.h"
 
 /*
   return error string for last error
index 35d0514b6821d95610bbcf43068266a48d65e767..3e17a70778302ce619cefe157d1b4b9dde4d122d 100644 (file)
@@ -33,6 +33,8 @@
 #include "ctdb_logging.h"
 #include "ctdb_private.h"
 
+#include "common/common.h"
+
 #include "ibwrapper.h"
 #include "ibw_ctdb.h"
 
index ec4d933b3da2629f1303e457f5991fd2c5a5c607..2c5a6c056a58c2271f1e7386d6f2ba808977cf64 100644 (file)
@@ -33,6 +33,8 @@
 #include "ctdb_logging.h"
 #include "ctdb_private.h"
 
+#include "common/common.h"
+
 #include "ibwrapper.h"
 #include "ibw_ctdb.h"
 
index 2f03b14d40745ac6deb3c2ad10b1815e0c14df7e..4fc207e826e79c5b368e4c4db774364fbd5f96a3 100644 (file)
@@ -96,16 +96,6 @@ struct ctdb_db_context *ctdb_attach(struct ctdb_context *ctdb,
 
 int ctdb_detach(struct ctdb_context *ctdb, uint32_t db_id);
 
-/*
-  find an attached ctdb_db handle given a name
- */
-struct ctdb_db_context *ctdb_db_handle(struct ctdb_context *ctdb, const char *name);
-
-/*
-  error string for last ctdb error
-*/
-const char *ctdb_errstr(struct ctdb_context *);
-
 /* a ctdb call function */
 typedef int (*ctdb_fn_t)(struct ctdb_call_info *);
 
@@ -164,9 +154,6 @@ int ctdb_fetch(struct ctdb_db_context *ctdb_db, TALLOC_CTX *mem_ctx,
 struct ctdb_db_context *find_ctdb_db(struct ctdb_context *ctdb, uint32_t id);
 
 
-struct ctdb_context *ctdb_cmdline_client(struct tevent_context *ev,
-                                        struct timeval req_timeout);
-
 struct ctdb_statistics;
 int ctdb_ctrl_statistics(struct ctdb_context *ctdb, uint32_t destnode, struct ctdb_statistics *status);
 int ctdb_ctrl_dbstatistics(struct ctdb_context *ctdb, uint32_t destnode, uint32_t dbid,
@@ -497,15 +484,6 @@ struct ctdb_client_control_state *ctdb_ctrl_getcapabilities_send(struct ctdb_con
 
 int ctdb_ctrl_getcapabilities_recv(struct ctdb_context *ctdb, TALLOC_CTX *mem_ctx, struct ctdb_client_control_state *state, uint32_t *capabilities);
 
-struct ctdb_marshall_buffer *ctdb_marshall_add(TALLOC_CTX *mem_ctx,
-                                              struct ctdb_marshall_buffer *m,
-                                              uint64_t db_id,
-                                              uint32_t reqid,
-                                              TDB_DATA key,
-                                              struct ctdb_ltdb_header *header,
-                                              TDB_DATA data);
-TDB_DATA ctdb_marshall_finish(struct ctdb_marshall_buffer *m);
-
 struct ctdb_transaction_handle *ctdb_transaction_start(struct ctdb_db_context *ctdb_db,
                                                       TALLOC_CTX *mem_ctx);
 int ctdb_transaction_fetch(struct ctdb_transaction_handle *h,
index 15197ed612aa41c910cf8256aeb3a83a1b1285b6..8e200732d5a13bb172c8cc1f75128cf1d8ade6f9 100644 (file)
@@ -411,10 +411,6 @@ enum ctdb_runstate {
        CTDB_RUNSTATE_SHUTDOWN,
 };
 
-const char *runstate_to_string(enum ctdb_runstate runstate);
-enum ctdb_runstate runstate_from_string(const char *label);
-void ctdb_set_runstate(struct ctdb_context *ctdb, enum ctdb_runstate runstate);
-
 void ctdb_shutdown_sequence(struct ctdb_context *ctdb, int exit_code);
 
 #define CTDB_MONITORING_ACTIVE         0
@@ -677,19 +673,6 @@ struct ctdb_fetch_handle {
 };
 
 /* internal prototypes */
-void ctdb_set_error(struct ctdb_context *ctdb, const char *fmt, ...) PRINTF_ATTRIBUTE(2,3);
-void ctdb_fatal(struct ctdb_context *ctdb, const char *msg);
-void ctdb_die(struct ctdb_context *ctdb, const char *msg);
-bool ctdb_set_helper(const char *type, char *helper, size_t size,
-                    const char *envvar, const char *dir, const char *file);
-void ctdb_external_trace(void);
-bool ctdb_same_address(ctdb_sock_addr *a1, ctdb_sock_addr *a2);
-int ctdb_parse_address(TALLOC_CTX *mem_ctx, const char *str,
-                      ctdb_sock_addr *address);
-bool ctdb_same_ip(const ctdb_sock_addr *ip1, const ctdb_sock_addr *ip2);
-bool ctdb_same_sockaddr(const ctdb_sock_addr *ip1, const ctdb_sock_addr *ip2);
-uint32_t ctdb_hash(const TDB_DATA *key);
-uint32_t *ctdb_key_to_idkey(TALLOC_CTX *mem_ctx, TDB_DATA key);
 
 void ctdb_request_call(struct ctdb_context *ctdb, struct ctdb_req_header *hdr);
 void ctdb_request_dmaster(struct ctdb_context *ctdb, struct ctdb_req_header *hdr);
@@ -698,16 +681,6 @@ void ctdb_reply_dmaster(struct ctdb_context *ctdb, struct ctdb_req_header *hdr);
 void ctdb_reply_call(struct ctdb_context *ctdb, struct ctdb_req_header *hdr);
 void ctdb_reply_error(struct ctdb_context *ctdb, struct ctdb_req_header *hdr);
 
-uint32_t ctdb_lmaster(struct ctdb_context *ctdb, const TDB_DATA *key);
-int ctdb_ltdb_fetch(struct ctdb_db_context *ctdb_db, 
-                   TDB_DATA key, struct ctdb_ltdb_header *header, 
-                   TALLOC_CTX *mem_ctx, TDB_DATA *data);
-int ctdb_ltdb_store(struct ctdb_db_context *ctdb_db, TDB_DATA key, 
-                   struct ctdb_ltdb_header *header, TDB_DATA data);
-int ctdb_ltdb_delete(struct ctdb_db_context *ctdb_db, TDB_DATA key);
-int ctdb_ltdb_fetch_with_header(struct ctdb_db_context *ctdb_db, 
-                   TDB_DATA key, struct ctdb_ltdb_header *header, 
-                   TALLOC_CTX *mem_ctx, TDB_DATA *data);
 int32_t ctdb_control_start_persistent_update(struct ctdb_context *ctdb, 
                        struct ctdb_req_control *c,
                        TDB_DATA recdata);
@@ -735,26 +708,6 @@ struct ctdb_call_state *ctdb_call_local_send(struct ctdb_db_context *ctdb_db,
 
 int ctdb_start_daemon(struct ctdb_context *ctdb, bool do_fork);
 
-/*
-  queue a packet for sending
-*/
-int ctdb_queue_send(struct ctdb_queue *queue, uint8_t *data, uint32_t length);
-
-/*
-  setup the fd used by the queue
- */
-int ctdb_queue_set_fd(struct ctdb_queue *queue, int fd);
-
-/*
-  setup a packet queue on a socket
- */
-struct ctdb_queue *ctdb_queue_setup(struct ctdb_context *ctdb,
-                                   TALLOC_CTX *mem_ctx, int fd, int alignment,
-                                   
-                                   ctdb_queue_cb_fn_t callback,
-                                   void *private_data, const char *fmt, ...)
-       PRINTF_ATTRIBUTE(7,8);
-
 /*
   allocate a packet for use in client<->daemon communication
  */
@@ -774,19 +727,6 @@ struct ctdb_req_header *_ctdb_transport_allocate(struct ctdb_context *ctdb,
 #define ctdb_transport_allocate(ctdb, mem_ctx, operation, length, type) \
        (type *)_ctdb_transport_allocate(ctdb, mem_ctx, operation, length, sizeof(type), #type)
 
-int ctdb_queue_length(struct ctdb_queue *queue);
-
-/*
-  lock a record in the ltdb, given a key
- */
-int ctdb_ltdb_lock(struct ctdb_db_context *ctdb_db, TDB_DATA key);
-
-/*
-  unlock a record in the ltdb, given a key
- */
-int ctdb_ltdb_unlock(struct ctdb_db_context *ctdb_db, TDB_DATA key);
-
-
 int ctdb_client_send_message(struct ctdb_context *ctdb, uint32_t vnn,
                             uint64_t srvid, TDB_DATA data);
 
@@ -956,14 +896,6 @@ int daemon_check_srvids(struct ctdb_context *ctdb, TDB_DATA indata,
 int32_t ctdb_ltdb_enable_seqnum(struct ctdb_context *ctdb, uint32_t db_id);
 int32_t ctdb_ltdb_update_seqnum(struct ctdb_context *ctdb, uint32_t db_id, uint32_t srcnode);
 
-struct ctdb_rec_data *ctdb_marshall_record(TALLOC_CTX *mem_ctx, uint32_t reqid,        
-                                          TDB_DATA key, struct ctdb_ltdb_header *, TDB_DATA data);
-
-struct ctdb_rec_data *ctdb_marshall_loop_next(struct ctdb_marshall_buffer *m, struct ctdb_rec_data *r,
-                                             uint32_t *reqid,
-                                             struct ctdb_ltdb_header *header,
-                                             TDB_DATA *key, TDB_DATA *data);
-
 int32_t ctdb_control_pull_db(struct ctdb_context *ctdb, TDB_DATA indata, TDB_DATA *outdata);
 int32_t ctdb_control_push_db(struct ctdb_context *ctdb, TDB_DATA indata);
 
@@ -1011,12 +943,6 @@ void ctdb_node_dead(struct ctdb_node *node);
 void ctdb_node_connected(struct ctdb_node *node);
 bool ctdb_blocking_freeze(struct ctdb_context *ctdb);
 
-struct tevent_signal *ctdb_init_sigchld(struct ctdb_context *ctdb);
-void ctdb_track_child(struct ctdb_context *ctdb, pid_t pid);
-pid_t ctdb_fork(struct ctdb_context *ctdb);
-void ctdb_set_child_info(TALLOC_CTX *mem_ctx, const char *child_name_fmt, ...);
-int ctdb_kill(struct ctdb_context *ctdb, pid_t pid, int signum);
-
 int32_t ctdb_control_takeover_ip(struct ctdb_context *ctdb, 
                                 struct ctdb_req_control *c,
                                 TDB_DATA indata, 
@@ -1262,11 +1188,6 @@ int ctdb_client_async_control(struct ctdb_context *ctdb,
                                client_async_callback fail_callback,
                                void *callback_data);
 
-struct ctdb_node_map *
-ctdb_node_list_to_map(struct ctdb_node **nodes, uint32_t num_nodes,
-                     TALLOC_CTX *mem_ctx);
-struct ctdb_node_map *ctdb_read_nodes_file(TALLOC_CTX *mem_ctx,
-                                          const char *nlist);
 void ctdb_load_nodes_file(struct ctdb_context *ctdb);
 
 int ctdb_control_reload_nodes_file(struct ctdb_context *ctdb, uint32_t opcode);
@@ -1274,10 +1195,6 @@ int ctdb_control_reload_nodes_file(struct ctdb_context *ctdb, uint32_t opcode);
 int32_t ctdb_dump_memory(struct ctdb_context *ctdb, TDB_DATA *outdata);
 int32_t ctdb_control_get_capabilities(struct ctdb_context *ctdb, TDB_DATA *outdata);
 
-char *ctdb_addr_to_str(ctdb_sock_addr *addr);
-unsigned ctdb_addr_to_port(ctdb_sock_addr *addr);
-void ctdb_canonicalize_ip(const ctdb_sock_addr *ip, ctdb_sock_addr *cip);
-
 int32_t ctdb_control_recd_ping(struct ctdb_context *ctdb);
 int32_t ctdb_control_set_recmaster(struct ctdb_context *ctdb, uint32_t opcode, TDB_DATA indata);
 
@@ -1381,12 +1298,6 @@ void ctdb_local_remove_from_delete_queue(struct ctdb_db_context *ctdb_db,
 
 struct ctdb_ltdb_header *ctdb_header_from_record_handle(struct ctdb_record_handle *h);
 
-int ctdb_trackingdb_add_pnn(struct ctdb_context *ctdb, TDB_DATA *data, uint32_t pnn);
-
-typedef void (*ctdb_trackingdb_cb)(struct ctdb_context *ctdb, uint32_t pnn, void *private_data);
-
-void ctdb_trackingdb_traverse(struct ctdb_context *ctdb, TDB_DATA data, ctdb_trackingdb_cb cb, void *private_data);
-
 int ctdb_start_revoke_ro_record(struct ctdb_context *ctdb, struct ctdb_db_context *ctdb_db, TDB_DATA key, struct ctdb_ltdb_header *header, TDB_DATA data);
 
 typedef void (*deferred_requeue_fn)(void *call_context, struct ctdb_req_header *hdr);
@@ -1395,12 +1306,6 @@ int ctdb_add_revoke_deferred_call(struct ctdb_context *ctdb, struct ctdb_db_cont
 
 int ctdb_set_db_readonly(struct ctdb_context *ctdb, struct ctdb_db_context *ctdb_db);
 
-int ctdb_null_func(struct ctdb_call_info *call);
-
-int ctdb_fetch_func(struct ctdb_call_info *call);
-
-int ctdb_fetch_with_header_func(struct ctdb_call_info *call);
-
 void ctdb_db_statistics_reset(struct ctdb_db_context *ctdb_db);
 
 int32_t ctdb_control_get_db_statistics(struct ctdb_context *ctdb,
index 8bc87257d4703025e4366aae695304583d7fee49..3c5f8854890e1a902a8babf5c031b91d001f4dc1 100644 (file)
@@ -32,6 +32,7 @@
 #include "ctdb_client.h"
 #include "ctdb_logging.h"
 
+#include "common/common.h"
 
 static void ctdb_ban_node_event(struct tevent_context *ev,
                                struct tevent_timer *te,
index 80716cdae05763e289f93c0ad0efc04f9683f235..16fe53aa5303201395ad38b1725cdecc3407d959 100644 (file)
@@ -38,6 +38,7 @@
 #include "common/rb_tree.h"
 #include "common/reqid.h"
 #include "common/system.h"
+#include "common/common.h"
 
 struct ctdb_sticky_record {
        struct ctdb_context *ctdb;
index 5e4516cbb37c8f80f92c6b0c29bde27b016b2ad5..21ace77471d3f60beac0684851933fac9abcabdd 100644 (file)
@@ -35,6 +35,7 @@
 #include "ctdb_logging.h"
 
 #include "common/reqid.h"
+#include "common/common.h"
 
 
 struct ctdb_control_state {
index 7371b05b1d92f2ff11a8acecd480a2628f53c16a..ef5dd3f25c0187cb649b213219771ad04e9ad9d3 100644 (file)
@@ -42,6 +42,7 @@
 #include "common/rb_tree.h"
 #include "common/reqid.h"
 #include "common/system.h"
+#include "common/common.h"
 
 struct ctdb_client_pid_list {
        struct ctdb_client_pid_list *next, *prev;
index 9d370648a0079fe76a93846e78306588127abe42..83a088fea03e3ef7b4ac348a2a886f7767c584d1 100644 (file)
@@ -32,7 +32,7 @@
 #include "ctdb_logging.h"
 
 #include "common/rb_tree.h"
-
+#include "common/common.h"
 
 /**
  * Cancel a transaction on database
index 6873d75f50a18c2e7f19682e37628fef35c887d0..05aa77ec9a22580293d96b3a950d772f0c4fe008 100644 (file)
@@ -33,6 +33,8 @@
 #include "ctdb_private.h"
 #include "ctdb_logging.h"
 
+#include "common/common.h"
+
 
 /*
   see if any nodes are dead
index cdda7ea85d045d73e0b54eb913848fb93569d8e6..3621ff1faad5a48c0ea33edb7c02826e72375b53 100644 (file)
@@ -34,6 +34,7 @@
 #include "ctdb_logging.h"
 
 #include "common/system.h"
+#include "common/common.h"
 
 /*
  * Non-blocking Locking API
index d4545a9d4c693eabaf16525d838b51f8db914c9d..ba2cf836ffa823e7329dc1cb578b5c19be378c69 100644 (file)
@@ -34,6 +34,7 @@
 #include "ctdb_logging.h"
 
 #include "common/system.h"
+#include "common/common.h"
 
 struct ctdb_log_backend {
        struct ctdb_log_backend *prev, *next;
index 1affada5f0ff1c5fa7e2b637bfb3088fe789b013..54cf7a0185784d9c2db1fe7a631ff45c6b95b2da 100644 (file)
@@ -39,6 +39,7 @@
 #include "common/rb_tree.h"
 #include "common/reqid.h"
 #include "common/system.h"
+#include "common/common.h"
 
 #define PERSISTENT_HEALTH_TDB "persistent_health.tdb"
 
index 4f861e82e2c312b3e90b12164e5db9453f9a2d89..50a3da45a176c6f46fb430c6a48fd4e2e402c313 100644 (file)
@@ -33,6 +33,7 @@
 #include "ctdb_logging.h"
 
 #include "common/system.h"
+#include "common/common.h"
 
 struct ctdb_monitor_state {
        uint32_t monitoring_mode;
index aa878044d33cd50b20354f6c465426f72f30884a..e5ad2fa7f6dc09d437330f3221f638933d6c5c2e 100644 (file)
@@ -35,6 +35,7 @@
 #include "ctdb_logging.h"
 
 #include "common/reqid.h"
+#include "common/common.h"
 
 struct ctdb_persistent_state {
        struct ctdb_context *ctdb;
index 23226d3bf0820f3399360caffc5658161e27cb21..c898b95e1ab46e1b289f2b1add3a2c954c9319f2 100644 (file)
@@ -37,6 +37,7 @@
 #include "ctdb_logging.h"
 
 #include "common/system.h"
+#include "common/common.h"
 
 int 
 ctdb_control_getvnnmap(struct ctdb_context *ctdb, uint32_t opcode, TDB_DATA indata, TDB_DATA *outdata)
index 8eaed2b7bed03eed9d3306b64fd74ee3603ac3b2..1db768120e8170cc69c1078025b98d1ed20476ba 100644 (file)
@@ -39,6 +39,7 @@
 
 #include "common/system.h"
 #include "common/cmdline.h"
+#include "common/common.h"
 
 
 /* List of SRVID requests that need to be processed */
index 95ded1426711f67c10b1817385186806673cf574..3ad24c977f70db3878d0cf9c460a4044b883d64a 100644 (file)
@@ -32,6 +32,8 @@
 #include "ctdb_client.h"
 #include "ctdb_logging.h"
 
+#include "common/common.h"
+
 /*
   choose the transport we will use
 */
index 9186cc5beeef2500dbf4e4d86b6f1cd85cdc1947..80878fe1701f08ce70027180c916e365a8f24499 100644 (file)
@@ -28,6 +28,7 @@
 
 #include "common/rb_tree.h"
 #include "common/reqid.h"
+#include "common/common.h"
 
 
 #define SERVER_ID_KEY_SIZE 3
index c806178b50aedcffc77d2523671db7f0bad30176..61a3a8d5a2ce724d7d32cd2b7606b921a6e946f0 100644 (file)
@@ -38,6 +38,7 @@
 #include "common/rb_tree.h"
 #include "common/reqid.h"
 #include "common/system.h"
+#include "common/common.h"
 
 
 #define TAKEOVER_TIMEOUT() timeval_current_ofs(ctdb->tunable.takeover_timeout,0)
index 4cdb3d02dfd69ec72a8a0f02043768b04d3e7499..da13a0e692fbeebe4b65097e29cb513d6429602f 100644 (file)
@@ -37,6 +37,7 @@
 
 #include "common/reqid.h"
 #include "common/system.h"
+#include "common/common.h"
 
 typedef void (*ctdb_traverse_fn_t)(void *private_data, TDB_DATA key, TDB_DATA data);
 
index 230a315b73ad1e8713f052052305d750ef83f0ed..0644a67497dd3f8596628a17df95289cd2c5cc1e 100644 (file)
@@ -27,6 +27,8 @@
 #include "ctdb_private.h"
 #include "ctdb_logging.h"
 
+#include "common/common.h"
+
 static const struct {
        const char *name;
        uint32_t default_v;
index 1c3fef2a07139c3be349e217e223a770abaab7de..17d4df5450ee6de3a25d11a4019361497b56488e 100644 (file)
@@ -34,6 +34,7 @@
 #include "ctdb_logging.h"
 
 #include "common/system.h"
+#include "common/common.h"
 
 struct ctdb_persistent_write_state {
        struct ctdb_db_context *ctdb_db;
index 7968cdc37d6b1c09a047ab95bd389d9a54610b29..3e028e8a4e1e86acdf615f26e06d95059e043aa5 100644 (file)
@@ -31,6 +31,8 @@
 #include "ctdb_client.h"
 #include "ctdb_logging.h"
 
+#include "common/common.h"
+
 /* 
    returns the ctdb uptime
 */
index 3d61befd620de8396f97c660d2ef3039df90c8a5..53b20b92b3d485e450baa0bf7303c6e7d168f467 100644 (file)
@@ -38,6 +38,7 @@
 
 #include "common/rb_tree.h"
 #include "common/system.h"
+#include "common/common.h"
 
 #define TIMELIMIT() timeval_current_ofs(10, 0)
 
index 58313844174b8c855b84527b4a282eb222021cce..7e5bf951696d2c9eb1a30b15a9fed8389ae86b87 100644 (file)
@@ -38,6 +38,7 @@
 #include "common/reqid.h"
 #include "common/system.h"
 #include "common/cmdline.h"
+#include "common/common.h"
 
 static struct {
        const char *nlist;
index 2fac047626a42217c5d005d1c50102248585072d..2c5dfae9165e1e7c6ba76991225a586ffdb90512 100644 (file)
@@ -37,6 +37,7 @@
 
 #include "common/rb_tree.h"
 #include "common/system.h"
+#include "common/common.h"
 
 
 static void ctdb_event_script_timeout(struct tevent_context *ev,
index 0b18c968e1ed90212df8d96c228c86923d81cae6..0fee1acb22ebb4118bb0ec276aad620ce8be815b 100644 (file)
@@ -32,6 +32,7 @@
 #include "ctdb_private.h"
 
 #include "common/system.h"
+#include "common/common.h"
 
 #include "ctdb_tcp.h"
 
index 02f580277ef90b50bd3c1ee4f3674ab9449746d3..c1791e08813baf951d087d53246268c75c72f97d 100644 (file)
@@ -30,6 +30,8 @@
 #include "ctdb_logging.h"
 #include "ctdb_private.h"
 
+#include "common/common.h"
+
 #include "ctdb_tcp.h"
 
 static int tnode_destructor(struct ctdb_tcp_node *tnode)
index 5be8d85e5334de1621240c111fcbf77b40a64c1f..210881988ee89598c5914101b9b075d750e05197 100644 (file)
@@ -27,6 +27,8 @@
 #include "ctdb_logging.h"
 #include "ctdb_private.h"
 
+#include "common/common.h"
+
 #include "ctdb_tcp.h"
 
 
index 1b0c30bc6ab9e6ac4b791a54ffc9e5d18d87ff67..536782c8e6b5da8c184809e86c33486520c274bb 100644 (file)
 #include "lib/util/time.h"
 #include "lib/util/debug.h"
 
-#include "common/cmdline.h"
-
 #include "ctdb_logging.h"
 #include "ctdb_private.h"
 #include "ctdb_client.h"
 
+#include "common/cmdline.h"
+#include "common/common.h"
+
 static struct timeval tp1,tp2;
 
 static void start_timer(void)
index 592332b14c0f66e868f4413c79f21cdd8f7803ee..600504b82b2f2ce0b8ea3cce41f8782b652b0b6b 100644 (file)
 
 #include "lib/util/time.h"
 
+#include "ctdb_private.h"
 #include "ctdb_client.h"
 
 #include "common/cmdline.h"
+#include "common/common.h"
 
 
 static struct timeval tp1,tp2;
index b92014a383fa45e8e3237ca7fd92ab797c747467..e24684f615a6e35f99d6da6475cc8856370dd3c5 100644 (file)
 
 #include "lib/util/time.h"
 
+#include "ctdb_private.h"
 #include "ctdb_client.h"
 
 #include "common/cmdline.h"
+#include "common/common.h"
 
 static int timelimit = 10;
 static int lock_count = 0;
index 29d7c2dcee6b1bd40c1d26e6abe9b924534e1ac2..3e4cc038d7a208d84632dd079d5d6de5b0cb8345 100644 (file)
@@ -34,6 +34,7 @@
 #include "ctdb_client.h"
 
 #include "common/cmdline.h"
+#include "common/common.h"
 
 static struct ctdb_db_context *ctdb_db;
 
index 206f52da7a06418216b853aabd6e591276e5fdeb..211927363fcdfab28306c9ffab9e0520e4a00445 100644 (file)
 
 #include "lib/util/time.h"
 
+#include "ctdb_private.h"
 #include "ctdb_client.h"
 
+#include "common/common.h"
+#include "common/cmdline.h"
+
 const char *TESTKEY = "testkey";
 
 /*
index ac3e15d457e7610fd14ed41b9feb983cd0ef485d..df777f4878fa71f8e38553610837c6218723d935 100644 (file)
 #include "lib/util/debug.h"
 #include "lib/util/time.h"
 
-#include "common/cmdline.h"
-
+#include "ctdb_private.h"
 #include "ctdb_logging.h"
 #include "ctdb_client.h"
 
+#include "common/cmdline.h"
+#include "common/common.h"
+
 static struct timeval tp1,tp2;
 
 static void start_timer(void)
index 8718faaa7df4a9327521fb8b1ee6660cc5fdc2bf..f539422df4afa00c7257846e972ce407945fff87 100644 (file)
 
 #include "lib/util/debug.h"
 
+#include "ctdb_private.h"
 #include "ctdb_logging.h"
 #include "ctdb_client.h"
 
 #include "common/cmdline.h"
 #include "common/system.h"
+#include "common/common.h"
 
 
 static struct {
index c861d318d31f2fc6a0dc96bca3bf0ac87a03cd12..6d9a3d1a6374367baec18ea38daeffd94707692c 100644 (file)
 #include "lib/util/debug.h"
 #include "lib/util/time.h"
 
-#include "common/cmdline.h"
-
 #include "ctdb_logging.h"
 #include "ctdb_private.h"
 #include "ctdb_client.h"
 
+#include "common/cmdline.h"
+#include "common/common.h"
+
 static struct timeval tp1,tp2;
 
 static void start_timer(void)
index 756c98db3ec8b5942e5fe059dd0cf064a8186f19..0405e831f820db0e7a43088bf1f2a5d5a4f4e6c6 100644 (file)
 
 #include "lib/util/time.h"
 
-#include "common/cmdline.h"
-
+#include "ctdb_private.h"
 #include "ctdb_client.h"
 
+#include "common/cmdline.h"
+#include "common/common.h"
+
 static int num_records = 10;
 static int base_rec;
 
index a3764e35ab1f377dbde90fbcf77d0973f8d57905..0e0471c3431cea9f2735ce90efcbefc72fcaacd3 100644 (file)
 #include "lib/tdb_wrap/tdb_wrap.h"
 #include "lib/util/time.h"
 
-#include "common/cmdline.h"
-
 #include "ctdb_private.h"
 
+#include "common/cmdline.h"
+#include "common/common.h"
+
 #define MAXINDEX 64
 char indices[MAXINDEX];
 
index 50ff6ce20b3e6a6c3cdbf25072a6f1819ac1a4a3..b7a3e32d9f6654b2e2a136088ae825ccb7f65bac 100644 (file)
 #include "lib/util/debug.h"
 #include "lib/util/time.h"
 
+#include "ctdb_private.h"
 #include "ctdb_logging.h"
 #include "ctdb_client.h"
 
 #include "common/cmdline.h"
+#include "common/common.h"
 
 static struct timeval tp1,tp2;
 
index 7dc347e59c48cc3a345c7f10037441676aa6b1c7..d69c8e043dbc611dce1ac01ff20f91d90e3e5084 100644 (file)
 
 #include "lib/util/time.h"
 
-#include "common/cmdline.h"
-
+#include "ctdb_private.h"
 #include "ctdb_client.h"
 
+#include "common/cmdline.h"
+#include "common/common.h"
+
 static const char *dbname = "test.tdb";
 
 static int traverse_callback(TDB_DATA key, TDB_DATA data, void *private_data)
index 971afc73bd9cd37a2005f214ef90726a0bfd61ab..7b5b544996738656e756b083efb6551a2ca2169d 100644 (file)
@@ -32,6 +32,7 @@
 #include "ctdb_client.h"
 
 #include "common/cmdline.h"
+#include "common/common.h"
 
 static struct ctdb_db_context *ctdb_db;
 
index ca138914fd7143907ee0d74bae902f813a30c03a..10dc54bbfdf2a5887bd18ff1a77c6fb4d4ef7b7d 100644 (file)
@@ -33,6 +33,7 @@
 #include "ctdb_client.h"
 
 #include "common/cmdline.h"
+#include "common/common.h"
 
 
 static void update_once(struct ctdb_context *ctdb, struct tevent_context *ev,
index 283a3141abfe507d7a884935fbdf9bf179981b18..1f94fd1321644d2ecdc72cea0c41897d8d4e2290 100644 (file)
@@ -19,6 +19,7 @@
 
 #include "replace.h"
 #include "system/filesys.h"
+#include "system/network.h"
 #include "system/time.h"
 
 #include <popt.h>
 
 #include "lib/util/dlinklist.h"
 
-#include "common/cmdline.h"
+#include "ctdb_private.h"
+
 #include "common/rb_tree.h"
+#include "common/cmdline.h"
+#include "common/common.h"
 
 static struct timeval tp1,tp2;
 
index 976fe6178f897b1c03afa837692ce10573ca2f88..d731fb4da42b8339268abfcc602d6e860eaad0bd 100644 (file)
@@ -45,6 +45,7 @@
 #include "common/cmdline.h"
 #include "common/rb_tree.h"
 #include "common/system.h"
+#include "common/common.h"
 
 #define ERR_TIMEOUT    20      /* timed out trying to reach node */
 #define ERR_NONODE     21      /* node does not exist */
index 13c2d6fea1fa044ff060c9e92037b3ac35bc3ae2..e76b4b2e2625bebc19eba052a658d131247e236d 100644 (file)
@@ -32,6 +32,7 @@
 #include "ctdb_protocol.h"
 
 #include "common/system.h"
+#include "common/common.h"
 
 #include <pcp/pmapi.h>
 #include <pcp/impl.h>