2 CTDB protocol marshalling
4 Copyright (C) Amitay Isaacs 2015
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/>.
21 #include "system/network.h"
27 #include "protocol_api.h"
28 #include "protocol_private.h"
30 struct ctdb_req_control_wire {
31 struct ctdb_req_header hdr;
41 struct ctdb_reply_control_wire {
42 struct ctdb_req_header hdr;
49 static size_t ctdb_req_control_data_len(struct ctdb_req_control_data *cd)
59 case CTDB_CONTROL_PROCESS_EXISTS:
60 len = ctdb_pid_len(cd->data.pid);
63 case CTDB_CONTROL_STATISTICS:
66 case CTDB_CONTROL_PING:
69 case CTDB_CONTROL_GETDBPATH:
70 len = ctdb_uint32_len(cd->data.db_id);
73 case CTDB_CONTROL_GETVNNMAP:
76 case CTDB_CONTROL_SETVNNMAP:
77 len = ctdb_vnn_map_len(cd->data.vnnmap);
80 case CTDB_CONTROL_GET_DEBUG:
83 case CTDB_CONTROL_SET_DEBUG:
84 len = ctdb_uint32_len(cd->data.loglevel);
87 case CTDB_CONTROL_GET_DBMAP:
90 case CTDB_CONTROL_PULL_DB:
91 len = ctdb_pulldb_len(cd->data.pulldb);
94 case CTDB_CONTROL_PUSH_DB:
95 len = ctdb_rec_buffer_len(cd->data.recbuf);
98 case CTDB_CONTROL_GET_RECMODE:
101 case CTDB_CONTROL_SET_RECMODE:
102 len = ctdb_uint32_len(cd->data.recmode);
105 case CTDB_CONTROL_STATISTICS_RESET:
108 case CTDB_CONTROL_DB_ATTACH:
109 len = ctdb_string_len(cd->data.db_name);
112 case CTDB_CONTROL_SET_CALL:
115 case CTDB_CONTROL_TRAVERSE_START:
116 len = ctdb_traverse_start_len(cd->data.traverse_start);
119 case CTDB_CONTROL_TRAVERSE_ALL:
120 len = ctdb_traverse_all_len(cd->data.traverse_all);
123 case CTDB_CONTROL_TRAVERSE_DATA:
124 len = ctdb_rec_data_len(cd->data.rec_data);
127 case CTDB_CONTROL_REGISTER_SRVID:
130 case CTDB_CONTROL_DEREGISTER_SRVID:
133 case CTDB_CONTROL_GET_DBNAME:
134 len = ctdb_uint32_len(cd->data.db_id);
137 case CTDB_CONTROL_ENABLE_SEQNUM:
138 len = ctdb_uint32_len(cd->data.db_id);
141 case CTDB_CONTROL_UPDATE_SEQNUM:
142 len = ctdb_uint32_len(cd->data.db_id);
145 case CTDB_CONTROL_DUMP_MEMORY:
148 case CTDB_CONTROL_GET_PID:
151 case CTDB_CONTROL_GET_RECMASTER:
154 case CTDB_CONTROL_SET_RECMASTER:
155 len = ctdb_uint32_len(cd->data.recmaster);
158 case CTDB_CONTROL_FREEZE:
161 case CTDB_CONTROL_THAW:
164 case CTDB_CONTROL_GET_PNN:
167 case CTDB_CONTROL_SHUTDOWN:
170 case CTDB_CONTROL_GET_MONMODE:
173 case CTDB_CONTROL_TCP_CLIENT:
174 len = ctdb_connection_len(cd->data.conn);
177 case CTDB_CONTROL_TCP_ADD:
178 len = ctdb_connection_len(cd->data.conn);
181 case CTDB_CONTROL_TCP_REMOVE:
182 len = ctdb_connection_len(cd->data.conn);
185 case CTDB_CONTROL_STARTUP:
188 case CTDB_CONTROL_SET_TUNABLE:
189 len = ctdb_tunable_len(cd->data.tunable);
192 case CTDB_CONTROL_GET_TUNABLE:
193 len = ctdb_stringn_len(cd->data.tun_var);
196 case CTDB_CONTROL_LIST_TUNABLES:
199 case CTDB_CONTROL_MODIFY_FLAGS:
200 len = ctdb_node_flag_change_len(cd->data.flag_change);
203 case CTDB_CONTROL_GET_ALL_TUNABLES:
206 case CTDB_CONTROL_KILL_TCP:
207 len = ctdb_connection_len(cd->data.conn);
210 case CTDB_CONTROL_GET_TCP_TICKLE_LIST:
211 len = ctdb_sock_addr_len(cd->data.addr);
214 case CTDB_CONTROL_SET_TCP_TICKLE_LIST:
215 len = ctdb_tickle_list_len(cd->data.tickles);
218 case CTDB_CONTROL_REGISTER_SERVER_ID:
219 len = ctdb_client_id_len(cd->data.cid);
222 case CTDB_CONTROL_UNREGISTER_SERVER_ID:
223 len = ctdb_client_id_len(cd->data.cid);
226 case CTDB_CONTROL_CHECK_SERVER_ID:
227 len = ctdb_client_id_len(cd->data.cid);
230 case CTDB_CONTROL_GET_SERVER_ID_LIST:
233 case CTDB_CONTROL_DB_ATTACH_PERSISTENT:
234 len = ctdb_string_len(cd->data.db_name);
237 case CTDB_CONTROL_UPDATE_RECORD:
238 len = ctdb_rec_buffer_len(cd->data.recbuf);
241 case CTDB_CONTROL_SEND_GRATUITOUS_ARP:
242 len = ctdb_addr_info_len(cd->data.addr_info);
245 case CTDB_CONTROL_TRANSACTION_START:
246 len = ctdb_uint32_len(cd->data.tid);
249 case CTDB_CONTROL_TRANSACTION_COMMIT:
250 len = ctdb_uint32_len(cd->data.tid);
253 case CTDB_CONTROL_WIPE_DATABASE:
254 len = ctdb_transdb_len(cd->data.transdb);
257 case CTDB_CONTROL_UPTIME:
260 case CTDB_CONTROL_START_RECOVERY:
263 case CTDB_CONTROL_END_RECOVERY:
266 case CTDB_CONTROL_RELOAD_NODES_FILE:
269 case CTDB_CONTROL_TRY_DELETE_RECORDS:
270 len = ctdb_rec_buffer_len(cd->data.recbuf);
273 case CTDB_CONTROL_ENABLE_MONITOR:
276 case CTDB_CONTROL_DISABLE_MONITOR:
279 case CTDB_CONTROL_ADD_PUBLIC_IP:
280 len = ctdb_addr_info_len(cd->data.addr_info);
283 case CTDB_CONTROL_DEL_PUBLIC_IP:
284 len = ctdb_addr_info_len(cd->data.addr_info);
287 case CTDB_CONTROL_RUN_EVENTSCRIPTS:
288 len = ctdb_string_len(cd->data.event_str);
291 case CTDB_CONTROL_GET_CAPABILITIES:
294 case CTDB_CONTROL_RECD_PING:
297 case CTDB_CONTROL_RELEASE_IP:
298 len = ctdb_public_ip_len(cd->data.pubip);
301 case CTDB_CONTROL_TAKEOVER_IP:
302 len = ctdb_public_ip_len(cd->data.pubip);
305 case CTDB_CONTROL_GET_PUBLIC_IPS:
308 case CTDB_CONTROL_GET_NODEMAP:
311 case CTDB_CONTROL_GET_EVENT_SCRIPT_STATUS:
312 len = ctdb_uint32_len(cd->data.event);
315 case CTDB_CONTROL_TRAVERSE_KILL:
316 len = ctdb_traverse_start_len(cd->data.traverse_start);
319 case CTDB_CONTROL_RECD_RECLOCK_LATENCY:
320 len = ctdb_double_len(cd->data.reclock_latency);
323 case CTDB_CONTROL_GET_RECLOCK_FILE:
326 case CTDB_CONTROL_SET_RECLOCK_FILE:
327 len = ctdb_string_len(cd->data.reclock_file);
330 case CTDB_CONTROL_STOP_NODE:
333 case CTDB_CONTROL_CONTINUE_NODE:
336 case CTDB_CONTROL_SET_NATGWSTATE:
337 len = ctdb_uint32_len(cd->data.role);
340 case CTDB_CONTROL_SET_LMASTERROLE:
341 len = ctdb_uint32_len(cd->data.role);
344 case CTDB_CONTROL_SET_RECMASTERROLE:
345 len = ctdb_uint32_len(cd->data.role);
348 case CTDB_CONTROL_ENABLE_SCRIPT:
349 len = ctdb_string_len(cd->data.script);
352 case CTDB_CONTROL_DISABLE_SCRIPT:
353 len = ctdb_string_len(cd->data.script);
356 case CTDB_CONTROL_SET_BAN_STATE:
357 len = ctdb_ban_state_len(cd->data.ban_state);
360 case CTDB_CONTROL_GET_BAN_STATE:
363 case CTDB_CONTROL_SET_DB_PRIORITY:
364 len = ctdb_db_priority_len(cd->data.db_prio);
367 case CTDB_CONTROL_GET_DB_PRIORITY:
368 len = ctdb_uint32_len(cd->data.db_id);
371 case CTDB_CONTROL_TRANSACTION_CANCEL:
374 case CTDB_CONTROL_REGISTER_NOTIFY:
375 len = ctdb_notify_data_len(cd->data.notify);
378 case CTDB_CONTROL_DEREGISTER_NOTIFY:
379 len = ctdb_uint64_len(cd->data.srvid);
382 case CTDB_CONTROL_TRANS3_COMMIT:
383 len = ctdb_rec_buffer_len(cd->data.recbuf);
386 case CTDB_CONTROL_GET_DB_SEQNUM:
387 u64 = cd->data.db_id;
388 len = ctdb_uint64_len(u64);
391 case CTDB_CONTROL_DB_SET_HEALTHY:
392 len = ctdb_uint32_len(cd->data.db_id);
395 case CTDB_CONTROL_DB_GET_HEALTH:
396 len = ctdb_uint32_len(cd->data.db_id);
399 case CTDB_CONTROL_GET_PUBLIC_IP_INFO:
400 len = ctdb_sock_addr_len(cd->data.addr);
403 case CTDB_CONTROL_GET_IFACES:
406 case CTDB_CONTROL_SET_IFACE_LINK_STATE:
407 len = ctdb_iface_len(cd->data.iface);
410 case CTDB_CONTROL_TCP_ADD_DELAYED_UPDATE:
411 len = ctdb_connection_len(cd->data.conn);
414 case CTDB_CONTROL_GET_STAT_HISTORY:
417 case CTDB_CONTROL_SCHEDULE_FOR_DELETION:
418 len = ctdb_key_data_len(cd->data.key);
421 case CTDB_CONTROL_SET_DB_READONLY:
422 len = ctdb_uint32_len(cd->data.db_id);
425 case CTDB_CONTROL_CHECK_SRVIDS:
426 len = ctdb_uint64_array_len(cd->data.u64_array);
429 case CTDB_CONTROL_TRAVERSE_START_EXT:
430 len = ctdb_traverse_start_ext_len(cd->data.traverse_start_ext);
433 case CTDB_CONTROL_GET_DB_STATISTICS:
434 len = ctdb_uint32_len(cd->data.db_id);
437 case CTDB_CONTROL_SET_DB_STICKY:
438 len = ctdb_uint32_len(cd->data.db_id);
441 case CTDB_CONTROL_RELOAD_PUBLIC_IPS:
444 case CTDB_CONTROL_TRAVERSE_ALL_EXT:
445 len = ctdb_traverse_all_ext_len(cd->data.traverse_all_ext);
448 case CTDB_CONTROL_RECEIVE_RECORDS:
449 len = ctdb_rec_buffer_len(cd->data.recbuf);
452 case CTDB_CONTROL_IPREALLOCATED:
455 case CTDB_CONTROL_GET_RUNSTATE:
458 case CTDB_CONTROL_DB_DETACH:
459 len = ctdb_uint32_len(cd->data.db_id);
462 case CTDB_CONTROL_GET_NODES_FILE:
465 case CTDB_CONTROL_DB_FREEZE:
466 len = ctdb_uint32_len(cd->data.db_id);
469 case CTDB_CONTROL_DB_THAW:
470 len = ctdb_uint32_len(cd->data.db_id);
473 case CTDB_CONTROL_DB_TRANSACTION_START:
474 len = ctdb_transdb_len(cd->data.transdb);
477 case CTDB_CONTROL_DB_TRANSACTION_COMMIT:
478 len = ctdb_transdb_len(cd->data.transdb);
481 case CTDB_CONTROL_DB_TRANSACTION_CANCEL:
482 len = ctdb_uint32_len(cd->data.db_id);
489 static void ctdb_req_control_data_push(struct ctdb_req_control_data *cd,
494 switch (cd->opcode) {
495 case CTDB_CONTROL_PROCESS_EXISTS:
496 ctdb_pid_push(cd->data.pid, buf);
499 case CTDB_CONTROL_GETDBPATH:
500 ctdb_uint32_push(cd->data.db_id, buf);
503 case CTDB_CONTROL_SETVNNMAP:
504 ctdb_vnn_map_push(cd->data.vnnmap, buf);
507 case CTDB_CONTROL_SET_DEBUG:
508 ctdb_uint32_push(cd->data.loglevel, buf);
511 case CTDB_CONTROL_PULL_DB:
512 ctdb_pulldb_push(cd->data.pulldb, buf);
515 case CTDB_CONTROL_PUSH_DB:
516 ctdb_rec_buffer_push(cd->data.recbuf, buf);
519 case CTDB_CONTROL_SET_RECMODE:
520 ctdb_uint32_push(cd->data.recmode, buf);
523 case CTDB_CONTROL_DB_ATTACH:
524 ctdb_string_push(cd->data.db_name, buf);
527 case CTDB_CONTROL_SET_CALL:
530 case CTDB_CONTROL_TRAVERSE_START:
531 ctdb_traverse_start_push(cd->data.traverse_start, buf);
534 case CTDB_CONTROL_TRAVERSE_ALL:
535 ctdb_traverse_all_push(cd->data.traverse_all, buf);
538 case CTDB_CONTROL_TRAVERSE_DATA:
539 ctdb_rec_data_push(cd->data.rec_data, buf);
542 case CTDB_CONTROL_GET_DBNAME:
543 ctdb_uint32_push(cd->data.db_id, buf);
546 case CTDB_CONTROL_ENABLE_SEQNUM:
547 ctdb_uint32_push(cd->data.db_id, buf);
550 case CTDB_CONTROL_UPDATE_SEQNUM:
551 ctdb_uint32_push(cd->data.db_id, buf);
554 case CTDB_CONTROL_SET_RECMASTER:
555 ctdb_uint32_push(cd->data.recmaster, buf);
558 case CTDB_CONTROL_TCP_CLIENT:
559 ctdb_connection_push(cd->data.conn, buf);
562 case CTDB_CONTROL_TCP_ADD:
563 ctdb_connection_push(cd->data.conn, buf);
566 case CTDB_CONTROL_TCP_REMOVE:
567 ctdb_connection_push(cd->data.conn, buf);
570 case CTDB_CONTROL_SET_TUNABLE:
571 ctdb_tunable_push(cd->data.tunable, buf);
574 case CTDB_CONTROL_GET_TUNABLE:
575 ctdb_stringn_push(cd->data.tun_var, buf);
578 case CTDB_CONTROL_MODIFY_FLAGS:
579 ctdb_node_flag_change_push(cd->data.flag_change, buf);
582 case CTDB_CONTROL_KILL_TCP:
583 ctdb_connection_push(cd->data.conn, buf);
586 case CTDB_CONTROL_GET_TCP_TICKLE_LIST:
587 ctdb_sock_addr_push(cd->data.addr, buf);
590 case CTDB_CONTROL_SET_TCP_TICKLE_LIST:
591 ctdb_tickle_list_push(cd->data.tickles, buf);
594 case CTDB_CONTROL_REGISTER_SERVER_ID:
595 ctdb_client_id_push(cd->data.cid, buf);
598 case CTDB_CONTROL_UNREGISTER_SERVER_ID:
599 ctdb_client_id_push(cd->data.cid, buf);
602 case CTDB_CONTROL_CHECK_SERVER_ID:
603 ctdb_client_id_push(cd->data.cid, buf);
606 case CTDB_CONTROL_DB_ATTACH_PERSISTENT:
607 ctdb_string_push(cd->data.db_name, buf);
610 case CTDB_CONTROL_UPDATE_RECORD:
611 ctdb_rec_buffer_push(cd->data.recbuf, buf);
614 case CTDB_CONTROL_SEND_GRATUITOUS_ARP:
615 ctdb_addr_info_push(cd->data.addr_info, buf);
618 case CTDB_CONTROL_TRANSACTION_START:
619 ctdb_uint32_push(cd->data.tid, buf);
622 case CTDB_CONTROL_TRANSACTION_COMMIT:
623 ctdb_uint32_push(cd->data.tid, buf);
626 case CTDB_CONTROL_WIPE_DATABASE:
627 ctdb_transdb_push(cd->data.transdb, buf);
630 case CTDB_CONTROL_TRY_DELETE_RECORDS:
631 ctdb_rec_buffer_push(cd->data.recbuf, buf);
634 case CTDB_CONTROL_ADD_PUBLIC_IP:
635 ctdb_addr_info_push(cd->data.addr_info, buf);
638 case CTDB_CONTROL_DEL_PUBLIC_IP:
639 ctdb_addr_info_push(cd->data.addr_info, buf);
642 case CTDB_CONTROL_RUN_EVENTSCRIPTS:
643 ctdb_string_push(cd->data.event_str, buf);
646 case CTDB_CONTROL_RELEASE_IP:
647 ctdb_public_ip_push(cd->data.pubip, buf);
650 case CTDB_CONTROL_TAKEOVER_IP:
651 ctdb_public_ip_push(cd->data.pubip, buf);
654 case CTDB_CONTROL_GET_EVENT_SCRIPT_STATUS:
655 ctdb_uint32_push(cd->data.event, buf);
658 case CTDB_CONTROL_TRAVERSE_KILL:
659 ctdb_traverse_start_push(cd->data.traverse_start, buf);
662 case CTDB_CONTROL_RECD_RECLOCK_LATENCY:
663 ctdb_double_push(cd->data.reclock_latency, buf);
666 case CTDB_CONTROL_SET_RECLOCK_FILE:
667 ctdb_string_push(cd->data.reclock_file, buf);
670 case CTDB_CONTROL_SET_NATGWSTATE:
671 ctdb_uint32_push(cd->data.role, buf);
674 case CTDB_CONTROL_SET_LMASTERROLE:
675 ctdb_uint32_push(cd->data.role, buf);
678 case CTDB_CONTROL_SET_RECMASTERROLE:
679 ctdb_uint32_push(cd->data.role, buf);
682 case CTDB_CONTROL_ENABLE_SCRIPT:
683 ctdb_string_push(cd->data.script, buf);
686 case CTDB_CONTROL_DISABLE_SCRIPT:
687 ctdb_string_push(cd->data.script, buf);
690 case CTDB_CONTROL_SET_BAN_STATE:
691 ctdb_ban_state_push(cd->data.ban_state, buf);
694 case CTDB_CONTROL_SET_DB_PRIORITY:
695 ctdb_db_priority_push(cd->data.db_prio, buf);
698 case CTDB_CONTROL_GET_DB_PRIORITY:
699 ctdb_uint32_push(cd->data.db_id, buf);
702 case CTDB_CONTROL_REGISTER_NOTIFY:
703 ctdb_notify_data_push(cd->data.notify, buf);
706 case CTDB_CONTROL_DEREGISTER_NOTIFY:
707 ctdb_uint64_push(cd->data.srvid, buf);
710 case CTDB_CONTROL_TRANS3_COMMIT:
711 ctdb_rec_buffer_push(cd->data.recbuf, buf);
714 case CTDB_CONTROL_GET_DB_SEQNUM:
715 u64 = cd->data.db_id;
716 ctdb_uint32_push(u64, buf);
719 case CTDB_CONTROL_DB_SET_HEALTHY:
720 ctdb_uint32_push(cd->data.db_id, buf);
723 case CTDB_CONTROL_DB_GET_HEALTH:
724 ctdb_uint32_push(cd->data.db_id, buf);
727 case CTDB_CONTROL_GET_PUBLIC_IP_INFO:
728 ctdb_sock_addr_push(cd->data.addr, buf);
731 case CTDB_CONTROL_SET_IFACE_LINK_STATE:
732 ctdb_iface_push(cd->data.iface, buf);
735 case CTDB_CONTROL_TCP_ADD_DELAYED_UPDATE:
736 ctdb_connection_push(cd->data.conn, buf);
739 case CTDB_CONTROL_SCHEDULE_FOR_DELETION:
740 ctdb_key_data_push(cd->data.key, buf);
743 case CTDB_CONTROL_SET_DB_READONLY:
744 ctdb_uint32_push(cd->data.db_id, buf);
747 case CTDB_CONTROL_CHECK_SRVIDS:
748 ctdb_uint64_array_push(cd->data.u64_array, buf);
751 case CTDB_CONTROL_TRAVERSE_START_EXT:
752 ctdb_traverse_start_ext_push(cd->data.traverse_start_ext, buf);
755 case CTDB_CONTROL_GET_DB_STATISTICS:
756 ctdb_uint32_push(cd->data.db_id, buf);
759 case CTDB_CONTROL_SET_DB_STICKY:
760 ctdb_uint32_push(cd->data.db_id, buf);
763 case CTDB_CONTROL_TRAVERSE_ALL_EXT:
764 ctdb_traverse_all_ext_push(cd->data.traverse_all_ext, buf);
767 case CTDB_CONTROL_RECEIVE_RECORDS:
768 ctdb_rec_buffer_push(cd->data.recbuf, buf);
771 case CTDB_CONTROL_DB_DETACH:
772 ctdb_uint32_push(cd->data.db_id, buf);
775 case CTDB_CONTROL_DB_FREEZE:
776 ctdb_uint32_push(cd->data.db_id, buf);
779 case CTDB_CONTROL_DB_THAW:
780 ctdb_uint32_push(cd->data.db_id, buf);
783 case CTDB_CONTROL_DB_TRANSACTION_START:
784 ctdb_transdb_push(cd->data.transdb, buf);
787 case CTDB_CONTROL_DB_TRANSACTION_COMMIT:
788 ctdb_transdb_push(cd->data.transdb, buf);
791 case CTDB_CONTROL_DB_TRANSACTION_CANCEL:
792 ctdb_uint32_push(cd->data.db_id, buf);
797 static int ctdb_req_control_data_pull(uint8_t *buf, size_t buflen,
800 struct ctdb_req_control_data *cd)
808 case CTDB_CONTROL_PROCESS_EXISTS:
809 ret = ctdb_pid_pull(buf, buflen, mem_ctx,
813 case CTDB_CONTROL_GETDBPATH:
814 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
818 case CTDB_CONTROL_SETVNNMAP:
819 ret = ctdb_vnn_map_pull(buf, buflen, mem_ctx,
823 case CTDB_CONTROL_SET_DEBUG:
824 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
828 case CTDB_CONTROL_PULL_DB:
829 ret = ctdb_pulldb_pull(buf, buflen, mem_ctx,
833 case CTDB_CONTROL_PUSH_DB:
834 ret = ctdb_rec_buffer_pull(buf, buflen, mem_ctx,
838 case CTDB_CONTROL_SET_RECMODE:
839 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
843 case CTDB_CONTROL_DB_ATTACH:
844 ret = ctdb_string_pull(buf, buflen, mem_ctx,
848 case CTDB_CONTROL_SET_CALL:
851 case CTDB_CONTROL_TRAVERSE_START:
852 ret = ctdb_traverse_start_pull(buf, buflen, mem_ctx,
853 &cd->data.traverse_start);
856 case CTDB_CONTROL_TRAVERSE_ALL:
857 ret = ctdb_traverse_all_pull(buf, buflen, mem_ctx,
858 &cd->data.traverse_all);
861 case CTDB_CONTROL_TRAVERSE_DATA:
862 ret = ctdb_rec_data_pull(buf, buflen, mem_ctx,
866 case CTDB_CONTROL_GET_DBNAME:
867 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
871 case CTDB_CONTROL_ENABLE_SEQNUM:
872 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
876 case CTDB_CONTROL_UPDATE_SEQNUM:
877 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
881 case CTDB_CONTROL_SET_RECMASTER:
882 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
883 &cd->data.recmaster);
886 case CTDB_CONTROL_TCP_CLIENT:
887 ret = ctdb_connection_pull(buf, buflen, mem_ctx,
891 case CTDB_CONTROL_TCP_ADD:
892 ret = ctdb_connection_pull(buf, buflen, mem_ctx,
896 case CTDB_CONTROL_TCP_REMOVE:
897 ret = ctdb_connection_pull(buf, buflen, mem_ctx,
901 case CTDB_CONTROL_SET_TUNABLE:
902 ret = ctdb_tunable_pull(buf, buflen, mem_ctx,
906 case CTDB_CONTROL_GET_TUNABLE:
907 ret = ctdb_stringn_pull(buf, buflen, mem_ctx,
911 case CTDB_CONTROL_MODIFY_FLAGS:
912 ret = ctdb_node_flag_change_pull(buf, buflen, mem_ctx,
913 &cd->data.flag_change);
916 case CTDB_CONTROL_KILL_TCP:
917 ret = ctdb_connection_pull(buf, buflen, mem_ctx,
921 case CTDB_CONTROL_GET_TCP_TICKLE_LIST:
922 ret = ctdb_sock_addr_pull(buf, buflen, mem_ctx,
926 case CTDB_CONTROL_SET_TCP_TICKLE_LIST:
927 ret = ctdb_tickle_list_pull(buf, buflen, mem_ctx,
931 case CTDB_CONTROL_REGISTER_SERVER_ID:
932 ret = ctdb_client_id_pull(buf, buflen, mem_ctx,
936 case CTDB_CONTROL_UNREGISTER_SERVER_ID:
937 ret = ctdb_client_id_pull(buf, buflen, mem_ctx,
941 case CTDB_CONTROL_CHECK_SERVER_ID:
942 ret = ctdb_client_id_pull(buf, buflen, mem_ctx,
946 case CTDB_CONTROL_DB_ATTACH_PERSISTENT:
947 ret = ctdb_string_pull(buf, buflen, mem_ctx,
951 case CTDB_CONTROL_UPDATE_RECORD:
952 ret = ctdb_rec_buffer_pull(buf, buflen, mem_ctx,
956 case CTDB_CONTROL_SEND_GRATUITOUS_ARP:
957 ret = ctdb_addr_info_pull(buf, buflen, mem_ctx,
958 &cd->data.addr_info);
961 case CTDB_CONTROL_TRANSACTION_START:
962 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
966 case CTDB_CONTROL_TRANSACTION_COMMIT:
967 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
971 case CTDB_CONTROL_WIPE_DATABASE:
972 ret = ctdb_transdb_pull(buf, buflen, mem_ctx,
976 case CTDB_CONTROL_TRY_DELETE_RECORDS:
977 ret = ctdb_rec_buffer_pull(buf, buflen, mem_ctx,
981 case CTDB_CONTROL_ADD_PUBLIC_IP:
982 ret = ctdb_addr_info_pull(buf, buflen, mem_ctx,
983 &cd->data.addr_info);
986 case CTDB_CONTROL_DEL_PUBLIC_IP:
987 ret = ctdb_addr_info_pull(buf, buflen, mem_ctx,
988 &cd->data.addr_info);
991 case CTDB_CONTROL_RUN_EVENTSCRIPTS:
992 ret = ctdb_string_pull(buf, buflen, mem_ctx,
993 &cd->data.event_str);
996 case CTDB_CONTROL_RELEASE_IP:
997 ret = ctdb_public_ip_pull(buf, buflen, mem_ctx,
1001 case CTDB_CONTROL_TAKEOVER_IP:
1002 ret = ctdb_public_ip_pull(buf, buflen, mem_ctx,
1006 case CTDB_CONTROL_GET_EVENT_SCRIPT_STATUS:
1007 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1011 case CTDB_CONTROL_TRAVERSE_KILL:
1012 ret = ctdb_traverse_start_pull(buf, buflen, mem_ctx,
1013 &cd->data.traverse_start);
1016 case CTDB_CONTROL_RECD_RECLOCK_LATENCY:
1017 ret = ctdb_double_pull(buf, buflen, mem_ctx,
1018 &cd->data.reclock_latency);
1021 case CTDB_CONTROL_SET_RECLOCK_FILE:
1022 ret = ctdb_string_pull(buf, buflen, mem_ctx,
1023 &cd->data.reclock_file);
1026 case CTDB_CONTROL_SET_NATGWSTATE:
1027 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1031 case CTDB_CONTROL_SET_LMASTERROLE:
1032 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1036 case CTDB_CONTROL_SET_RECMASTERROLE:
1037 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1041 case CTDB_CONTROL_ENABLE_SCRIPT:
1042 ret = ctdb_string_pull(buf, buflen, mem_ctx,
1046 case CTDB_CONTROL_DISABLE_SCRIPT:
1047 ret = ctdb_string_pull(buf, buflen, mem_ctx,
1051 case CTDB_CONTROL_SET_BAN_STATE:
1052 ret = ctdb_ban_state_pull(buf, buflen, mem_ctx,
1053 &cd->data.ban_state);
1056 case CTDB_CONTROL_SET_DB_PRIORITY:
1057 ret = ctdb_db_priority_pull(buf, buflen, mem_ctx,
1061 case CTDB_CONTROL_GET_DB_PRIORITY:
1062 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1066 case CTDB_CONTROL_REGISTER_NOTIFY:
1067 ret = ctdb_notify_data_pull(buf, buflen, mem_ctx,
1071 case CTDB_CONTROL_DEREGISTER_NOTIFY:
1072 ctdb_uint64_pull(buf, buflen, mem_ctx,
1076 case CTDB_CONTROL_TRANS3_COMMIT:
1077 ret = ctdb_rec_buffer_pull(buf, buflen, mem_ctx,
1081 case CTDB_CONTROL_GET_DB_SEQNUM:
1082 ret = ctdb_uint64_pull(buf, buflen, mem_ctx, &u64);
1083 cd->data.db_id = (uint32_t)u64;
1086 case CTDB_CONTROL_DB_SET_HEALTHY:
1087 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1091 case CTDB_CONTROL_DB_GET_HEALTH:
1092 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1096 case CTDB_CONTROL_GET_PUBLIC_IP_INFO:
1097 ret = ctdb_sock_addr_pull(buf, buflen, mem_ctx,
1101 case CTDB_CONTROL_SET_IFACE_LINK_STATE:
1102 ret = ctdb_iface_pull(buf, buflen, mem_ctx,
1106 case CTDB_CONTROL_TCP_ADD_DELAYED_UPDATE:
1107 ret = ctdb_connection_pull(buf, buflen, mem_ctx,
1111 case CTDB_CONTROL_SCHEDULE_FOR_DELETION:
1112 ret = ctdb_key_data_pull(buf, buflen, mem_ctx,
1116 case CTDB_CONTROL_SET_DB_READONLY:
1117 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1121 case CTDB_CONTROL_CHECK_SRVIDS:
1122 ret = ctdb_uint64_array_pull(buf, buflen, mem_ctx,
1123 &cd->data.u64_array);
1126 case CTDB_CONTROL_TRAVERSE_START_EXT:
1127 ret = ctdb_traverse_start_ext_pull(buf, buflen, mem_ctx,
1128 &cd->data.traverse_start_ext);
1131 case CTDB_CONTROL_GET_DB_STATISTICS:
1132 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1136 case CTDB_CONTROL_SET_DB_STICKY:
1137 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1141 case CTDB_CONTROL_TRAVERSE_ALL_EXT:
1142 ret = ctdb_traverse_all_ext_pull(buf, buflen, mem_ctx,
1143 &cd->data.traverse_all_ext);
1146 case CTDB_CONTROL_RECEIVE_RECORDS:
1147 ret = ctdb_rec_buffer_pull(buf, buflen, mem_ctx,
1151 case CTDB_CONTROL_DB_DETACH:
1152 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1156 case CTDB_CONTROL_DB_FREEZE:
1157 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1161 case CTDB_CONTROL_DB_THAW:
1162 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1166 case CTDB_CONTROL_DB_TRANSACTION_START:
1167 ret = ctdb_transdb_pull(buf, buflen, mem_ctx,
1171 case CTDB_CONTROL_DB_TRANSACTION_COMMIT:
1172 ret = ctdb_transdb_pull(buf, buflen, mem_ctx,
1176 case CTDB_CONTROL_DB_TRANSACTION_CANCEL:
1177 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1185 static size_t ctdb_reply_control_data_len(struct ctdb_reply_control_data *cd)
1193 switch (cd->opcode) {
1194 case CTDB_CONTROL_PROCESS_EXISTS:
1197 case CTDB_CONTROL_STATISTICS:
1198 len = ctdb_statistics_len(cd->data.stats);
1201 case CTDB_CONTROL_PING:
1204 case CTDB_CONTROL_GETDBPATH:
1205 len = ctdb_string_len(cd->data.db_path);
1208 case CTDB_CONTROL_GETVNNMAP:
1209 len = ctdb_vnn_map_len(cd->data.vnnmap);
1212 case CTDB_CONTROL_SETVNNMAP:
1215 case CTDB_CONTROL_GET_DEBUG:
1216 len = ctdb_uint32_len(cd->data.loglevel);
1219 case CTDB_CONTROL_SET_DEBUG:
1222 case CTDB_CONTROL_GET_DBMAP:
1223 len = ctdb_dbid_map_len(cd->data.dbmap);
1226 case CTDB_CONTROL_PULL_DB:
1227 len = ctdb_rec_buffer_len(cd->data.recbuf);
1230 case CTDB_CONTROL_PUSH_DB:
1233 case CTDB_CONTROL_GET_RECMODE:
1236 case CTDB_CONTROL_SET_RECMODE:
1239 case CTDB_CONTROL_STATISTICS_RESET:
1242 case CTDB_CONTROL_DB_ATTACH:
1243 len = ctdb_uint32_len(cd->data.db_id);
1246 case CTDB_CONTROL_SET_CALL:
1249 case CTDB_CONTROL_TRAVERSE_START:
1252 case CTDB_CONTROL_TRAVERSE_ALL:
1255 case CTDB_CONTROL_TRAVERSE_DATA:
1258 case CTDB_CONTROL_REGISTER_SRVID:
1261 case CTDB_CONTROL_DEREGISTER_SRVID:
1264 case CTDB_CONTROL_GET_DBNAME:
1265 len = ctdb_string_len(cd->data.db_name);
1268 case CTDB_CONTROL_ENABLE_SEQNUM:
1271 case CTDB_CONTROL_UPDATE_SEQNUM:
1274 case CTDB_CONTROL_DUMP_MEMORY:
1275 len = ctdb_string_len(cd->data.mem_str);
1278 case CTDB_CONTROL_GET_PID:
1281 case CTDB_CONTROL_GET_RECMASTER:
1284 case CTDB_CONTROL_SET_RECMASTER:
1287 case CTDB_CONTROL_FREEZE:
1290 case CTDB_CONTROL_THAW:
1293 case CTDB_CONTROL_GET_PNN:
1296 case CTDB_CONTROL_SHUTDOWN:
1299 case CTDB_CONTROL_GET_MONMODE:
1302 case CTDB_CONTROL_TCP_CLIENT:
1305 case CTDB_CONTROL_TCP_ADD:
1308 case CTDB_CONTROL_TCP_REMOVE:
1311 case CTDB_CONTROL_STARTUP:
1314 case CTDB_CONTROL_SET_TUNABLE:
1317 case CTDB_CONTROL_GET_TUNABLE:
1318 len = ctdb_uint32_len(cd->data.tun_value);
1321 case CTDB_CONTROL_LIST_TUNABLES:
1322 len = ctdb_var_list_len(cd->data.tun_var_list);
1325 case CTDB_CONTROL_MODIFY_FLAGS:
1328 case CTDB_CONTROL_GET_ALL_TUNABLES:
1329 len = ctdb_tunable_list_len(cd->data.tun_list);
1332 case CTDB_CONTROL_KILL_TCP:
1335 case CTDB_CONTROL_GET_TCP_TICKLE_LIST:
1336 len = ctdb_tickle_list_len(cd->data.tickles);
1339 case CTDB_CONTROL_SET_TCP_TICKLE_LIST:
1342 case CTDB_CONTROL_REGISTER_SERVER_ID:
1345 case CTDB_CONTROL_UNREGISTER_SERVER_ID:
1348 case CTDB_CONTROL_CHECK_SERVER_ID:
1351 case CTDB_CONTROL_GET_SERVER_ID_LIST:
1352 len = ctdb_client_id_map_len(cd->data.cid_map);
1355 case CTDB_CONTROL_DB_ATTACH_PERSISTENT:
1356 len = ctdb_uint32_len(cd->data.db_id);
1359 case CTDB_CONTROL_UPDATE_RECORD:
1362 case CTDB_CONTROL_SEND_GRATUITOUS_ARP:
1365 case CTDB_CONTROL_TRANSACTION_START:
1368 case CTDB_CONTROL_TRANSACTION_COMMIT:
1371 case CTDB_CONTROL_WIPE_DATABASE:
1374 case CTDB_CONTROL_UPTIME:
1375 len = ctdb_uptime_len(cd->data.uptime);
1378 case CTDB_CONTROL_START_RECOVERY:
1381 case CTDB_CONTROL_END_RECOVERY:
1384 case CTDB_CONTROL_RELOAD_NODES_FILE:
1387 case CTDB_CONTROL_TRY_DELETE_RECORDS:
1388 len = ctdb_rec_buffer_len(cd->data.recbuf);
1391 case CTDB_CONTROL_ENABLE_MONITOR:
1394 case CTDB_CONTROL_DISABLE_MONITOR:
1397 case CTDB_CONTROL_ADD_PUBLIC_IP:
1400 case CTDB_CONTROL_DEL_PUBLIC_IP:
1403 case CTDB_CONTROL_RUN_EVENTSCRIPTS:
1406 case CTDB_CONTROL_GET_CAPABILITIES:
1407 len = ctdb_uint32_len(cd->data.caps);
1410 case CTDB_CONTROL_RECD_PING:
1413 case CTDB_CONTROL_RELEASE_IP:
1416 case CTDB_CONTROL_TAKEOVER_IP:
1419 case CTDB_CONTROL_GET_PUBLIC_IPS:
1420 len = ctdb_public_ip_list_len(cd->data.pubip_list);
1423 case CTDB_CONTROL_GET_NODEMAP:
1424 len = ctdb_node_map_len(cd->data.nodemap);
1427 case CTDB_CONTROL_GET_EVENT_SCRIPT_STATUS:
1428 len = ctdb_script_list_len(cd->data.script_list);
1431 case CTDB_CONTROL_TRAVERSE_KILL:
1434 case CTDB_CONTROL_RECD_RECLOCK_LATENCY:
1437 case CTDB_CONTROL_GET_RECLOCK_FILE:
1438 len = ctdb_string_len(cd->data.reclock_file);
1441 case CTDB_CONTROL_SET_RECLOCK_FILE:
1444 case CTDB_CONTROL_STOP_NODE:
1447 case CTDB_CONTROL_CONTINUE_NODE:
1450 case CTDB_CONTROL_SET_NATGWSTATE:
1453 case CTDB_CONTROL_SET_LMASTERROLE:
1456 case CTDB_CONTROL_SET_RECMASTERROLE:
1459 case CTDB_CONTROL_ENABLE_SCRIPT:
1462 case CTDB_CONTROL_DISABLE_SCRIPT:
1465 case CTDB_CONTROL_SET_BAN_STATE:
1468 case CTDB_CONTROL_GET_BAN_STATE:
1469 len = ctdb_ban_state_len(cd->data.ban_state);
1472 case CTDB_CONTROL_SET_DB_PRIORITY:
1475 case CTDB_CONTROL_GET_DB_PRIORITY:
1478 case CTDB_CONTROL_TRANSACTION_CANCEL:
1481 case CTDB_CONTROL_REGISTER_NOTIFY:
1484 case CTDB_CONTROL_DEREGISTER_NOTIFY:
1487 case CTDB_CONTROL_TRANS3_COMMIT:
1490 case CTDB_CONTROL_GET_DB_SEQNUM:
1491 len = ctdb_uint64_len(cd->data.seqnum);
1494 case CTDB_CONTROL_DB_SET_HEALTHY:
1497 case CTDB_CONTROL_DB_GET_HEALTH:
1498 len = ctdb_string_len(cd->data.reason);
1501 case CTDB_CONTROL_GET_PUBLIC_IP_INFO:
1502 len = ctdb_public_ip_info_len(cd->data.ipinfo);
1505 case CTDB_CONTROL_GET_IFACES:
1506 len = ctdb_iface_list_len(cd->data.iface_list);
1509 case CTDB_CONTROL_SET_IFACE_LINK_STATE:
1512 case CTDB_CONTROL_TCP_ADD_DELAYED_UPDATE:
1515 case CTDB_CONTROL_GET_STAT_HISTORY:
1516 len = ctdb_statistics_list_len(cd->data.stats_list);
1519 case CTDB_CONTROL_SCHEDULE_FOR_DELETION:
1522 case CTDB_CONTROL_SET_DB_READONLY:
1525 case CTDB_CONTROL_CHECK_SRVIDS:
1526 len = ctdb_uint8_array_len(cd->data.u8_array);
1529 case CTDB_CONTROL_TRAVERSE_START_EXT:
1532 case CTDB_CONTROL_GET_DB_STATISTICS:
1533 len = ctdb_db_statistics_len(cd->data.dbstats);
1536 case CTDB_CONTROL_SET_DB_STICKY:
1539 case CTDB_CONTROL_RELOAD_PUBLIC_IPS:
1542 case CTDB_CONTROL_TRAVERSE_ALL_EXT:
1545 case CTDB_CONTROL_RECEIVE_RECORDS:
1546 len = ctdb_rec_buffer_len(cd->data.recbuf);
1549 case CTDB_CONTROL_IPREALLOCATED:
1552 case CTDB_CONTROL_GET_RUNSTATE:
1553 len = ctdb_uint32_len(cd->data.runstate);
1556 case CTDB_CONTROL_DB_DETACH:
1559 case CTDB_CONTROL_GET_NODES_FILE:
1560 len = ctdb_node_map_len(cd->data.nodemap);
1563 case CTDB_CONTROL_DB_FREEZE:
1566 case CTDB_CONTROL_DB_THAW:
1569 case CTDB_CONTROL_DB_TRANSACTION_START:
1572 case CTDB_CONTROL_DB_TRANSACTION_COMMIT:
1575 case CTDB_CONTROL_DB_TRANSACTION_CANCEL:
1582 static void ctdb_reply_control_data_push(struct ctdb_reply_control_data *cd,
1585 switch (cd->opcode) {
1586 case CTDB_CONTROL_STATISTICS:
1587 ctdb_statistics_push(cd->data.stats, buf);
1590 case CTDB_CONTROL_GETDBPATH:
1591 ctdb_string_push(cd->data.db_path, buf);
1594 case CTDB_CONTROL_GETVNNMAP:
1595 ctdb_vnn_map_push(cd->data.vnnmap, buf);
1598 case CTDB_CONTROL_GET_DEBUG:
1599 ctdb_uint32_push(cd->data.loglevel, buf);
1602 case CTDB_CONTROL_GET_DBMAP:
1603 ctdb_dbid_map_push(cd->data.dbmap, buf);
1606 case CTDB_CONTROL_PULL_DB:
1607 ctdb_rec_buffer_push(cd->data.recbuf, buf);
1610 case CTDB_CONTROL_PUSH_DB:
1613 case CTDB_CONTROL_DB_ATTACH:
1614 ctdb_uint32_push(cd->data.db_id, buf);
1617 case CTDB_CONTROL_GET_DBNAME:
1618 ctdb_string_push(cd->data.db_name, buf);
1621 case CTDB_CONTROL_DUMP_MEMORY:
1622 ctdb_string_push(cd->data.mem_str, buf);
1625 case CTDB_CONTROL_GET_PID:
1628 case CTDB_CONTROL_GET_RECMASTER:
1631 case CTDB_CONTROL_GET_TUNABLE:
1632 ctdb_uint32_push(cd->data.tun_value, buf);
1635 case CTDB_CONTROL_LIST_TUNABLES:
1636 ctdb_var_list_push(cd->data.tun_var_list, buf);
1639 case CTDB_CONTROL_GET_ALL_TUNABLES:
1640 ctdb_tunable_list_push(cd->data.tun_list, buf);
1643 case CTDB_CONTROL_GET_TCP_TICKLE_LIST:
1644 ctdb_tickle_list_push(cd->data.tickles, buf);
1647 case CTDB_CONTROL_GET_SERVER_ID_LIST:
1648 ctdb_client_id_map_push(cd->data.cid_map, buf);
1651 case CTDB_CONTROL_DB_ATTACH_PERSISTENT:
1652 ctdb_uint32_push(cd->data.db_id, buf);
1655 case CTDB_CONTROL_UPTIME:
1656 ctdb_uptime_push(cd->data.uptime, buf);
1659 case CTDB_CONTROL_TRY_DELETE_RECORDS:
1660 ctdb_rec_buffer_push(cd->data.recbuf, buf);
1663 case CTDB_CONTROL_GET_CAPABILITIES:
1664 ctdb_uint32_push(cd->data.caps, buf);
1667 case CTDB_CONTROL_GET_PUBLIC_IPS:
1668 ctdb_public_ip_list_push(cd->data.pubip_list, buf);
1671 case CTDB_CONTROL_GET_NODEMAP:
1672 ctdb_node_map_push(cd->data.nodemap, buf);
1675 case CTDB_CONTROL_GET_EVENT_SCRIPT_STATUS:
1676 ctdb_script_list_push(cd->data.script_list, buf);
1679 case CTDB_CONTROL_GET_RECLOCK_FILE:
1680 ctdb_string_push(cd->data.reclock_file, buf);
1683 case CTDB_CONTROL_GET_BAN_STATE:
1684 ctdb_ban_state_push(cd->data.ban_state, buf);
1687 case CTDB_CONTROL_GET_DB_PRIORITY:
1690 case CTDB_CONTROL_GET_DB_SEQNUM:
1691 ctdb_uint64_push(cd->data.seqnum, buf);
1694 case CTDB_CONTROL_DB_GET_HEALTH:
1695 ctdb_string_push(cd->data.reason, buf);
1698 case CTDB_CONTROL_GET_PUBLIC_IP_INFO:
1699 ctdb_public_ip_info_push(cd->data.ipinfo, buf);
1702 case CTDB_CONTROL_GET_IFACES:
1703 ctdb_iface_list_push(cd->data.iface_list, buf);
1706 case CTDB_CONTROL_GET_STAT_HISTORY:
1707 ctdb_statistics_list_push(cd->data.stats_list, buf);
1710 case CTDB_CONTROL_CHECK_SRVIDS:
1711 ctdb_uint8_array_push(cd->data.u8_array, buf);
1714 case CTDB_CONTROL_GET_DB_STATISTICS:
1715 ctdb_db_statistics_push(cd->data.dbstats, buf);
1718 case CTDB_CONTROL_RECEIVE_RECORDS:
1719 ctdb_rec_buffer_push(cd->data.recbuf, buf);
1722 case CTDB_CONTROL_GET_RUNSTATE:
1723 ctdb_uint32_push(cd->data.runstate, buf);
1726 case CTDB_CONTROL_GET_NODES_FILE:
1727 ctdb_node_map_push(cd->data.nodemap, buf);
1732 static int ctdb_reply_control_data_pull(uint8_t *buf, size_t buflen,
1733 uint32_t opcode, TALLOC_CTX *mem_ctx,
1734 struct ctdb_reply_control_data *cd)
1737 cd->opcode = opcode;
1740 case CTDB_CONTROL_STATISTICS:
1741 ret = ctdb_statistics_pull(buf, buflen, mem_ctx,
1745 case CTDB_CONTROL_GETDBPATH:
1746 ret = ctdb_string_pull(buf, buflen, mem_ctx,
1750 case CTDB_CONTROL_GETVNNMAP:
1751 ret = ctdb_vnn_map_pull(buf, buflen, mem_ctx,
1755 case CTDB_CONTROL_GET_DEBUG:
1756 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1757 &cd->data.loglevel);
1760 case CTDB_CONTROL_GET_DBMAP:
1761 ret = ctdb_dbid_map_pull(buf, buflen, mem_ctx,
1765 case CTDB_CONTROL_PULL_DB:
1766 ret = ctdb_rec_buffer_pull(buf, buflen, mem_ctx,
1770 case CTDB_CONTROL_PUSH_DB:
1773 case CTDB_CONTROL_DB_ATTACH:
1774 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1778 case CTDB_CONTROL_GET_DBNAME:
1779 ret = ctdb_string_pull(buf, buflen, mem_ctx,
1783 case CTDB_CONTROL_DUMP_MEMORY:
1784 ret = ctdb_string_pull(buf, buflen, mem_ctx,
1788 case CTDB_CONTROL_GET_PID:
1791 case CTDB_CONTROL_GET_RECMASTER:
1794 case CTDB_CONTROL_GET_TUNABLE:
1795 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1796 &cd->data.tun_value);
1799 case CTDB_CONTROL_LIST_TUNABLES:
1800 ret = ctdb_var_list_pull(buf, buflen, mem_ctx,
1801 &cd->data.tun_var_list);
1804 case CTDB_CONTROL_GET_ALL_TUNABLES:
1805 ret = ctdb_tunable_list_pull(buf, buflen, mem_ctx,
1806 &cd->data.tun_list);
1809 case CTDB_CONTROL_GET_TCP_TICKLE_LIST:
1810 ret = ctdb_tickle_list_pull(buf, buflen, mem_ctx,
1814 case CTDB_CONTROL_GET_SERVER_ID_LIST:
1815 ret = ctdb_client_id_map_pull(buf, buflen, mem_ctx,
1819 case CTDB_CONTROL_DB_ATTACH_PERSISTENT:
1820 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1824 case CTDB_CONTROL_UPTIME:
1825 ret = ctdb_uptime_pull(buf, buflen, mem_ctx,
1829 case CTDB_CONTROL_TRY_DELETE_RECORDS:
1830 ctdb_rec_buffer_pull(buf, buflen, mem_ctx,
1834 case CTDB_CONTROL_GET_CAPABILITIES:
1835 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1839 case CTDB_CONTROL_GET_PUBLIC_IPS:
1840 ret = ctdb_public_ip_list_pull(buf, buflen, mem_ctx,
1841 &cd->data.pubip_list);
1844 case CTDB_CONTROL_GET_NODEMAP:
1845 ret = ctdb_node_map_pull(buf, buflen, mem_ctx,
1849 case CTDB_CONTROL_GET_EVENT_SCRIPT_STATUS:
1850 ret = ctdb_script_list_pull(buf, buflen, mem_ctx,
1851 &cd->data.script_list);
1854 case CTDB_CONTROL_GET_RECLOCK_FILE:
1855 ret = ctdb_string_pull(buf, buflen, mem_ctx,
1856 &cd->data.reclock_file);
1859 case CTDB_CONTROL_GET_BAN_STATE:
1860 ret = ctdb_ban_state_pull(buf, buflen, mem_ctx,
1861 &cd->data.ban_state);
1864 case CTDB_CONTROL_GET_DB_PRIORITY:
1867 case CTDB_CONTROL_GET_DB_SEQNUM:
1868 ret = ctdb_uint64_pull(buf, buflen, mem_ctx,
1872 case CTDB_CONTROL_DB_GET_HEALTH:
1873 ret = ctdb_string_pull(buf, buflen, mem_ctx,
1877 case CTDB_CONTROL_GET_PUBLIC_IP_INFO:
1878 ret = ctdb_public_ip_info_pull(buf, buflen, mem_ctx,
1882 case CTDB_CONTROL_GET_IFACES:
1883 ret = ctdb_iface_list_pull(buf, buflen, mem_ctx,
1884 &cd->data.iface_list);
1887 case CTDB_CONTROL_GET_STAT_HISTORY:
1888 ret = ctdb_statistics_list_pull(buf, buflen, mem_ctx,
1889 &cd->data.stats_list);
1892 case CTDB_CONTROL_CHECK_SRVIDS:
1893 ret = ctdb_uint8_array_pull(buf, buflen, mem_ctx,
1894 &cd->data.u8_array);
1897 case CTDB_CONTROL_GET_DB_STATISTICS:
1898 ret = ctdb_db_statistics_pull(buf, buflen, mem_ctx,
1902 case CTDB_CONTROL_RECEIVE_RECORDS:
1903 ret = ctdb_rec_buffer_pull(buf, buflen, mem_ctx,
1907 case CTDB_CONTROL_GET_RUNSTATE:
1908 ret = ctdb_uint32_pull(buf, buflen, mem_ctx,
1909 &cd->data.runstate);
1912 case CTDB_CONTROL_GET_NODES_FILE:
1913 ret = ctdb_node_map_pull(buf, buflen, mem_ctx,
1921 int ctdb_req_control_push(struct ctdb_req_header *h,
1922 struct ctdb_req_control *request,
1923 TALLOC_CTX *mem_ctx,
1924 uint8_t **pkt, size_t *pkt_len)
1926 struct ctdb_req_control_wire *wire;
1928 size_t length, buflen, datalen;
1931 datalen = ctdb_req_control_data_len(&request->rdata);
1932 length = offsetof(struct ctdb_req_control_wire, data) + datalen;
1934 ret = allocate_pkt(mem_ctx, length, &buf, &buflen);
1939 wire = (struct ctdb_req_control_wire *)buf;
1942 memcpy(&wire->hdr, h, sizeof(struct ctdb_req_header));
1944 wire->opcode = request->opcode;
1945 wire->pad = request->pad;
1946 wire->srvid = request->srvid;
1947 wire->client_id = request->client_id;
1948 wire->flags = request->flags;
1950 wire->datalen = datalen;
1951 ctdb_req_control_data_push(&request->rdata, wire->data);
1958 int ctdb_req_control_pull(uint8_t *pkt, size_t pkt_len,
1959 struct ctdb_req_header *h,
1960 TALLOC_CTX *mem_ctx,
1961 struct ctdb_req_control *request)
1963 struct ctdb_req_control_wire *wire =
1964 (struct ctdb_req_control_wire *)pkt;
1968 length = offsetof(struct ctdb_req_control_wire, data);
1969 if (pkt_len < length) {
1972 if (pkt_len < length + wire->datalen) {
1976 memcpy(h, &wire->hdr, sizeof(struct ctdb_req_header));
1978 request->opcode = wire->opcode;
1979 request->pad = wire->pad;
1980 request->srvid = wire->srvid;
1981 request->client_id = wire->client_id;
1982 request->flags = wire->flags;
1984 ret = ctdb_req_control_data_pull(wire->data, wire->datalen,
1985 request->opcode, mem_ctx,
1994 int ctdb_reply_control_push(struct ctdb_req_header *h,
1995 struct ctdb_reply_control *reply,
1996 TALLOC_CTX *mem_ctx,
1997 uint8_t **pkt, size_t *pkt_len)
1999 struct ctdb_reply_control_wire *wire;
2001 size_t length, buflen, datalen, errlen;
2004 if (reply->status == 0) {
2005 datalen = ctdb_reply_control_data_len(&reply->rdata);
2010 if (reply->errmsg == NULL) {
2013 errlen = strlen(reply->errmsg) + 1;
2016 length = offsetof(struct ctdb_reply_control_wire, data) +
2019 ret = allocate_pkt(mem_ctx, length, &buf, &buflen);
2024 wire = (struct ctdb_reply_control_wire *)buf;
2027 memcpy(&wire->hdr, h, sizeof(struct ctdb_req_header));
2029 wire->status = reply->status;
2031 wire->datalen = datalen;
2032 if (reply->status == 0) {
2033 ctdb_reply_control_data_push(&reply->rdata, wire->data);
2036 wire->errorlen = errlen;
2038 memcpy(wire->data + datalen, reply->errmsg, wire->errorlen);
2046 int ctdb_reply_control_pull(uint8_t *pkt, size_t pkt_len, uint32_t opcode,
2047 struct ctdb_req_header *h,
2048 TALLOC_CTX *mem_ctx,
2049 struct ctdb_reply_control *reply)
2051 struct ctdb_reply_control_wire *wire =
2052 (struct ctdb_reply_control_wire *)pkt;
2056 length = offsetof(struct ctdb_reply_control_wire, data);
2058 if (pkt_len < length) {
2061 if (pkt_len < length + wire->datalen + wire->errorlen) {
2065 memcpy(h, &wire->hdr, sizeof(struct ctdb_req_header));
2067 reply->status = wire->status;
2069 if (reply->status != -1) {
2070 ret = ctdb_reply_control_data_pull(wire->data, wire->datalen,
2078 if (wire->errorlen > 0) {
2079 reply->errmsg = talloc_memdup(mem_ctx,
2080 wire->data + wire->datalen,
2083 reply->errmsg = NULL;