4 Copyright (C) Andrew Tridgell 2006
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 3 of the License, or
9 (at your option) any later version.
11 This program is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with this program; if not, see <http://www.gnu.org/licenses/>.
20 #ifndef _CTDB_PROTOCOL_H
21 #define _CTDB_PROTOCOL_H
23 #include <sys/socket.h>
25 /* default ctdb port number */
26 #define CTDB_PORT 4379
28 /* we must align packets to ensure ctdb works on all architectures (eg. sparc) */
29 #define CTDB_DS_ALIGNMENT 8
32 #define CTDB_NULL_FUNC 0xFF000001
33 #define CTDB_FETCH_FUNC 0xFF000002
34 #define CTDB_FETCH_WITH_HEADER_FUNC 0xFF000003
43 #define CTDB_IMMEDIATE_MIGRATION 0x00000001
44 #define CTDB_CALL_FLAG_VACUUM_MIGRATION 0x00000002
45 #define CTDB_WANT_READONLY 0x00000004
50 structure passed to a ctdb call backend function
52 struct ctdb_call_info {
53 TDB_DATA key; /* record key */
54 struct ctdb_ltdb_header *header;
55 TDB_DATA record_data; /* current data in the record */
56 TDB_DATA *new_data; /* optionally updated record data */
57 TDB_DATA *call_data; /* optionally passed from caller */
58 TDB_DATA *reply_data; /* optionally returned by function */
59 uint32_t status; /* optional reply status - defaults to zero */
62 #define CTDB_ERR_INVALID 1
63 #define CTDB_ERR_NOMEM 2
68 #define CTDB_FLAG_TORTURE (1<<1)
71 a message handler ID meaning "give me all messages"
73 #define CTDB_SRVID_ALL (~(uint64_t)0)
78 #define CTDB_SRVID_RECOVERY 0xF100000000000000LL
81 a message handler ID meaning that the cluster has been reconfigured
83 #define CTDB_SRVID_RECONFIGURE 0xF200000000000000LL
86 a message handler ID meaning that an IP address has been released
88 #define CTDB_SRVID_RELEASE_IP 0xF300000000000000LL
91 a message handler ID meaning that an IP address has been taken
93 #define CTDB_SRVID_TAKE_IP 0xF301000000000000LL
96 a message ID to set the node flags in the recovery daemon
98 #define CTDB_SRVID_SET_NODE_FLAGS 0xF400000000000000LL
101 a message ID to ask the recovery daemon to update the expected node
102 assignment for a public ip
104 #define CTDB_SRVID_RECD_UPDATE_IP 0xF500000000000000LL
107 a message to tell the recovery daemon to fetch a set of records
109 #define CTDB_SRVID_VACUUM_FETCH 0xF700000000000000LL
112 * a message to tell recovery daemon to detach a database
114 #define CTDB_SRVID_DETACH_DATABASE 0xF701000000000000LL
116 a message to tell the recovery daemon to write a talloc memdump
119 #define CTDB_SRVID_MEM_DUMP 0xF800000000000000LL
121 /* A message id used to ask the recover daemon to send logs
123 #define CTDB_SRVID_GETLOG 0xF801000000000000LL
125 /* A message id used to ask the recover daemon to send logs
127 #define CTDB_SRVID_CLEARLOG 0xF802000000000000LL
130 a message ID to get the recovery daemon to push the node flags out
132 #define CTDB_SRVID_PUSH_NODE_FLAGS 0xF900000000000000LL
135 a message ID to get the recovery daemon to reload the nodes file
137 #define CTDB_SRVID_RELOAD_NODES 0xFA00000000000000LL
140 a message ID to get the recovery daemon to perform a takeover run
142 #define CTDB_SRVID_TAKEOVER_RUN 0xFB00000000000000LL
144 /* request recovery daemon to rebalance ips for a node.
145 input is uint32_t for the node id.
147 #define CTDB_SRVID_REBALANCE_NODE 0xFB01000000000000LL
149 /* A message handler ID to stop takeover runs from occurring */
150 #define CTDB_SRVID_DISABLE_TAKEOVER_RUNS 0xFB03000000000000LL
152 /* A message handler ID to stop recoveries from occurring */
153 #define CTDB_SRVID_DISABLE_RECOVERIES 0xFB04000000000000LL
155 /* A message id to ask the recovery daemon to temporarily disable the
158 #define CTDB_SRVID_DISABLE_IP_CHECK 0xFC00000000000000LL
160 /* A dummy port used for sending back ipreallocate resposnes to the main
163 #define CTDB_SRVID_TAKEOVER_RUN_RESPONSE 0xFD00000000000000LL
165 /* A range of ports reserved for registering a PID (top 8 bits)
166 * All ports matching the 8 top bits are reserved for exclusive use by
167 * registering a SRVID that matches the process-id of the requesting process
169 #define CTDB_SRVID_PID_RANGE 0x0000000000000000LL
171 /* A range of ports reserved for samba (top 8 bits)
172 * All ports matching the 8 top bits are reserved for exclusive use by
175 #define CTDB_SRVID_SAMBA_NOTIFY 0xFE00000000000000LL
176 #define CTDB_SRVID_SAMBA_RANGE 0xFE00000000000000LL
178 /* A range of ports reserved for a CTDB NFS server (top 8 bits)
179 * All ports matching the 8 top bits are reserved for exclusive use by
182 #define CTDB_SRVID_NFSD_RANGE 0xEE00000000000000LL
184 /* A range of ports reserved for a CTDB ISCSI server (top 8 bits)
185 * All ports matching the 8 top bits are reserved for exclusive use by
188 #define CTDB_SRVID_ISCSID_RANGE 0xDE00000000000000LL
190 /* A range of ports reserved for testing (top 8 bits)
191 * All ports matching the 8 top bits are reserved for exclusive use by
194 #define CTDB_SRVID_TEST_RANGE 0xCE00000000000000LL
196 /* Range of ports reserved for traversals */
197 #define CTDB_SRVID_TRAVERSE_RANGE 0xBE00000000000000LL
199 /* used on the domain socket, send a pdu to the local daemon */
200 #define CTDB_CURRENT_NODE 0xF0000001
201 /* send a broadcast to all nodes in the cluster, active or not */
202 #define CTDB_BROADCAST_ALL 0xF0000002
203 /* send a broadcast to all nodes in the current vnn map */
204 #define CTDB_BROADCAST_VNNMAP 0xF0000003
205 /* send a broadcast to all connected nodes */
206 #define CTDB_BROADCAST_CONNECTED 0xF0000004
207 /* send a broadcast to selected connected nodes */
208 #define CTDB_MULTICAST 0xF0000005
210 /* the key used for transaction locking on persistent databases */
211 #define CTDB_TRANSACTION_LOCK_KEY "__transaction_lock__"
213 /* the key used to store persistent db sequence number */
214 #define CTDB_DB_SEQNUM_KEY "__db_sequence_number__"
216 #define MONITOR_SCRIPT_OK 0
217 #define MONITOR_SCRIPT_TIMEOUT 1
219 #define MAX_SCRIPT_NAME 31
220 #define MAX_SCRIPT_OUTPUT 511
222 char name[MAX_SCRIPT_NAME+1];
223 struct timeval start;
224 struct timeval finished;
226 char output[MAX_SCRIPT_OUTPUT+1];
229 struct ctdb_script_list_old {
230 uint32_t num_scripts;
231 struct ctdb_script scripts[1];
234 /* different calls to event scripts. */
236 CTDB_EVENT_INIT, /* CTDB starting up: no args */
237 CTDB_EVENT_SETUP, /* CTDB starting up after transport is readdy: no args. */
238 CTDB_EVENT_STARTUP, /* CTDB starting up after initial recovery: no args. */
239 CTDB_EVENT_START_RECOVERY, /* CTDB recovery starting: no args. */
240 CTDB_EVENT_RECOVERED, /* CTDB recovery finished: no args. */
241 CTDB_EVENT_TAKE_IP, /* IP taken: interface, IP address, netmask bits. */
242 CTDB_EVENT_RELEASE_IP, /* IP released: interface, IP address, netmask bits. */
243 CTDB_EVENT_STOPPED, /* Deprecated, do not use. */
244 CTDB_EVENT_MONITOR, /* Please check if service is healthy: no args. */
245 CTDB_EVENT_STATUS, /* Deprecated, do not use. */
246 CTDB_EVENT_SHUTDOWN, /* CTDB shutting down: no args. */
247 CTDB_EVENT_RELOAD, /* Deprecated, do not use */
248 CTDB_EVENT_UPDATE_IP, /* IP updating: old interface, new interface, IP address, netmask bits. */
249 CTDB_EVENT_IPREALLOCATED, /* when a takeover_run() completes */
253 /* Mapping from enum to names. */
254 extern const char *ctdb_eventscript_call_names[];
259 enum ctdb_operation {
262 CTDB_REQ_DMASTER = 2,
263 CTDB_REPLY_DMASTER = 3,
264 CTDB_REPLY_ERROR = 4,
265 CTDB_REQ_MESSAGE = 5,
267 CTDB_REQ_CONTROL = 7,
268 CTDB_REPLY_CONTROL = 8,
269 CTDB_REQ_KEEPALIVE = 9,
272 #define CTDB_MAGIC 0x43544442 /* CTDB */
273 #define CTDB_PROTOCOL 1
275 enum ctdb_controls {CTDB_CONTROL_PROCESS_EXISTS = 0,
276 CTDB_CONTROL_STATISTICS = 1,
278 CTDB_CONTROL_PING = 3,
279 CTDB_CONTROL_GETDBPATH = 4,
280 CTDB_CONTROL_GETVNNMAP = 5,
281 CTDB_CONTROL_SETVNNMAP = 6,
282 CTDB_CONTROL_GET_DEBUG = 7,
283 CTDB_CONTROL_SET_DEBUG = 8,
284 CTDB_CONTROL_GET_DBMAP = 9,
285 CTDB_CONTROL_GET_NODEMAPv4 = 10, /* obsolete */
286 CTDB_CONTROL_SET_DMASTER = 11, /* obsolete */
288 CTDB_CONTROL_PULL_DB = 13,
289 CTDB_CONTROL_PUSH_DB = 14,
290 CTDB_CONTROL_GET_RECMODE = 15,
291 CTDB_CONTROL_SET_RECMODE = 16,
292 CTDB_CONTROL_STATISTICS_RESET = 17,
293 CTDB_CONTROL_DB_ATTACH = 18,
294 CTDB_CONTROL_SET_CALL = 19, /* obsolete */
295 CTDB_CONTROL_TRAVERSE_START = 20,
296 CTDB_CONTROL_TRAVERSE_ALL = 21,
297 CTDB_CONTROL_TRAVERSE_DATA = 22,
298 CTDB_CONTROL_REGISTER_SRVID = 23,
299 CTDB_CONTROL_DEREGISTER_SRVID = 24,
300 CTDB_CONTROL_GET_DBNAME = 25,
301 CTDB_CONTROL_ENABLE_SEQNUM = 26,
302 CTDB_CONTROL_UPDATE_SEQNUM = 27,
304 CTDB_CONTROL_DUMP_MEMORY = 29,
305 CTDB_CONTROL_GET_PID = 30,
306 CTDB_CONTROL_GET_RECMASTER = 31,
307 CTDB_CONTROL_SET_RECMASTER = 32,
308 CTDB_CONTROL_FREEZE = 33,
309 CTDB_CONTROL_THAW = 34,
310 CTDB_CONTROL_GET_PNN = 35,
311 CTDB_CONTROL_SHUTDOWN = 36,
312 CTDB_CONTROL_GET_MONMODE = 37,
317 CTDB_CONTROL_TAKEOVER_IPv4 = 42, /* obsolete */
318 CTDB_CONTROL_RELEASE_IPv4 = 43, /* obsolete */
319 CTDB_CONTROL_TCP_CLIENT = 44,
320 CTDB_CONTROL_TCP_ADD = 45,
321 CTDB_CONTROL_TCP_REMOVE = 46,
322 CTDB_CONTROL_STARTUP = 47,
323 CTDB_CONTROL_SET_TUNABLE = 48,
324 CTDB_CONTROL_GET_TUNABLE = 49,
325 CTDB_CONTROL_LIST_TUNABLES = 50,
326 CTDB_CONTROL_GET_PUBLIC_IPSv4 = 51, /* obsolete */
327 CTDB_CONTROL_MODIFY_FLAGS = 52,
328 CTDB_CONTROL_GET_ALL_TUNABLES = 53,
329 CTDB_CONTROL_KILL_TCP = 54,
330 CTDB_CONTROL_GET_TCP_TICKLE_LIST = 55,
331 CTDB_CONTROL_SET_TCP_TICKLE_LIST = 56,
332 CTDB_CONTROL_REGISTER_SERVER_ID = 57,
333 CTDB_CONTROL_UNREGISTER_SERVER_ID = 58,
334 CTDB_CONTROL_CHECK_SERVER_ID = 59,
335 CTDB_CONTROL_GET_SERVER_ID_LIST = 60,
336 CTDB_CONTROL_DB_ATTACH_PERSISTENT = 61,
337 CTDB_CONTROL_PERSISTENT_STORE = 62, /* obsolete */
338 CTDB_CONTROL_UPDATE_RECORD = 63,
339 CTDB_CONTROL_SEND_GRATIOUS_ARP = 64,
340 CTDB_CONTROL_TRANSACTION_START = 65,
341 CTDB_CONTROL_TRANSACTION_COMMIT = 66,
342 CTDB_CONTROL_WIPE_DATABASE = 67,
344 CTDB_CONTROL_UPTIME = 69,
345 CTDB_CONTROL_START_RECOVERY = 70,
346 CTDB_CONTROL_END_RECOVERY = 71,
347 CTDB_CONTROL_RELOAD_NODES_FILE = 72,
349 CTDB_CONTROL_TRY_DELETE_RECORDS = 74,
350 CTDB_CONTROL_ENABLE_MONITOR = 75,
351 CTDB_CONTROL_DISABLE_MONITOR = 76,
352 CTDB_CONTROL_ADD_PUBLIC_IP = 77,
353 CTDB_CONTROL_DEL_PUBLIC_IP = 78,
354 CTDB_CONTROL_RUN_EVENTSCRIPTS = 79,
355 CTDB_CONTROL_GET_CAPABILITIES = 80,
356 CTDB_CONTROL_START_PERSISTENT_UPDATE = 81,
357 CTDB_CONTROL_CANCEL_PERSISTENT_UPDATE= 82,
358 CTDB_CONTROL_TRANS2_COMMIT = 83, /* obsolete */
359 CTDB_CONTROL_TRANS2_FINISHED = 84, /* obsolete */
360 CTDB_CONTROL_TRANS2_ERROR = 85, /* obsolete */
361 CTDB_CONTROL_TRANS2_COMMIT_RETRY = 86, /* obsolete */
362 CTDB_CONTROL_RECD_PING = 87,
363 CTDB_CONTROL_RELEASE_IP = 88,
364 CTDB_CONTROL_TAKEOVER_IP = 89,
365 CTDB_CONTROL_GET_PUBLIC_IPS = 90,
366 CTDB_CONTROL_GET_NODEMAP = 91,
367 CTDB_CONTROL_GET_EVENT_SCRIPT_STATUS = 96,
368 CTDB_CONTROL_TRAVERSE_KILL = 97,
369 CTDB_CONTROL_RECD_RECLOCK_LATENCY = 98,
370 CTDB_CONTROL_GET_RECLOCK_FILE = 99,
371 CTDB_CONTROL_SET_RECLOCK_FILE = 100,
372 CTDB_CONTROL_STOP_NODE = 101,
373 CTDB_CONTROL_CONTINUE_NODE = 102,
374 CTDB_CONTROL_SET_NATGWSTATE = 103,
375 CTDB_CONTROL_SET_LMASTERROLE = 104,
376 CTDB_CONTROL_SET_RECMASTERROLE = 105,
377 CTDB_CONTROL_ENABLE_SCRIPT = 107,
378 CTDB_CONTROL_DISABLE_SCRIPT = 108,
379 CTDB_CONTROL_SET_BAN_STATE = 109,
380 CTDB_CONTROL_GET_BAN_STATE = 110,
381 CTDB_CONTROL_SET_DB_PRIORITY = 111,
382 CTDB_CONTROL_GET_DB_PRIORITY = 112,
383 CTDB_CONTROL_TRANSACTION_CANCEL = 113,
384 CTDB_CONTROL_REGISTER_NOTIFY = 114,
385 CTDB_CONTROL_DEREGISTER_NOTIFY = 115,
386 CTDB_CONTROL_TRANS2_ACTIVE = 116, /* obsolete */
387 CTDB_CONTROL_GET_LOG = 117, /* obsolete */
388 CTDB_CONTROL_CLEAR_LOG = 118, /* obsolete */
389 CTDB_CONTROL_TRANS3_COMMIT = 119,
390 CTDB_CONTROL_GET_DB_SEQNUM = 120,
391 CTDB_CONTROL_DB_SET_HEALTHY = 121,
392 CTDB_CONTROL_DB_GET_HEALTH = 122,
393 CTDB_CONTROL_GET_PUBLIC_IP_INFO = 123,
394 CTDB_CONTROL_GET_IFACES = 124,
395 CTDB_CONTROL_SET_IFACE_LINK_STATE = 125,
396 CTDB_CONTROL_TCP_ADD_DELAYED_UPDATE = 126,
397 CTDB_CONTROL_GET_STAT_HISTORY = 127,
398 CTDB_CONTROL_SCHEDULE_FOR_DELETION = 128,
399 CTDB_CONTROL_SET_DB_READONLY = 129,
400 CTDB_CONTROL_CHECK_SRVIDS = 130,
401 CTDB_CONTROL_TRAVERSE_START_EXT = 131,
402 CTDB_CONTROL_GET_DB_STATISTICS = 132,
403 CTDB_CONTROL_SET_DB_STICKY = 133,
404 CTDB_CONTROL_RELOAD_PUBLIC_IPS = 134,
405 CTDB_CONTROL_TRAVERSE_ALL_EXT = 135,
406 CTDB_CONTROL_RECEIVE_RECORDS = 136,
407 CTDB_CONTROL_IPREALLOCATED = 137,
408 CTDB_CONTROL_GET_RUNSTATE = 138,
409 CTDB_CONTROL_DB_DETACH = 139,
410 CTDB_CONTROL_GET_NODES_FILE = 140,
411 CTDB_CONTROL_DB_FREEZE = 141,
412 CTDB_CONTROL_DB_THAW = 142,
413 CTDB_CONTROL_DB_TRANSACTION_START = 143,
414 CTDB_CONTROL_DB_TRANSACTION_COMMIT = 144,
415 CTDB_CONTROL_DB_TRANSACTION_CANCEL = 145,
421 struct ctdb_req_header {
424 uint32_t ctdb_version;
432 struct ctdb_req_call_old {
433 struct ctdb_req_header hdr;
439 uint32_t calldatalen;
440 uint8_t data[1]; /* key[] followed by calldata[] */
443 struct ctdb_reply_call_old {
444 struct ctdb_req_header hdr;
450 struct ctdb_reply_error_old {
451 struct ctdb_req_header hdr;
457 struct ctdb_req_dmaster_old {
458 struct ctdb_req_header hdr;
467 struct ctdb_reply_dmaster_old {
468 struct ctdb_req_header hdr;
476 struct ctdb_req_message_old {
477 struct ctdb_req_header hdr;
483 struct ctdb_req_control_old {
484 struct ctdb_req_header hdr;
489 #define CTDB_CTRL_FLAG_NOREPLY 1
490 #define CTDB_CTRL_FLAG_OPCODE_SPECIFIC 0xFFFF0000
496 struct ctdb_reply_control_old {
497 struct ctdb_req_header hdr;
504 struct ctdb_req_keepalive_old {
505 struct ctdb_req_header hdr;
510 the extended header for records in the ltdb
512 struct ctdb_ltdb_header {
516 #define CTDB_REC_FLAG_DEFAULT 0x00000000
517 #define CTDB_REC_FLAG_MIGRATED_WITH_DATA 0x00010000
518 #define CTDB_REC_FLAG_VACUUM_MIGRATED 0x00020000
519 #define CTDB_REC_FLAG_AUTOMATIC 0x00040000
520 #define CTDB_REC_RO_HAVE_DELEGATIONS 0x01000000
521 #define CTDB_REC_RO_HAVE_READONLY 0x02000000
522 #define CTDB_REC_RO_REVOKING_READONLY 0x04000000
523 #define CTDB_REC_RO_REVOKE_COMPLETE 0x08000000
524 #define CTDB_REC_RO_FLAGS (CTDB_REC_RO_HAVE_DELEGATIONS|\
525 CTDB_REC_RO_HAVE_READONLY|\
526 CTDB_REC_RO_REVOKING_READONLY|\
527 CTDB_REC_RO_REVOKE_COMPLETE)
533 definitions for different socket structures
537 struct sockaddr_in ip;
538 struct sockaddr_in6 ip6;
542 A structure describing a single node, its flags and its address
544 struct ctdb_node_and_flags {
552 Structure used for a nodemap.
553 The nodemap is the structure containing a list of all nodes
554 known to the cluster and their associated flags.
556 struct ctdb_node_map_old {
558 struct ctdb_node_and_flags nodes[1];
564 #define NODE_FLAGS_DISCONNECTED 0x00000001 /* node isn't connected */
565 #define NODE_FLAGS_UNHEALTHY 0x00000002 /* monitoring says node is unhealthy */
566 #define NODE_FLAGS_PERMANENTLY_DISABLED 0x00000004 /* administrator has disabled node */
567 #define NODE_FLAGS_BANNED 0x00000008 /* recovery daemon has banned the node */
568 #define NODE_FLAGS_DELETED 0x00000010 /* this node has been deleted */
569 #define NODE_FLAGS_STOPPED 0x00000020 /* this node has been stopped */
570 #define NODE_FLAGS_DISABLED (NODE_FLAGS_UNHEALTHY|NODE_FLAGS_PERMANENTLY_DISABLED)
571 #define NODE_FLAGS_INACTIVE (NODE_FLAGS_DELETED|NODE_FLAGS_DISCONNECTED|NODE_FLAGS_BANNED|NODE_FLAGS_STOPPED)
576 #define CTDB_CAP_RECMASTER 0x00000001
577 #define CTDB_CAP_LMASTER 0x00000002
578 /* This capability is set if CTDB_LVS_PUBLIC_IP is set */
579 #define CTDB_CAP_LVS 0x00000004
580 /* This capability is set if NATGW is enabled */
581 #define CTDB_CAP_NATGW 0x00000008
586 #define CTDB_CAP_PARALLEL_RECOVERY 0x00010000
588 #define CTDB_CAP_FEATURES (CTDB_CAP_PARALLEL_RECOVERY)
590 #define CTDB_CAP_DEFAULT (CTDB_CAP_RECMASTER | \
594 struct ctdb_public_ip {
599 struct ctdb_public_ip_list_old {
601 struct ctdb_public_ip ips[1];
605 struct ctdb_latency_counter {
613 structure used to pass record data between the child and parent
615 struct ctdb_rec_data_old {
623 struct ctdb_traverse_start {
629 struct ctdb_traverse_start_ext {
633 bool withemptyrecords;
637 ctdb statistics information
639 #define MAX_COUNT_BUCKETS 16
640 #define MAX_HOT_KEYS 10
642 struct ctdb_statistics {
643 uint32_t num_clients;
646 uint32_t client_packets_sent;
647 uint32_t client_packets_recv;
648 uint32_t node_packets_sent;
649 uint32_t node_packets_recv;
650 uint32_t keepalive_packets_sent;
651 uint32_t keepalive_packets_recv;
655 uint32_t req_dmaster;
656 uint32_t reply_dmaster;
657 uint32_t reply_error;
658 uint32_t req_message;
659 uint32_t req_control;
660 uint32_t reply_control;
664 uint32_t req_message;
665 uint32_t req_control;
673 struct ctdb_latency_counter ctdbd;
674 struct ctdb_latency_counter recd;
678 uint32_t num_current;
679 uint32_t num_pending;
681 struct ctdb_latency_counter latency;
682 uint32_t buckets[MAX_COUNT_BUCKETS];
684 uint32_t total_calls;
685 uint32_t pending_calls;
686 uint32_t childwrite_calls;
687 uint32_t pending_childwrite_calls;
688 uint32_t memory_used;
689 uint32_t __last_counter; /* hack for control_statistics_all */
690 uint32_t max_hop_count;
691 uint32_t hop_count_bucket[MAX_COUNT_BUCKETS];
692 struct ctdb_latency_counter call_latency;
693 struct ctdb_latency_counter childwrite_latency;
694 uint32_t num_recoveries;
695 struct timeval statistics_start_time;
696 struct timeval statistics_current_time;
697 uint32_t total_ro_delegations;
698 uint32_t total_ro_revokes;
702 * wire format for statistics history
704 struct ctdb_statistics_list_old {
706 struct ctdb_statistics stats[1];
712 struct ctdb_db_statistics_old {
715 uint32_t num_current;
716 uint32_t num_pending;
718 struct ctdb_latency_counter latency;
719 uint32_t buckets[MAX_COUNT_BUCKETS];
722 struct ctdb_latency_counter latency;
724 uint32_t db_ro_delegations;
725 uint32_t db_ro_revokes;
726 uint32_t hop_count_bucket[MAX_COUNT_BUCKETS];
727 uint32_t num_hot_keys;
731 } hot_keys[MAX_HOT_KEYS];
732 char hot_keys_wire[1];
736 * wire format for interface list
739 #define CTDB_IFACE_SIZE IFNAMSIZ
741 #define CTDB_IFACE_SIZE 16
744 #define INVALID_GENERATION 1
745 /* table that contains the mapping between a hash value and lmaster
747 struct ctdb_vnn_map {
754 a wire representation of the vnn map
756 struct ctdb_vnn_map_wire {
762 struct ctdb_notify_data_old {
765 uint8_t notify_data[1];
768 /* table that contains a list of all dbids on a node
770 struct ctdb_dbid_map {
774 #define CTDB_DB_FLAGS_PERSISTENT 0x01
775 #define CTDB_DB_FLAGS_READONLY 0x02
776 #define CTDB_DB_FLAGS_STICKY 0x04
781 #define CTDB_RECOVERY_NORMAL 0
782 #define CTDB_RECOVERY_ACTIVE 1
784 enum ctdb_server_id_type {
790 struct ctdb_server_id {
791 enum ctdb_server_id_type type;
796 struct ctdb_server_id_list {
798 struct ctdb_server_id server_ids[1];
802 struct timeval current_time;
803 struct timeval ctdbd_start_time;
804 struct timeval last_recovery_started;
805 struct timeval last_recovery_finished;
808 struct ctdb_control_tcp_addr {
813 struct ctdb_ban_time {
818 struct ctdb_db_priority {
824 * Structures to support SRVID requests and replies
826 struct srvid_request {
831 struct srvid_request_data {
838 a tcp connection description
839 also used by tcp_add and tcp_remove controls
841 struct ctdb_tcp_connection {
842 ctdb_sock_addr src_addr;
843 ctdb_sock_addr dst_addr;
846 /* the wire representation for a tcp tickle array */
847 struct ctdb_tcp_wire_array {
849 struct ctdb_tcp_connection connections[1];
852 /* the list of tcp tickles used by get/set tcp tickle list */
853 struct ctdb_control_tcp_tickle_list {
855 struct ctdb_tcp_wire_array tickles;
858 /* all tunable variables go in here */
859 struct ctdb_tunable {
860 uint32_t max_redirect_count;
861 uint32_t seqnum_interval; /* unit is ms */
862 uint32_t control_timeout;
863 uint32_t traverse_timeout;
864 uint32_t keepalive_interval;
865 uint32_t keepalive_limit;
866 uint32_t recover_timeout;
867 uint32_t recover_interval;
868 uint32_t election_timeout;
869 uint32_t takeover_timeout;
870 uint32_t monitor_interval;
871 uint32_t tickle_update_interval;
872 uint32_t script_timeout;
873 uint32_t script_timeout_count; /* allow dodgy scripts to hang this many times in a row before we mark the node unhealthy */
874 uint32_t script_unhealthy_on_timeout; /* obsolete */
875 uint32_t recovery_grace_period;
876 uint32_t recovery_ban_period;
877 uint32_t database_hash_size;
878 uint32_t database_max_dead;
879 uint32_t rerecovery_timeout;
880 uint32_t enable_bans;
881 uint32_t deterministic_public_ips;
882 uint32_t reclock_ping_period;
883 uint32_t no_ip_failback;
884 uint32_t disable_ip_failover;
885 uint32_t verbose_memory_names;
886 uint32_t recd_ping_timeout;
887 uint32_t recd_ping_failcount;
888 uint32_t log_latency_ms;
889 uint32_t reclock_latency_ms;
890 uint32_t recovery_drop_all_ips;
891 uint32_t verify_recovery_lock;
892 uint32_t vacuum_interval;
893 uint32_t vacuum_max_run_time;
894 uint32_t repack_limit;
895 uint32_t vacuum_limit;
896 uint32_t max_queue_depth_drop_msg;
897 uint32_t allow_unhealthy_db_read;
898 uint32_t stat_history_interval;
899 uint32_t deferred_attach_timeout;
900 uint32_t vacuum_fast_path_count;
901 uint32_t lcp2_public_ip_assignment;
902 uint32_t allow_client_db_attach;
903 uint32_t recover_pdb_by_seqnum;
904 uint32_t deferred_rebalance_on_node_add;
905 uint32_t fetch_collapse;
906 uint32_t hopcount_make_sticky;
907 uint32_t sticky_duration;
908 uint32_t sticky_pindown;
909 uint32_t no_ip_takeover;
910 uint32_t db_record_count_warn;
911 uint32_t db_record_size_warn;
912 uint32_t db_size_warn;
913 uint32_t pulldb_preallocation_size;
914 uint32_t no_ip_host_on_all_disabled;
915 uint32_t samba3_hack;
916 uint32_t mutex_enabled;
917 uint32_t lock_processes_per_db;
921 CTDB_RUNSTATE_UNKNOWN,
924 CTDB_RUNSTATE_FIRST_RECOVERY,
925 CTDB_RUNSTATE_STARTUP,
926 CTDB_RUNSTATE_RUNNING,
927 CTDB_RUNSTATE_SHUTDOWN,
930 #define CTDB_MONITORING_ACTIVE 0
931 #define CTDB_MONITORING_DISABLED 1
934 struct holding a ctdb_sock_addr and an interface name,
935 used to add/remove public addresses
937 struct ctdb_control_ip_iface {
945 struct holding a ctdb_sock_addr and an interface name,
946 used for send_gratious_arp
948 struct ctdb_control_gratious_arp {
956 structure used for CTDB_SRVID_NODE_FLAGS_CHANGED
958 struct ctdb_node_flag_change {
964 #define CTDB_LMASTER_ANY 0xffffffff
966 /* structure used for pulldb control */
967 struct ctdb_control_pulldb {
972 /* structure used for sending lists of records */
973 struct ctdb_marshall_buffer {
980 structure for setting a tunable
982 struct ctdb_control_set_tunable {
989 structure for getting a tunable
991 struct ctdb_control_get_tunable {
997 structure for listing tunables
999 struct ctdb_control_list_tunable {
1001 /* returns a : separated list of tunable names */
1006 struct ctdb_control_transdb {
1008 uint32_t transaction_id;
1011 #define CTDB_PUBLIC_IP_FLAGS_ONLY_AVAILABLE 0x00010000
1013 struct ctdb_control_iface_info {
1014 char name[CTDB_IFACE_SIZE+2];
1015 uint16_t link_state;
1016 uint32_t references;
1019 struct ctdb_control_public_ip_info {
1020 struct ctdb_public_ip ip;
1021 uint32_t active_idx;
1023 struct ctdb_control_iface_info ifaces[1];
1026 struct ctdb_control_get_ifaces {
1028 struct ctdb_control_iface_info ifaces[1];
1032 * structure to pass to a schedule_for_deletion_control
1034 struct ctdb_control_schedule_for_deletion {
1036 struct ctdb_ltdb_header hdr;
1038 uint8_t key[1]; /* key[] */