Lines Matching refs:irpc
4 local test for irpc code
24 #include "lib/messaging/irpc.h"
41 serve up AddOne over the irpc system
43 static NTSTATUS irpc_AddOne(struct irpc_message *irpc, struct echo_AddOne *r)
59 struct irpc_message *irpc = talloc_get_type(private_data, struct irpc_message);
60 struct echo_EchoData *r = irpc->data;
63 irpc_send_reply(irpc, NT_STATUS_NO_MEMORY);
66 irpc_send_reply(irpc, NT_STATUS_OK);
71 serve up EchoData over the irpc system
73 static NTSTATUS irpc_EchoData(struct irpc_message *irpc, struct echo_EchoData *r)
75 irpc->defer_reply = true;
76 event_add_timed(irpc->ev, irpc, timeval_zero(), deferred_echodata, irpc);
145 static void irpc_callback(struct irpc_request *irpc)
147 struct echo_AddOne *r = (struct echo_AddOne *)irpc->r;
148 int *pong_count = (int *)irpc->async.private_data;
149 NTSTATUS status = irpc_call_recv(irpc);
151 printf("irpc call failed - %s\n", nt_errstr(status));
181 struct irpc_request *irpc;
183 irpc = IRPC_CALL_SEND(data->msg_ctx1, cluster_id(0, MSG_ID2),
186 torture_assert(tctx, irpc != NULL, "AddOne send failed");
188 irpc->async.fn = irpc_callback;
189 irpc->async.private_data = &pong_count;
250 struct torture_tcase *tcase = torture_suite_add_tcase(suite, "irpc");