rpc               149 opal/mca/event/libevent2022/libevent/evrpc-internal.h 	struct evrpc *rpc;
rpc                94 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evrpc *rpc;
rpc                99 opal/mca/event/libevent2022/libevent/evrpc.c 	while ((rpc = TAILQ_FIRST(&base->registered_rpcs)) != NULL) {
rpc               100 opal/mca/event/libevent2022/libevent/evrpc.c 		r = evrpc_unregister_rpc(base, rpc->uri);
rpc               227 opal/mca/event/libevent2022/libevent/evrpc.c evrpc_register_rpc(struct evrpc_base *base, struct evrpc *rpc,
rpc               230 opal/mca/event/libevent2022/libevent/evrpc.c 	char *constructed_uri = evrpc_construct_uri(rpc->uri);
rpc               232 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->base = base;
rpc               233 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->cb = cb;
rpc               234 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->cb_arg = cb_arg;
rpc               236 opal/mca/event/libevent2022/libevent/evrpc.c 	TAILQ_INSERT_TAIL(&base->registered_rpcs, rpc, next);
rpc               241 opal/mca/event/libevent2022/libevent/evrpc.c 	    rpc);
rpc               252 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evrpc *rpc;
rpc               256 opal/mca/event/libevent2022/libevent/evrpc.c 	TAILQ_FOREACH(rpc, &base->registered_rpcs, next) {
rpc               257 opal/mca/event/libevent2022/libevent/evrpc.c 		if (strcmp(rpc->uri, name) == 0)
rpc               260 opal/mca/event/libevent2022/libevent/evrpc.c 	if (rpc == NULL) {
rpc               264 opal/mca/event/libevent2022/libevent/evrpc.c 	TAILQ_REMOVE(&base->registered_rpcs, rpc, next);
rpc               274 opal/mca/event/libevent2022/libevent/evrpc.c 	mm_free((char *)rpc->uri);
rpc               275 opal/mca/event/libevent2022/libevent/evrpc.c 	mm_free(rpc);
rpc               286 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evrpc *rpc = arg;
rpc               297 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc_state->rpc = rpc;
rpc               301 opal/mca/event/libevent2022/libevent/evrpc.c 	if (TAILQ_FIRST(&rpc->base->input_hooks) != NULL) {
rpc               309 opal/mca/event/libevent2022/libevent/evrpc.c 		hook_res = evrpc_process_hooks(&rpc->base->input_hooks,
rpc               315 opal/mca/event/libevent2022/libevent/evrpc.c 			evrpc_pause_request(rpc->base, rpc_state,
rpc               341 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evrpc *rpc;
rpc               345 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc = rpc_state->rpc;
rpc               352 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc_state->request = rpc->request_new(rpc->request_new_arg);
rpc               356 opal/mca/event/libevent2022/libevent/evrpc.c 	if (rpc->request_unmarshal(
rpc               364 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc_state->reply = rpc->reply_new(rpc->reply_new_arg);
rpc               369 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->cb(rpc_state, rpc->cb_arg);
rpc               384 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evrpc *rpc;
rpc               386 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc = rpc_state->rpc;
rpc               392 opal/mca/event/libevent2022/libevent/evrpc.c 		rpc->request_free(rpc_state->request);
rpc               394 opal/mca/event/libevent2022/libevent/evrpc.c 		rpc->reply_free(rpc_state->reply);
rpc               407 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evrpc *rpc;
rpc               412 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc = rpc_state->rpc;
rpc               414 opal/mca/event/libevent2022/libevent/evrpc.c 	if (rpc->reply_complete(rpc_state->reply) == -1) {
rpc               425 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->reply_marshal(rpc_state->rpc_data, rpc_state->reply);
rpc               427 opal/mca/event/libevent2022/libevent/evrpc.c 	if (TAILQ_FIRST(&rpc->base->output_hooks) != NULL) {
rpc               433 opal/mca/event/libevent2022/libevent/evrpc.c 		hook_res = evrpc_process_hooks(&rpc->base->output_hooks,
rpc               439 opal/mca/event/libevent2022/libevent/evrpc.c 			if (evrpc_pause_request(rpc->base, rpc_state,
rpc              1114 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evrpc* rpc = (struct evrpc *)mm_calloc(1, sizeof(struct evrpc));
rpc              1115 opal/mca/event/libevent2022/libevent/evrpc.c 	if (rpc == NULL)
rpc              1117 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->uri = mm_strdup(name);
rpc              1118 opal/mca/event/libevent2022/libevent/evrpc.c 	if (rpc->uri == NULL) {
rpc              1119 opal/mca/event/libevent2022/libevent/evrpc.c 		mm_free(rpc);
rpc              1122 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->request_new = req_new;
rpc              1123 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->request_new_arg = req_new_arg;
rpc              1124 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->request_free = req_free;
rpc              1125 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->request_unmarshal = req_unmarshal;
rpc              1126 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->reply_new = rpl_new;
rpc              1127 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->reply_new_arg = rpl_new_arg;
rpc              1128 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->reply_free = rpl_free;
rpc              1129 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->reply_complete = rpl_complete;
rpc              1130 opal/mca/event/libevent2022/libevent/evrpc.c 	rpc->reply_marshal = rpl_marshal;
rpc              1131 opal/mca/event/libevent2022/libevent/evrpc.c 	return (rpc);
rpc              1143 opal/mca/event/libevent2022/libevent/evrpc.c 	struct evrpc* rpc =
rpc              1146 opal/mca/event/libevent2022/libevent/evrpc.c 	if (rpc == NULL)
rpc              1148 opal/mca/event/libevent2022/libevent/evrpc.c 	evrpc_register_rpc(base, rpc,
rpc               177 opal/mca/event/libevent2022/libevent/include/event2/rpc.h 	struct evrpc* rpc; \
rpc               108 opal/mca/event/libevent2022/libevent/test/regress_rpc.c MessageCb(EVRPC_STRUCT(Message)* rpc, void *arg)
rpc               110 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	struct kill* kill_reply = rpc->reply;
rpc               113 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 		struct evhttp_request* req = EVRPC_REQUEST_HTTP(rpc);
rpc               125 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	EVRPC_REQUEST_DONE(rpc);
rpc               131 opal/mca/event/libevent2022/libevent/test/regress_rpc.c NeverReplyCb(EVRPC_STRUCT(NeverReply)* rpc, void *arg)
rpc               134 opal/mca/event/libevent2022/libevent/test/regress_rpc.c 	saved_rpc = rpc;