Lines Matching refs:reply
365 rpc_state->reply = rpc->reply_new(rpc->reply_new_arg); in evrpc_request_cb_closure()
366 if (rpc_state->reply == NULL) in evrpc_request_cb_closure()
393 if (rpc_state->reply != NULL) in evrpc_reqstate_free_()
394 rpc->reply_free(rpc_state->reply); in evrpc_reqstate_free_()
414 if (rpc->reply_complete(rpc_state->reply) == -1) { in evrpc_request_done()
425 rpc->reply_marshal(rpc_state->rpc_data, rpc_state->reply); in evrpc_request_done()
470 return req->reply; in evrpc_get_reply()
712 (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); in evrpc_schedule_request()
757 (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); in evrpc_schedule_request_closure()
824 struct evrpc_pool *pool, void *request, void *reply, in evrpc_make_request_ctx() argument
848 ctx->reply = reply; in evrpc_make_request_ctx()
930 res = ctx->reply_unmarshal(ctx->reply, req->input_buffer); in evrpc_reply_done_closure()
937 ctx->reply_clear(ctx->reply); in evrpc_reply_done_closure()
940 (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); in evrpc_reply_done_closure()
1080 void *request, void *reply, in evrpc_send_request_generic() argument
1090 ctx = evrpc_make_request_ctx(pool, request, reply, in evrpc_send_request_generic()
1098 (*(cb))(&status, request, reply, cb_arg); in evrpc_send_request_generic()
1166 void (*cb)(struct evrpc_status*, void *request, void *reply, void *arg), in evrpc_request_set_cb() argument