311 	struct evrpc_pool *pool;  in rpc_pool_with_connection()  local
313 	pool = evrpc_pool_new(NULL);  in rpc_pool_with_connection()
314 	assert(pool != NULL);  in rpc_pool_with_connection()
319 	evrpc_pool_add_connection(pool, evcon);  in rpc_pool_with_connection()
321 	return (pool);  in rpc_pool_with_connection()
450 	struct evrpc_pool *pool = NULL;  in rpc_basic_client()  local
464 	pool = rpc_pool_with_connection(port);  in rpc_basic_client()
465 	tt_assert(pool);  in rpc_basic_client()
467 	assert(evrpc_add_hook(pool, EVRPC_OUTPUT, rpc_hook_add_meta, NULL));  in rpc_basic_client()
468 	assert(evrpc_add_hook(pool, EVRPC_INPUT, rpc_hook_remove_header, (void*)"output"));  in rpc_basic_client()
478 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill,  GotKillCb, NULL);  in rpc_basic_client()
489 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill,  GotKillCb, NULL);  in rpc_basic_client()
501 			pool, msg, kill, GotKillCb, NULL);  in rpc_basic_client()
517 	if (pool)  in rpc_basic_client()
518 		evrpc_pool_free(pool);  in rpc_basic_client()
536 	struct evrpc_pool *pool = NULL;  in rpc_basic_queued_client()  local
542 	pool = rpc_pool_with_connection(port);  in rpc_basic_queued_client()
543 	tt_assert(pool);  in rpc_basic_queued_client()
554 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill_one,  GotKillCbTwo, NULL);  in rpc_basic_queued_client()
555 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill_two,  GotKillCb, NULL);  in rpc_basic_queued_client()
573 	if (pool)  in rpc_basic_queued_client()
574 		evrpc_pool_free(pool);  in rpc_basic_queued_client()
636 	struct evrpc_pool *pool = NULL;  in rpc_basic_client_with_pause()  local
645 	pool = rpc_pool_with_connection(port);  in rpc_basic_client_with_pause()
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()
658 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill, GotKillCb, NULL);  in rpc_basic_client_with_pause()
676 	if (pool)  in rpc_basic_client_with_pause()
677 		evrpc_pool_free(pool);  in rpc_basic_client_with_pause()
688 	struct evrpc_pool *pool = NULL;  in rpc_client_timeout()  local
694 	pool = rpc_pool_with_connection(port);  in rpc_client_timeout()
695 	tt_assert(pool);  in rpc_client_timeout()
698 	evrpc_pool_set_timeout(pool, 1);  in rpc_client_timeout()
708 	EVRPC_MAKE_REQUEST(NeverReply, pool, msg, kill, GotErrorCb, NULL);  in rpc_client_timeout()
727 	if (pool)  in rpc_client_timeout()
728 		evrpc_pool_free(pool);  in rpc_client_timeout()