Lines Matching defs:base
66 struct evrpc_base* base = calloc(1, sizeof(struct evrpc_base));
67 if (base == NULL)
73 TAILQ_INIT(&base->registered_rpcs);
74 TAILQ_INIT(&base->input_hooks);
75 TAILQ_INIT(&base->output_hooks);
76 base->http_server = http_server;
78 return (base);
82 evrpc_free(struct evrpc_base *base)
87 while ((rpc = TAILQ_FIRST(&base->registered_rpcs)) != NULL) {
88 assert(evrpc_unregister_rpc(base, rpc->uri));
90 while ((hook = TAILQ_FIRST(&base->input_hooks)) != NULL) {
91 assert(evrpc_remove_hook(base, EVRPC_INPUT, hook));
93 while ((hook = TAILQ_FIRST(&base->output_hooks)) != NULL) {
94 assert(evrpc_remove_hook(base, EVRPC_OUTPUT, hook));
96 free(base);
105 struct _evrpc_hooks *base = vbase;
110 head = &base->in_hooks;
113 head = &base->out_hooks;
151 struct _evrpc_hooks *base = vbase;
155 head = &base->in_hooks;
158 head = &base->out_hooks;
208 evrpc_register_rpc(struct evrpc_base *base, struct evrpc *rpc,
213 rpc->base = base;
217 TAILQ_INSERT_TAIL(&base->registered_rpcs, rpc, next);
219 evhttp_set_cb(base->http_server,
230 evrpc_unregister_rpc(struct evrpc_base *base, const char *name)
236 TAILQ_FOREACH(rpc, &base->registered_rpcs, next) {
244 TAILQ_REMOVE(&base->registered_rpcs, rpc, next);
252 assert(evhttp_del_cb(base->http_server, registered_uri) == 0);
274 if (evrpc_process_hooks(&rpc->base->input_hooks,
351 if (evrpc_process_hooks(&rpc->base->output_hooks,
383 evrpc_pool_new(struct event_base *base)
395 pool->base = base;
449 * associate an event base with this connection
451 if (pool->base != NULL)
452 evhttp_connection_set_base(connection, pool->base);
569 if (pool->base != NULL)
570 event_base_set(pool->base, &ctx->ev_timeout);
