Home
last modified time | relevance | path

Searched refs:ctdb_req_header (Results 1 – 25 of 34) sorted by relevance

12

/dports/net/samba412/samba-4.12.15/ctdb/protocol/
H A Dprotocol_api.h102 struct ctdb_req_header *h,
114 struct ctdb_req_header *h,
126 struct ctdb_req_header *h,
138 struct ctdb_req_header *h,
150 struct ctdb_req_header *h,
164 struct ctdb_req_header *h,
176 struct ctdb_req_header *h,
628 struct ctdb_req_header *h,
640 struct ctdb_req_header *h,
654 struct ctdb_req_header *h,
[all …]
H A Dprotocol_call.c92 struct ctdb_req_header *h, in ctdb_req_call_pull()
96 struct ctdb_req_header header; in ctdb_req_call_pull()
174 size_t ctdb_reply_call_len(struct ctdb_req_header *h, in ctdb_reply_call_len()
208 struct ctdb_req_header *h, in ctdb_reply_call_pull()
212 struct ctdb_req_header header; in ctdb_reply_call_pull()
276 struct ctdb_req_header *h, in ctdb_reply_error_pull()
280 struct ctdb_req_header header; in ctdb_reply_error_pull()
369 struct ctdb_req_header *h, in ctdb_req_dmaster_pull()
373 struct ctdb_req_header header; in ctdb_req_dmaster_pull()
507 struct ctdb_req_header *h, in ctdb_reply_dmaster_pull()
[all …]
H A Dprotocol_header.c30 int ctdb_req_header_verify(struct ctdb_req_header *h, uint32_t operation) in ctdb_req_header_verify()
32 if (h->length < sizeof(struct ctdb_req_header)) { in ctdb_req_header_verify()
51 void ctdb_req_header_fill(struct ctdb_req_header *h, uint32_t generation, in ctdb_req_header_fill()
55 h->length = sizeof(struct ctdb_req_header); in ctdb_req_header_fill()
65 size_t ctdb_req_header_len(struct ctdb_req_header *in) in ctdb_req_header_len()
77 void ctdb_req_header_push(struct ctdb_req_header *in, uint8_t *buf, in ctdb_req_header_push()
110 struct ctdb_req_header *out, size_t *npull) in ctdb_req_header_pull()
H A Dprotocol_keepalive.c30 size_t ctdb_req_keepalive_len(struct ctdb_req_header *h, in ctdb_req_keepalive_len()
38 int ctdb_req_keepalive_push(struct ctdb_req_header *h, in ctdb_req_keepalive_push()
64 struct ctdb_req_header *h, in ctdb_req_keepalive_pull()
68 struct ctdb_req_header header; in ctdb_req_keepalive_pull()
H A Dprotocol_tunnel.c30 size_t ctdb_req_tunnel_len(struct ctdb_req_header *h, in ctdb_req_tunnel_len()
39 int ctdb_req_tunnel_push(struct ctdb_req_header *h, in ctdb_req_tunnel_push()
72 struct ctdb_req_header *h, in ctdb_req_tunnel_pull()
76 struct ctdb_req_header header; in ctdb_req_tunnel_pull()
H A Dprotocol_message.c310 size_t ctdb_req_message_len(struct ctdb_req_header *h, in ctdb_req_message_len()
320 int ctdb_req_message_push(struct ctdb_req_header *h, in ctdb_req_message_push()
352 struct ctdb_req_header *h, in ctdb_req_message_pull()
356 struct ctdb_req_header header; in ctdb_req_message_pull()
397 size_t ctdb_req_message_data_len(struct ctdb_req_header *h, in ctdb_req_message_data_len()
405 int ctdb_req_message_data_push(struct ctdb_req_header *h, in ctdb_req_message_data_push()
432 struct ctdb_req_header *h, in ctdb_req_message_data_pull()
436 struct ctdb_req_header header; in ctdb_req_message_data_pull()
H A Dprotocol_control.c1761 size_t ctdb_req_control_len(struct ctdb_req_header *h, in ctdb_req_control_len()
1776 int ctdb_req_control_push(struct ctdb_req_header *h, in ctdb_req_control_push()
1824 struct ctdb_req_header *h, in ctdb_req_control_pull()
1828 struct ctdb_req_header header; in ctdb_req_control_pull()
1897 size_t ctdb_reply_control_len(struct ctdb_req_header *h, in ctdb_reply_control_len()
1917 int ctdb_reply_control_push(struct ctdb_req_header *h, in ctdb_reply_control_push()
1963 struct ctdb_req_header *h, in ctdb_reply_control_pull()
1967 struct ctdb_req_header header; in ctdb_reply_control_pull()
/dports/net/samba412/samba-4.12.15/ctdb/tests/src/
H A Dprotocol_ctdb_compat_test.c235 struct ctdb_req_header hdr;
342 struct ctdb_req_header hdr;
423 struct ctdb_req_header hdr;
504 struct ctdb_req_header hdr;
603 struct ctdb_req_header hdr;
699 struct ctdb_req_header hdr;
793 struct ctdb_req_header hdr;
898 struct ctdb_req_header hdr;
1048 struct ctdb_req_header hdr;
1112 struct ctdb_req_header hdr;
[all …]
H A Dfake_ctdbd.c1590 struct ctdb_req_header *header, in client_send_message()
1630 struct ctdb_req_header *header, in client_send_control()
1713 struct ctdb_req_header *header, in control_ping()
1877 struct ctdb_req_header *header, in control_get_recmode()
1895 struct ctdb_req_header header;
3198 struct ctdb_req_header *header;
3748 struct ctdb_req_header header; in client_read_handler()
3822 struct ctdb_req_header header; in client_process_packet()
3856 struct ctdb_req_header header; in client_process_call()
3927 struct ctdb_req_header header; in client_process_message()
[all …]
H A Dprotocol_common_ctdb.h31 void fill_ctdb_req_header(struct ctdb_req_header *h);
32 void verify_ctdb_req_header(struct ctdb_req_header *h, in fill_ctdb_req_header()
33 struct ctdb_req_header *h2); in fill_ctdb_req_header()
H A Dprotocol_ctdb_test.c137 struct ctdb_req_header h1, h2; \
173 struct ctdb_req_header h1, h2; \
209 struct ctdb_req_header h1, h2; \
245 struct ctdb_req_header h1, h2; \ in ctdb_req_call_len_old()
276 PROTOCOL_CTDB1_TEST(struct ctdb_req_header, ctdb_req_header);
338 TEST_FUNC(ctdb_req_header)();
/dports/net/samba412/samba-4.12.15/ctdb/include/
H A Dctdb_protocol.h62 struct ctdb_req_header hdr;
73 struct ctdb_req_header hdr;
80 struct ctdb_req_header hdr;
87 struct ctdb_req_header hdr;
97 struct ctdb_req_header hdr;
106 struct ctdb_req_header hdr;
113 struct ctdb_req_header hdr;
124 struct ctdb_req_header hdr;
132 struct ctdb_req_header hdr;
138 struct ctdb_req_header hdr;
H A Dctdb_private.h496 struct ctdb_req_header *hdr);
498 struct ctdb_req_header *hdr);
525 TDB_DATA key, struct ctdb_req_header *hdr,
540 struct ctdb_req_header *hdr);
542 struct ctdb_req_header *hdr);
646 struct ctdb_req_header *hdr);
693 TDB_DATA key, struct ctdb_req_header *hdr,
699 struct ctdb_req_header *hdr, TDB_DATA *data,
700 void (*recv_pkt)(void *, struct ctdb_req_header *),
856 struct ctdb_req_header *hdr, unsigned opcode);
[all …]
H A Dctdb_client.h58 struct ctdb_req_header *_ctdbd_allocate_pkt(struct ctdb_context *ctdb,
73 struct ctdb_req_header *hdr);
/dports/net/samba412/samba-4.12.15/ctdb/server/
H A Dctdb_server.c187 void ctdb_input_pkt(struct ctdb_context *ctdb, struct ctdb_req_header *hdr) in ctdb_input_pkt()
348 struct ctdb_req_header *hdr;
368 static void ctdb_defer_packet(struct ctdb_context *ctdb, struct ctdb_req_header *hdr) in ctdb_defer_packet()
396 struct ctdb_req_header *hdr) in ctdb_broadcast_packet_all()
412 struct ctdb_req_header *hdr) in ctdb_broadcast_packet_active()
429 struct ctdb_req_header *hdr) in ctdb_broadcast_packet_connected()
446 void ctdb_queue_packet(struct ctdb_context *ctdb, struct ctdb_req_header *hdr) in ctdb_queue_packet()
501 void ctdb_queue_packet_opcode(struct ctdb_context *ctdb, struct ctdb_req_header *hdr, unsigned opco… in ctdb_queue_packet_opcode()
H A Dctdb_call.c70 static void ctdb_call_input_pkt(void *p, struct ctdb_req_header *hdr) in ctdb_call_input_pkt()
81 struct ctdb_req_header *hdr, uint32_t status,
84 struct ctdb_req_header *hdr, uint32_t status, in ctdb_send_error()
340 struct ctdb_req_header *hdr, in ctdb_become_dmaster()
438 struct ctdb_req_header *hdr;
491 struct ctdb_req_header *hdr, in dmaster_defer_setup()
536 struct ctdb_req_header *hdr, in dmaster_defer_add()
745 struct ctdb_req_header *hdr;
750 struct ctdb_req_header *hdr;
1174 void ctdb_reply_call(struct ctdb_context *ctdb, struct ctdb_req_header *hdr) in ctdb_reply_call()
[all …]
H A Dctdb_daemon.c61 static void daemon_incoming_packet(void *, struct ctdb_req_header *);
414 ctdb_request_message(client->ctdb, (struct ctdb_req_header *)c); in daemon_request_message_from_client()
521 static void daemon_incoming_packet_wrap(void *p, struct ctdb_req_header *hdr) in daemon_incoming_packet_wrap()
568 daemon_incoming_packet(client, (struct ctdb_req_header *)dfr->dfc->c); in reprocess_deferred_call()
774 (struct ctdb_req_header *)c, &data, in daemon_request_call_from_client()
947 static void daemon_incoming_packet(void *p, struct ctdb_req_header *hdr) in daemon_incoming_packet()
1006 struct ctdb_req_header *hdr; in ctdb_daemon_read_cb()
1020 hdr = (struct ctdb_req_header *)data; in ctdb_daemon_read_cb()
1570 struct ctdb_req_header *_ctdb_transport_allocate(struct ctdb_context *ctdb, in _ctdb_transport_allocate()
1577 struct ctdb_req_header *hdr; in _ctdb_transport_allocate()
[all …]
H A Dctdb_keepalive.c190 struct ctdb_req_header *hdr) in ctdb_request_keepalive()
202 if (hdr->length == sizeof(struct ctdb_req_header)) { in ctdb_request_keepalive()
H A Dctdb_client.c47 struct ctdb_req_header *_ctdbd_allocate_pkt(struct ctdb_context *ctdb, in _ctdbd_allocate_pkt()
54 struct ctdb_req_header *hdr; in _ctdbd_allocate_pkt()
59 hdr = (struct ctdb_req_header *)talloc_zero_size(mem_ctx, size); in _ctdbd_allocate_pkt()
150 static int ctdb_client_queue_pkt(struct ctdb_context *ctdb, struct ctdb_req_header *hdr) in ctdb_client_queue_pkt()
162 static void ctdb_client_reply_call(struct ctdb_context *ctdb, struct ctdb_req_header *hdr) in ctdb_client_reply_call()
193 struct ctdb_req_header *hdr) in ctdb_request_message()
208 static void ctdb_client_reply_control(struct ctdb_context *ctdb, struct ctdb_req_header *hdr);
216 struct ctdb_req_header *hdr = (struct ctdb_req_header *)data; in ctdb_client_read_cb()
618 struct ctdb_req_header *hdr) in ctdb_client_reply_control()
H A Dctdbd.c55 struct ctdb_req_header *hdr = (struct ctdb_req_header *)data; in ctdb_recv_pkt()
H A Dctdb_ltdb_server.c242 void (*recv_pkt)(void *, struct ctdb_req_header *);
244 struct ctdb_req_header *hdr;
291 TDB_DATA key, struct ctdb_req_header *hdr, in ctdb_ltdb_lock_requeue()
292 void (*recv_pkt)(void *, struct ctdb_req_header *), in ctdb_ltdb_lock_requeue() argument
348 struct ctdb_req_header *hdr, TDB_DATA *data, in ctdb_ltdb_lock_fetch_requeue()
349 void (*recv_pkt)(void *, struct ctdb_req_header *), in ctdb_ltdb_lock_fetch_requeue() argument
1075 ctdb_input_pkt(ctdb, (struct ctdb_req_header *)da_ctx->c); in ctdb_deferred_attach_callback()
/dports/net/samba412/samba-4.12.15/ctdb/tcp/
H A Dtcp_io.c43 struct ctdb_req_header *hdr = (struct ctdb_req_header *)data; in ctdb_tcp_read_cb()
/dports/net/samba412/samba-4.12.15/source3/lib/
H A Dctdbd_conn.c77 struct ctdb_req_header *hdr; in ctdbd_process_exists()
338 struct ctdb_req_header *req;
401 struct ctdb_req_header *hdr = NULL;
581 struct ctdb_req_header *hdr)
601 struct ctdb_req_header *hdr = NULL;
703 struct ctdb_req_header *hdr;
883 struct ctdb_req_header *hdr = NULL;
957 struct ctdb_req_header *hdr = NULL;
1082 struct ctdb_req_header *hdr = NULL;
1589 struct ctdb_req_header *hdr;
[all …]
/dports/net/samba412/samba-4.12.15/ctdb/client/
H A Dclient_call.c61 struct ctdb_req_header h; in ctdb_client_call_send()
143 struct ctdb_req_header h; in ctdb_client_reply_call()
H A Dclient_tunnel.c41 struct ctdb_req_header hdr;
332 struct ctdb_req_header h; in ctdb_client_req_tunnel()
403 struct ctdb_req_header h; in ctdb_tunnel_request_send()
587 struct ctdb_req_header h; in ctdb_tunnel_reply_send()

12