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/>.
20 #ifndef __PROTOCOL_PRIVATE_H__
21 #define __PROTOCOL_PRIVATE_H__
26 * From protocol/protocol_basic.c
29 size_t ctdb_uint8_len(uint8_t *in);
30 void ctdb_uint8_push(uint8_t *in, uint8_t *buf, size_t *npush);
31 int ctdb_uint8_pull(uint8_t *buf, size_t buflen, uint8_t *out, size_t *npull);
33 size_t ctdb_uint16_len(uint16_t *in);
34 void ctdb_uint16_push(uint16_t *in, uint8_t *buf, size_t *npush);
35 int ctdb_uint16_pull(uint8_t *buf, size_t buflen, uint16_t *out,
38 size_t ctdb_int32_len(int32_t *in);
39 void ctdb_int32_push(int32_t *in, uint8_t *buf, size_t *npush);
40 int ctdb_int32_pull(uint8_t *buf, size_t buflen, int32_t *out, size_t *npull);
42 size_t ctdb_uint32_len(uint32_t *in);
43 void ctdb_uint32_push(uint32_t *in, uint8_t *buf, size_t *npush);
44 int ctdb_uint32_pull(uint8_t *buf, size_t buflen, uint32_t *out,
47 size_t ctdb_uint64_len(uint64_t *in);
48 void ctdb_uint64_push(uint64_t *in, uint8_t *buf, size_t *npush);
49 int ctdb_uint64_pull(uint8_t *buf, size_t buflen, uint64_t *out,
52 size_t ctdb_double_len(double *in);
53 void ctdb_double_push(double *in, uint8_t *buf, size_t *npush);
54 int ctdb_double_pull(uint8_t *buf, size_t buflen, double *out, size_t *npull);
56 size_t ctdb_bool_len(bool *in);
57 void ctdb_bool_push(bool *in, uint8_t *buf, size_t *npush);
58 int ctdb_bool_pull(uint8_t *buf, size_t buflen, bool *out, size_t *npull);
60 size_t ctdb_chararray_len(char *in, size_t len);
61 void ctdb_chararray_push(char *in, size_t len, uint8_t *buf, size_t *npush);
62 int ctdb_chararray_pull(uint8_t *buf, size_t buflen, char *out, size_t len,
65 size_t ctdb_string_len(const char **in);
66 void ctdb_string_push(const char **in, uint8_t *buf, size_t *npush);
67 int ctdb_string_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
68 const char **out, size_t *npull);
70 size_t ctdb_stringn_len(const char **in);
71 void ctdb_stringn_push(const char **in, uint8_t *buf, size_t *npush);
72 int ctdb_stringn_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
73 const char **out, size_t *npull);
75 size_t ctdb_pid_len(pid_t *in);
76 void ctdb_pid_push(pid_t *in, uint8_t *buf, size_t *npush);
77 int ctdb_pid_pull(uint8_t *buf, size_t buflen, pid_t *out, size_t *npull);
79 size_t ctdb_timeval_len(struct timeval *in);
80 void ctdb_timeval_push(struct timeval *in, uint8_t *buf, size_t *npush);
81 int ctdb_timeval_pull(uint8_t *buf, size_t buflen, struct timeval *out,
84 size_t ctdb_padding_len(int count);
85 void ctdb_padding_push(int count, uint8_t *buf, size_t *npush);
86 int ctdb_padding_pull(uint8_t *buf, size_t buflen, int count, size_t *npull);
89 * From protocol/protocol_types.c
92 size_t ctdb_tdb_data_len(TDB_DATA *in);
93 void ctdb_tdb_data_push(TDB_DATA *in, uint8_t *buf, size_t *npush);
94 int ctdb_tdb_data_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
95 TDB_DATA *out, size_t *npull);
97 size_t ctdb_tdb_datan_len(TDB_DATA *in);
98 void ctdb_tdb_datan_push(TDB_DATA *in, uint8_t *buf, size_t *npush);
99 int ctdb_tdb_datan_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
100 TDB_DATA *out, size_t *npull);
102 size_t ctdb_latency_counter_len(struct ctdb_latency_counter *in);
103 void ctdb_latency_counter_push(struct ctdb_latency_counter *in, uint8_t *buf,
105 int ctdb_latency_counter_pull(uint8_t *buf, size_t buflen,
106 struct ctdb_latency_counter *out, size_t *npull);
108 size_t ctdb_statistics_len(struct ctdb_statistics *in);
109 void ctdb_statistics_push(struct ctdb_statistics *in, uint8_t *buf,
111 int ctdb_statistics_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
112 struct ctdb_statistics **out, size_t *npull);
114 size_t ctdb_statistics_list_len(struct ctdb_statistics_list *stats_list);
115 void ctdb_statistics_list_push(struct ctdb_statistics_list *stats_list,
117 int ctdb_statistics_list_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
118 struct ctdb_statistics_list **out);
120 size_t ctdb_vnn_map_len(struct ctdb_vnn_map *in);
121 void ctdb_vnn_map_push(struct ctdb_vnn_map *in, uint8_t *buf, size_t *npush);
122 int ctdb_vnn_map_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
123 struct ctdb_vnn_map **out, size_t *npull);
125 size_t ctdb_dbid_len(struct ctdb_dbid *in);
126 void ctdb_dbid_push(struct ctdb_dbid *in, uint8_t *buf, size_t *npush);
127 int ctdb_dbid_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
128 struct ctdb_dbid **out, size_t *npull);
130 size_t ctdb_dbid_map_len(struct ctdb_dbid_map *in);
131 void ctdb_dbid_map_push(struct ctdb_dbid_map *in, uint8_t *buf,
133 int ctdb_dbid_map_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
134 struct ctdb_dbid_map **out, size_t *npull);
136 size_t ctdb_pulldb_len(struct ctdb_pulldb *in);
137 void ctdb_pulldb_push(struct ctdb_pulldb *in, uint8_t *buf, size_t *npush);
138 int ctdb_pulldb_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
139 struct ctdb_pulldb **out, size_t *npull);
141 size_t ctdb_pulldb_ext_len(struct ctdb_pulldb_ext *pulldb);
142 void ctdb_pulldb_ext_push(struct ctdb_pulldb_ext *pulldb, uint8_t *buf);
143 int ctdb_pulldb_ext_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
144 struct ctdb_pulldb_ext **out);
146 size_t ctdb_traverse_start_len(struct ctdb_traverse_start *traverse);
147 void ctdb_traverse_start_push(struct ctdb_traverse_start *traverse,
149 int ctdb_traverse_start_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
150 struct ctdb_traverse_start **out);
152 size_t ctdb_traverse_all_len(struct ctdb_traverse_all *traverse);
153 void ctdb_traverse_all_push(struct ctdb_traverse_all *traverse, uint8_t *buf);
154 int ctdb_traverse_all_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
155 struct ctdb_traverse_all **out);
157 size_t ctdb_traverse_start_ext_len(struct ctdb_traverse_start_ext *traverse);
158 void ctdb_traverse_start_ext_push(struct ctdb_traverse_start_ext *traverse,
160 int ctdb_traverse_start_ext_pull(uint8_t *buf, size_t buflen,
162 struct ctdb_traverse_start_ext **out);
164 size_t ctdb_traverse_all_ext_len(struct ctdb_traverse_all_ext *traverse);
165 void ctdb_traverse_all_ext_push(struct ctdb_traverse_all_ext *traverse,
167 int ctdb_traverse_all_ext_pull(uint8_t *buf, size_t buflen,
169 struct ctdb_traverse_all_ext **out);
171 size_t ctdb_sock_addr_len(ctdb_sock_addr *addr);
172 void ctdb_sock_addr_push(ctdb_sock_addr *addr, uint8_t *buf);
173 int ctdb_sock_addr_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
174 ctdb_sock_addr **out);
176 size_t ctdb_connection_len(struct ctdb_connection *conn);
177 void ctdb_connection_push(struct ctdb_connection *conn, uint8_t *buf);
178 int ctdb_connection_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
179 struct ctdb_connection **out);
181 size_t ctdb_tunable_len(struct ctdb_tunable *tunable);
182 void ctdb_tunable_push(struct ctdb_tunable *tunable, uint8_t *buf);
183 int ctdb_tunable_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
184 struct ctdb_tunable **out);
186 size_t ctdb_node_flag_change_len(struct ctdb_node_flag_change *flag_change);
187 void ctdb_node_flag_change_push(struct ctdb_node_flag_change *flag_change,
189 int ctdb_node_flag_change_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
190 struct ctdb_node_flag_change **out);
192 size_t ctdb_var_list_len(struct ctdb_var_list *var_list);
193 void ctdb_var_list_push(struct ctdb_var_list *var_list, uint8_t *buf);
194 int ctdb_var_list_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
195 struct ctdb_var_list **out);
197 size_t ctdb_tunable_list_len(struct ctdb_tunable_list *tun_list);
198 void ctdb_tunable_list_push(struct ctdb_tunable_list *tun_list, uint8_t *buf);
199 int ctdb_tunable_list_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
200 struct ctdb_tunable_list **out);
202 size_t ctdb_tickle_list_len(struct ctdb_tickle_list *tickles);
203 void ctdb_tickle_list_push(struct ctdb_tickle_list *tickles, uint8_t *buf);
204 int ctdb_tickle_list_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
205 struct ctdb_tickle_list **out);
207 size_t ctdb_addr_info_len(struct ctdb_addr_info *addr_info);
208 void ctdb_addr_info_push(struct ctdb_addr_info *addr_info, uint8_t *buf);
209 int ctdb_addr_info_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
210 struct ctdb_addr_info **out);
212 size_t ctdb_transdb_len(struct ctdb_transdb *transdb);
213 void ctdb_transdb_push(struct ctdb_transdb *transdb, uint8_t *buf);
214 int ctdb_transdb_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
215 struct ctdb_transdb **out);
217 size_t ctdb_uptime_len(struct ctdb_uptime *uptime);
218 void ctdb_uptime_push(struct ctdb_uptime *uptime, uint8_t *buf);
219 int ctdb_uptime_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
220 struct ctdb_uptime **out);
222 size_t ctdb_public_ip_len(struct ctdb_public_ip *public_ip);
223 void ctdb_public_ip_push(struct ctdb_public_ip *public_ip, uint8_t *buf);
224 int ctdb_public_ip_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
225 struct ctdb_public_ip **out);
227 size_t ctdb_public_ip_list_len(struct ctdb_public_ip_list *pubip_list);
228 void ctdb_public_ip_list_push(struct ctdb_public_ip_list *pubip_list,
230 int ctdb_public_ip_list_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
231 struct ctdb_public_ip_list **out);
233 size_t ctdb_node_and_flags_len(struct ctdb_node_and_flags *node);
234 void ctdb_node_and_flags_push(struct ctdb_node_and_flags *node, uint8_t *buf);
235 int ctdb_node_and_flags_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
236 struct ctdb_node_and_flags **out);
238 size_t ctdb_node_map_len(struct ctdb_node_map *nodemap);
239 void ctdb_node_map_push(struct ctdb_node_map *nodemap, uint8_t *buf);
240 int ctdb_node_map_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
241 struct ctdb_node_map **out);
243 size_t ctdb_script_len(struct ctdb_script *script);
244 void ctdb_script_push(struct ctdb_script *script, uint8_t *buf);
245 int ctdb_script_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
246 struct ctdb_script **out);
248 size_t ctdb_script_list_len(struct ctdb_script_list *script_list);
249 void ctdb_script_list_push(struct ctdb_script_list *script_list, uint8_t *buf);
250 int ctdb_script_list_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
251 struct ctdb_script_list **out);
253 size_t ctdb_ban_state_len(struct ctdb_ban_state *ban_state);
254 void ctdb_ban_state_push(struct ctdb_ban_state *ban_state, uint8_t *buf);
255 int ctdb_ban_state_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
256 struct ctdb_ban_state **out);
258 size_t ctdb_notify_data_len(struct ctdb_notify_data *notify);
259 void ctdb_notify_data_push(struct ctdb_notify_data *notify, uint8_t *buf);
260 int ctdb_notify_data_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
261 struct ctdb_notify_data **out);
263 size_t ctdb_iface_len(struct ctdb_iface *iface);
264 void ctdb_iface_push(struct ctdb_iface *iface, uint8_t *buf);
265 int ctdb_iface_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
266 struct ctdb_iface **out);
268 size_t ctdb_iface_list_len(struct ctdb_iface_list *iface_list);
269 void ctdb_iface_list_push(struct ctdb_iface_list *iface_list, uint8_t *buf);
270 int ctdb_iface_list_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
271 struct ctdb_iface_list **out);
273 size_t ctdb_public_ip_info_len(struct ctdb_public_ip_info *ipinfo);
274 void ctdb_public_ip_info_push(struct ctdb_public_ip_info *ipinfo, uint8_t *buf);
275 int ctdb_public_ip_info_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
276 struct ctdb_public_ip_info **out);
278 size_t ctdb_key_data_len(struct ctdb_key_data *key);
279 void ctdb_key_data_push(struct ctdb_key_data *key, uint8_t *buf);
280 int ctdb_key_data_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
281 struct ctdb_key_data **out);
283 size_t ctdb_db_statistics_len(struct ctdb_db_statistics *dbstats);
284 void ctdb_db_statistics_push(struct ctdb_db_statistics *dbstats, void *buf);
285 int ctdb_db_statistics_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
286 struct ctdb_db_statistics **out);
288 size_t ctdb_election_message_len(struct ctdb_election_message *election);
289 void ctdb_election_message_push(struct ctdb_election_message *election,
291 int ctdb_election_message_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
292 struct ctdb_election_message **out);
294 size_t ctdb_srvid_message_len(struct ctdb_srvid_message *msg);
295 void ctdb_srvid_message_push(struct ctdb_srvid_message *msg, uint8_t *buf);
296 int ctdb_srvid_message_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
297 struct ctdb_srvid_message **out);
299 size_t ctdb_disable_message_len(struct ctdb_disable_message *disable);
300 void ctdb_disable_message_push(struct ctdb_disable_message *disable,
302 int ctdb_disable_message_pull(uint8_t *buf, size_t buflen, TALLOC_CTX *mem_ctx,
303 struct ctdb_disable_message **out);
305 #endif /* __PROTOCOL_PRIVATE_H__ */