Lines Matching defs:subreq
223 static void wbc_connect_connected(struct tevent_req *subreq);
230 struct tevent_req *result, *subreq;
289 subreq = async_connect_send(mem_ctx, ev, wb_ctx->fd,
292 if (subreq == NULL) {
295 tevent_req_set_callback(subreq, wbc_connect_connected, result);
306 static void wbc_connect_connected(struct tevent_req *subreq)
309 subreq, struct tevent_req);
312 res = async_connect_recv(subreq, &err);
313 TALLOC_FREE(subreq);
347 static void wb_open_pipe_connect_nonpriv_done(struct tevent_req *subreq);
348 static void wb_open_pipe_ping_done(struct tevent_req *subreq);
349 static void wb_open_pipe_getpriv_done(struct tevent_req *subreq);
350 static void wb_open_pipe_connect_priv_done(struct tevent_req *subreq);
357 struct tevent_req *result, *subreq;
373 subreq = wb_connect_send(state, ev, wb_ctx, wb_ctx->dir);
374 if (subreq == NULL) {
377 tevent_req_set_callback(subreq, wb_open_pipe_connect_nonpriv_done,
386 static void wb_open_pipe_connect_nonpriv_done(struct tevent_req *subreq)
389 subreq, struct tevent_req);
394 wbc_err = wb_connect_recv(subreq);
395 TALLOC_FREE(subreq);
406 subreq = wb_simple_trans_send(state, state->ev, NULL,
408 if (tevent_req_nomem(subreq, req)) {
411 tevent_req_set_callback(subreq, wb_open_pipe_ping_done, req);
414 static void wb_open_pipe_ping_done(struct tevent_req *subreq)
417 subreq, struct tevent_req);
423 ret = wb_simple_trans_recv(subreq, state, &wb_resp, &err);
424 TALLOC_FREE(subreq);
438 subreq = wb_simple_trans_send(state, state->ev, NULL,
440 if (tevent_req_nomem(subreq, req)) {
443 tevent_req_set_callback(subreq, wb_open_pipe_getpriv_done, req);
446 static void wb_open_pipe_getpriv_done(struct tevent_req *subreq)
449 subreq, struct tevent_req);
455 ret = wb_simple_trans_recv(subreq, state, &wb_resp, &err);
456 TALLOC_FREE(subreq);
465 subreq = wb_connect_send(state, state->ev, state->wb_ctx,
468 if (tevent_req_nomem(subreq, req)) {
471 tevent_req_set_callback(subreq, wb_open_pipe_connect_priv_done, req);
474 static void wb_open_pipe_connect_priv_done(struct tevent_req *subreq)
477 subreq, struct tevent_req);
482 wbc_err = wb_connect_recv(subreq);
483 TALLOC_FREE(subreq);
531 static void wb_trans_connect_done(struct tevent_req *subreq);
532 static void wb_trans_done(struct tevent_req *subreq);
533 static void wb_trans_retry_wait_done(struct tevent_req *subreq);
564 struct tevent_req *subreq;
573 subreq = wb_open_pipe_send(state, state->ev, state->wb_ctx,
575 if (tevent_req_nomem(subreq, req)) {
578 tevent_req_set_callback(subreq, wb_trans_connect_done, req);
584 subreq = wb_simple_trans_send(state, state->ev, NULL,
586 if (tevent_req_nomem(subreq, req)) {
589 tevent_req_set_callback(subreq, wb_trans_done, req);
596 struct tevent_req *subreq;
620 subreq = tevent_wakeup_send(state, state->ev,
622 if (tevent_req_nomem(subreq, req)) {
625 tevent_req_set_callback(subreq, wb_trans_retry_wait_done, req);
629 static void wb_trans_retry_wait_done(struct tevent_req *subreq)
632 subreq, struct tevent_req);
637 ret = tevent_wakeup_recv(subreq);
638 TALLOC_FREE(subreq);
644 subreq = wb_open_pipe_send(state, state->ev, state->wb_ctx,
646 if (tevent_req_nomem(subreq, req)) {
649 tevent_req_set_callback(subreq, wb_trans_connect_done, req);
652 static void wb_trans_connect_done(struct tevent_req *subreq)
655 subreq, struct tevent_req);
660 wbc_err = wb_open_pipe_recv(subreq);
661 TALLOC_FREE(subreq);
667 subreq = wb_simple_trans_send(state, state->ev, NULL,
669 if (tevent_req_nomem(subreq, req)) {
672 tevent_req_set_callback(subreq, wb_trans_done, req);
675 static void wb_trans_done(struct tevent_req *subreq)
678 subreq, struct tevent_req);
683 ret = wb_simple_trans_recv(subreq, state, &state->wb_resp, &err);
684 TALLOC_FREE(subreq);