rpc_state 82 opal/mca/event/libevent2022/libevent/evrpc-internal.h void evrpc_reqstate_free(struct evrpc_req_generic* rpc_state); rpc_state 287 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_req_generic *rpc_state = NULL; rpc_state 294 opal/mca/event/libevent2022/libevent/evrpc.c rpc_state = mm_calloc(1, sizeof(struct evrpc_req_generic)); rpc_state 295 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state == NULL) rpc_state 297 opal/mca/event/libevent2022/libevent/evrpc.c rpc_state->rpc = rpc; rpc_state 298 opal/mca/event/libevent2022/libevent/evrpc.c rpc_state->http_req = req; rpc_state 299 opal/mca/event/libevent2022/libevent/evrpc.c rpc_state->rpc_data = NULL; rpc_state 304 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_hook_associate_meta(&rpc_state->hook_meta, req->evcon); rpc_state 310 opal/mca/event/libevent2022/libevent/evrpc.c rpc_state, req, req->input_buffer); rpc_state 315 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_pause_request(rpc->base, rpc_state, rpc_state 327 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_request_cb_closure(rpc_state, EVRPC_CONTINUE); rpc_state 331 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state != NULL) rpc_state 332 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_reqstate_free(rpc_state); rpc_state 340 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_req_generic *rpc_state = arg; rpc_state 344 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(rpc_state); rpc_state 345 opal/mca/event/libevent2022/libevent/evrpc.c rpc = rpc_state->rpc; rpc_state 346 opal/mca/event/libevent2022/libevent/evrpc.c req = rpc_state->http_req; rpc_state 352 opal/mca/event/libevent2022/libevent/evrpc.c rpc_state->request = rpc->request_new(rpc->request_new_arg); rpc_state 353 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state->request == NULL) rpc_state 357 opal/mca/event/libevent2022/libevent/evrpc.c rpc_state->request, req->input_buffer) == -1) { rpc_state 364 opal/mca/event/libevent2022/libevent/evrpc.c rpc_state->reply = rpc->reply_new(rpc->reply_new_arg); rpc_state 365 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state->reply == NULL) rpc_state 369 opal/mca/event/libevent2022/libevent/evrpc.c rpc->cb(rpc_state, rpc->cb_arg); rpc_state 374 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state != NULL) rpc_state 375 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_reqstate_free(rpc_state); rpc_state 382 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_reqstate_free(struct evrpc_req_generic* rpc_state) rpc_state 385 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(rpc_state != NULL); rpc_state 386 opal/mca/event/libevent2022/libevent/evrpc.c rpc = rpc_state->rpc; rpc_state 389 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state->hook_meta != NULL) rpc_state 390 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_hook_context_free(rpc_state->hook_meta); rpc_state 391 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state->request != NULL) rpc_state 392 opal/mca/event/libevent2022/libevent/evrpc.c rpc->request_free(rpc_state->request); rpc_state 393 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state->reply != NULL) rpc_state 394 opal/mca/event/libevent2022/libevent/evrpc.c rpc->reply_free(rpc_state->reply); rpc_state 395 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state->rpc_data != NULL) rpc_state 396 opal/mca/event/libevent2022/libevent/evrpc.c evbuffer_free(rpc_state->rpc_data); rpc_state 397 opal/mca/event/libevent2022/libevent/evrpc.c mm_free(rpc_state); rpc_state 404 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_request_done(struct evrpc_req_generic *rpc_state) rpc_state 409 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(rpc_state); rpc_state 411 opal/mca/event/libevent2022/libevent/evrpc.c req = rpc_state->http_req; rpc_state 412 opal/mca/event/libevent2022/libevent/evrpc.c rpc = rpc_state->rpc; rpc_state 414 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc->reply_complete(rpc_state->reply) == -1) { rpc_state 419 opal/mca/event/libevent2022/libevent/evrpc.c if ((rpc_state->rpc_data = evbuffer_new()) == NULL) { rpc_state 425 opal/mca/event/libevent2022/libevent/evrpc.c rpc->reply_marshal(rpc_state->rpc_data, rpc_state->reply); rpc_state 430 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_hook_associate_meta(&rpc_state->hook_meta, req->evcon); rpc_state 434 opal/mca/event/libevent2022/libevent/evrpc.c rpc_state, req, rpc_state->rpc_data); rpc_state 439 opal/mca/event/libevent2022/libevent/evrpc.c if (evrpc_pause_request(rpc->base, rpc_state, rpc_state 452 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_request_done_closure(rpc_state, EVRPC_CONTINUE); rpc_state 456 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state != NULL) rpc_state 457 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_reqstate_free(rpc_state); rpc_state 477 opal/mca/event/libevent2022/libevent/evrpc.c struct evrpc_req_generic *rpc_state = arg; rpc_state 479 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(rpc_state); rpc_state 480 opal/mca/event/libevent2022/libevent/evrpc.c req = rpc_state->http_req; rpc_state 490 opal/mca/event/libevent2022/libevent/evrpc.c evhttp_send_reply(req, HTTP_OK, "OK", rpc_state->rpc_data); rpc_state 492 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_reqstate_free(rpc_state); rpc_state 497 opal/mca/event/libevent2022/libevent/evrpc.c if (rpc_state != NULL) rpc_state 498 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_reqstate_free(rpc_state);