Home
last modified time | relevance | path

Searched refs:pool (Results 1 – 7 of 7) sorted by relevance

/libevent-2.1.12/
H A Devrpc.c511 if (pool == NULL) in evrpc_pool_new()
522 pool->base = base; in evrpc_pool_new()
525 return (pool); in evrpc_pool_new()
571 mm_free(pool); in evrpc_pool_free()
663 struct evrpc_pool *pool = ctx->pool; in evrpc_schedule_request() local
723 struct evrpc_pool *pool = ctx->pool; in evrpc_schedule_request_closure() local
802 struct evrpc_pool *pool = ctx->pool; in evrpc_make_request() local
837 ctx->pool = pool; in evrpc_make_request_ctx()
863 struct evrpc_pool *pool = ctx->pool; in evrpc_reply_done() local
917 struct evrpc_pool *pool = ctx->pool; in evrpc_reply_done_closure() local
[all …]
H A Devrpc-internal.h174 struct evrpc_pool *pool; member
H A DChangeLog-1.4213 o associate an event base with an rpc pool
H A Dwhatsnew-2.1.txt530 timeout pool. (People who are using this pattern should also consider
H A DChangeLog-2.01213 o allow connections to be removed from an rpc pool
/libevent-2.1.12/test/
H A Dregress_rpc.c321 return (pool); in rpc_pool_with_connection()
465 tt_assert(pool); in rpc_basic_client()
517 if (pool) in rpc_basic_client()
543 tt_assert(pool); in rpc_basic_queued_client()
573 if (pool) in rpc_basic_queued_client()
646 tt_assert(pool); in rpc_basic_client_with_pause()
647 assert(evrpc_add_hook(pool, EVRPC_INPUT, rpc_hook_pause, pool)); in rpc_basic_client_with_pause()
648 assert(evrpc_add_hook(pool, EVRPC_OUTPUT, rpc_hook_pause, pool)); in rpc_basic_client_with_pause()
676 if (pool) in rpc_basic_client_with_pause()
695 tt_assert(pool); in rpc_client_timeout()
[all …]
/libevent-2.1.12/include/event2/
H A Drpc.h197 struct evrpc_pool *pool, void *request, void *reply,
220 pool, request, reply, cb, cbarg) \ argument
221 evrpc_make_request_ctx(pool, request, reply, \
240 int evrpc_send_request_##rpcname(struct evrpc_pool *pool, \
245 return evrpc_send_request_generic(pool, request, reply, \
387 #define EVRPC_MAKE_REQUEST(name, pool, request, reply, cb, cbarg) \ argument
423 void evrpc_pool_free(struct evrpc_pool *pool);
434 void evrpc_pool_add_connection(struct evrpc_pool *pool,
446 void evrpc_pool_remove_connection(struct evrpc_pool *pool,
586 int evrpc_send_request_generic(struct evrpc_pool *pool,
[all …]