Lines Matching refs:request
282 /* let's check that we can parse the request */
283 rpc_state->request = rpc->request_new();
284 if (rpc_state->request == NULL)
290 rpc_state->request, req->input_buffer) == -1) {
291 /* we failed to parse the request; that's a bummer */
295 /* at this point, we have a well formed request, prepare the reply */
322 if (rpc_state->request != NULL)
323 rpc->request_free(rpc_state->request);
350 /* do hook based tweaks to the request */
402 evrpc_request_wrapper_free(struct evrpc_request_wrapper *request)
404 free(request->name);
405 free(request);
412 struct evrpc_request_wrapper *request;
415 while ((request = TAILQ_FIRST(&pool->requests)) != NULL) {
416 TAILQ_REMOVE(&pool->requests, request, next);
418 evrpc_request_wrapper_free(request);
438 * Add a connection to the RPC pool. A request scheduled on the pool
467 struct evrpc_request_wrapper *request =
469 TAILQ_REMOVE(&pool->requests, request, next);
470 evrpc_schedule_request(connection, request);
490 * idle and can be used to make a request.
520 /* serialize the request data into the output buffer */
521 ctx->request_marshal(req->output_buffer, ctx->request);
530 /* apply hooks to the outgoing request */
545 /* start the request over the connection */
557 (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg);
576 * if no connection is available, we queue the request on the pool,
602 /* apply hooks to the incoming request */
623 (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg);
627 /* the http layer owns the request structure */
629 /* see if we can schedule another request */
