sntp/libevent/evrpc.c

74 	struct evrpc_base* base = mm_calloc(1, sizeof(struct evrpc_base));
75 	if (base == NULL)
81 	TAILQ_INIT(&base->registered_rpcs);
82 	TAILQ_INIT(&base->input_hooks);
83 	TAILQ_INIT(&base->output_hooks);
85 	TAILQ_INIT(&base->paused_requests);
87 	base->http_server = http_server;
89 	return (base);
93 evrpc_free(struct evrpc_base *base)
100 	while ((rpc = TAILQ_FIRST(&base->registered_rpcs)) != NULL) {
101 		r = evrpc_unregister_rpc(base, rpc->uri);
104 	while ((pause = TAILQ_FIRST(&base->paused_requests)) != NULL) {
105 		TAILQ_REMOVE(&base->paused_requests, pause, next);
108 	while ((hook = TAILQ_FIRST(&base->input_hooks)) != NULL) {
109 		r = evrpc_remove_hook(base, EVRPC_INPUT, hook);
112 	while ((hook = TAILQ_FIRST(&base->output_hooks)) != NULL) {
113 		r = evrpc_remove_hook(base, EVRPC_OUTPUT, hook);
116 	mm_free(base);
125 	struct evrpc_hooks_ *base = vbase;
130 		head = &base->in_hooks;
133 		head = &base->out_hooks;
171 	struct evrpc_hooks_ *base = vbase;
175 		head = &base->in_hooks;
178 		head = &base->out_hooks;
228 evrpc_register_rpc(struct evrpc_base *base, struct evrpc *rpc,
233 	rpc->base = base;
237 	TAILQ_INSERT_TAIL(&base->registered_rpcs, rpc, next);
239 	evhttp_set_cb(base->http_server,
250 evrpc_unregister_rpc(struct evrpc_base *base, const char *name)
257 	TAILQ_FOREACH(rpc, &base->registered_rpcs, next) {
265 	TAILQ_REMOVE(&base->registered_rpcs, rpc, next);
270 	r = evhttp_del_cb(base->http_server, registered_uri);
302 	if (TAILQ_FIRST(&rpc->base->input_hooks) != NULL) {
310 		hook_res = evrpc_process_hooks(&rpc->base->input_hooks,
316 			evrpc_pause_request(rpc->base, rpc_state,
426 	if (TAILQ_FIRST(&rpc->base->output_hooks) != NULL) {
432 		hook_res = evrpc_process_hooks(&rpc->base->output_hooks,
438 			if (evrpc_pause_request(rpc->base, rpc_state,
507 evrpc_pool_new(struct event_base *base)
521 	pool->base = base;
586 	 * associate an event base with this connection
588 	if (pool->base != NULL)
589 		evhttp_connection_set_base(connection, pool->base);
765 	struct evrpc_hooks_ *base = vbase;
773 	TAILQ_INSERT_TAIL(&base->pause_requests, pause, next);
780 	struct evrpc_hooks_ *base = vbase;
781 	struct evrpc_pause_list *head = &base->pause_requests;
804 	evtimer_assign(&ctx->ev_timeout, pool->base, evrpc_request_timeout, ctx);
1132 evrpc_register_generic(struct evrpc_base *base, const char *name,
1145 	evrpc_register_rpc(base, rpc,