Home
last modified time | relevance | path

Searched refs:timeout_ev (Results 1 – 25 of 35) sorted by relevance

12

/dports/www/nginx-full/nchan-1.2.12/src/subscribers/
H A Dmemstore_ipc.c26 ngx_event_t timeout_ev; member
42 if(d->timeout_ev.timer_set) { in sub_dequeue()
43 ngx_del_timer(&d->timeout_ev); in sub_dequeue()
132 if(data->timeout_ev.timer_set) { in reset_timer()
133 ngx_del_timer(&data->timeout_ev); in reset_timer()
135 ngx_add_timer(&data->timeout_ev, MEMSTORE_IPC_SUBSCRIBER_TIMEOUT * 1000); in reset_timer()
185 ngx_memzero(&d->timeout_ev, sizeof(d->timeout_ev)); in memstore_ipc_subscriber_create()
186 nchan_init_timer(&d->timeout_ev, timeout_ev_handler, d); in memstore_ipc_subscriber_create()
H A Dinternal.c57 nchan_subscriber_init_timeout_timer(&fsub->sub, &fsub->timeout_ev); in internal_subscriber_create()
158 if(f->timeout_ev.timer_set) { in reset_timer()
159 ngx_del_timer(&f->timeout_ev); in reset_timer()
161 ngx_add_timer(&f->timeout_ev, f->sub.cf->subscriber_timeout * 1000); in reset_timer()
168 if(self->cf && self->cf->subscriber_timeout > 0 && !fsub->timeout_ev.timer_set) { in internal_enqueue()
192 if(self->cf && self->cf->subscriber_timeout > 0 && f->timeout_ev.timer_set) { in internal_dequeue()
193 ngx_del_timer(&f->timeout_ev); in internal_dequeue()
H A Dhttp-raw-stream.c41 if(fsub->data.timeout_ev.timer_set) { in rawstream_respond_message()
42 ngx_del_timer(&fsub->data.timeout_ev); in rawstream_respond_message()
43 ngx_add_timer(&fsub->data.timeout_ev, sub->cf->subscriber_timeout * 1000); in rawstream_respond_message()
H A Dlongpoll.c56 nchan_subscriber_init_timeout_timer(&fsub->sub, &fsub->data.timeout_ev); in longpoll_subscriber_create()
186 ngx_add_timer(&fsub->data.timeout_ev, self->cf->subscriber_timeout * 1000); in longpoll_enqueue()
201 if(fsub->data.timeout_ev.timer_set) { in longpoll_dequeue()
202 ngx_del_timer(&fsub->data.timeout_ev); in longpoll_dequeue()
293 if(fsub->data.timeout_ev.timer_set) { in longpoll_respond_message()
294 ngx_del_timer(&fsub->data.timeout_ev); in longpoll_respond_message()
H A Dhttp-chunked.c57 if(fsub->data.timeout_ev.timer_set) { in chunked_respond_message()
58 ngx_del_timer(&fsub->data.timeout_ev); in chunked_respond_message()
59 ngx_add_timer(&fsub->data.timeout_ev, sub->cf->subscriber_timeout * 1000); in chunked_respond_message()
H A Dhttp-multipart-mixed.c91 if(fsub->data.timeout_ev.timer_set) { in multipart_respond_message()
92 ngx_del_timer(&fsub->data.timeout_ev); in multipart_respond_message()
93 ngx_add_timer(&fsub->data.timeout_ev, sub->cf->subscriber_timeout * 1000); in multipart_respond_message()
H A Dlongpoll-private.h13 ngx_event_t timeout_ev; member
H A Dinternal.h11 ngx_event_t timeout_ev; member
H A Deventsource.c123 if(fsub->data.timeout_ev.timer_set) { in es_respond_message()
124 ngx_del_timer(&fsub->data.timeout_ev); in es_respond_message()
125 ngx_add_timer(&fsub->data.timeout_ev, sub->cf->subscriber_timeout * 1000); in es_respond_message()
H A Dgetmsg_proxy.c19 ngx_event_t timeout_ev; member
H A Dwebsocket.c191 ngx_event_t timeout_ev; member
744 nchan_subscriber_init_timeout_timer(&fsub->sub, &fsub->timeout_ev); in websocket_subscriber_create()
1212 ngx_add_timer(&fsub->timeout_ev, self->cf->subscriber_timeout * 1000); in websocket_enqueue()
1227 if(fsub->timeout_ev.timer_set) { in websocket_delete_timers()
1228 ngx_del_timer(&fsub->timeout_ev); in websocket_delete_timers()
1931 if(fsub->timeout_ev.timer_set) { in websocket_respond_message()
1932 ngx_del_timer(&fsub->timeout_ev); in websocket_respond_message()
1933 ngx_add_timer(&fsub->timeout_ev, fsub->sub.cf->subscriber_timeout * 1000); in websocket_respond_message()
/dports/net/sems/sems-f89581a/core/plug-in/session_timer/
H A DSessionTimer.cpp69 AmTimeoutEvent* timeout_ev = dynamic_cast<AmTimeoutEvent*>(ev); in process() local
70 if (timeout_ev) { in process()
71 if (timeout_ev->data.get(0).asInt() >= ID_SESSION_TIMER_TIMERS_START && in process()
72 timeout_ev->data.get(0).asInt() <=ID_SESSION_TIMER_TIMERS_END) { in process()
73 DBG("received timeout Event with ID %d\n", timeout_ev->data.get(0).asInt()); in process()
74 onTimeoutEvent(timeout_ev); in process()
429 void SessionTimer::onTimeoutEvent(AmTimeoutEvent* timeout_ev) in onTimeoutEvent() argument
432 int timer_id = timeout_ev->data.get(0).asInt(); in onTimeoutEvent()
H A DSessionTimer.h155 void onTimeoutEvent(AmTimeoutEvent* timeout_ev);
/dports/mail/rspamd-devel/rspamd-93430bb/src/lua/
H A Dlua_redis.c136 ev_timer timeout_ev; member
196 ev_timer_stop (ud->event_loop, &cur->timeout_ev); in lua_redis_dtor()
267 if (ev_can_stop (&sp_ud->timeout_ev)) { in lua_redis_fin()
420 if (ev_can_stop (&sp_ud->timeout_ev)) { in lua_redis_push_data()
422 &sp_ud->timeout_ev); in lua_redis_push_data()
610 if (ev_can_stop ( &sp_ud->timeout_ev)) { in lua_redis_callback_sync()
611 ev_timer_stop (ud->event_loop, &sp_ud->timeout_ev); in lua_redis_callback_sync()
1174 sp_ud->timeout_ev.data = sp_ud; in lua_redis_make_request()
1177 ev_timer_start (ud->event_loop, &sp_ud->timeout_ev); in lua_redis_make_request()
1540 sp_ud->timeout_ev.data = sp_ud; in lua_redis_add_cmd()
[all …]
/dports/mail/rspamd/rspamd-3.1/src/lua/
H A Dlua_redis.c137 ev_timer timeout_ev; member
197 ev_timer_stop (ud->event_loop, &cur->timeout_ev); in lua_redis_dtor()
268 if (ev_can_stop (&sp_ud->timeout_ev)) { in lua_redis_fin()
421 if (ev_can_stop (&sp_ud->timeout_ev)) { in lua_redis_push_data()
423 &sp_ud->timeout_ev); in lua_redis_push_data()
611 if (ev_can_stop ( &sp_ud->timeout_ev)) { in lua_redis_callback_sync()
612 ev_timer_stop (ud->event_loop, &sp_ud->timeout_ev); in lua_redis_callback_sync()
1175 sp_ud->timeout_ev.data = sp_ud; in lua_redis_make_request()
1178 ev_timer_start (ud->event_loop, &sp_ud->timeout_ev); in lua_redis_make_request()
1541 sp_ud->timeout_ev.data = sp_ud; in lua_redis_add_cmd()
[all …]
/dports/security/dirmngr/dirmngr-1.1.0/src/
H A Dldap.c295 pth_event_t timeout_ev; in ldap_wrapper_thread() local
298 timeout_ev = pth_event (PTH_EVENT_TIME, pth_timeout (1, 0)); in ldap_wrapper_thread()
299 if (! timeout_ev) in ldap_wrapper_thread()
311 pth_event_concat (timeout_ev, ctx->log_ev, NULL); in ldap_wrapper_thread()
317 nfds = pth_wait (timeout_ev); in ldap_wrapper_thread()
320 pth_event_free (timeout_ev, PTH_FREE_THIS); in ldap_wrapper_thread()
325 if (pth_event_status (timeout_ev) == PTH_STATUS_OCCURRED) in ldap_wrapper_thread()
327 pth_event_free (timeout_ev, PTH_FREE_THIS); in ldap_wrapper_thread()
/dports/mail/rspamd-devel/rspamd-93430bb/src/
H A Dworker.c190 task->timeout_ev.data = task; in rspamd_worker_body_handler()
191 ev_timer_init (&task->timeout_ev, rspamd_task_timeout, in rspamd_worker_body_handler()
194 ev_set_priority (&task->timeout_ev, EV_MAXPRI); in rspamd_worker_body_handler()
195 ev_timer_start (task->event_loop, &task->timeout_ev); in rspamd_worker_body_handler()
H A Drspamd_proxy.c1847 task->timeout_ev.data = task; in rspamd_proxy_self_scan()
1848 ev_timer_init (&task->timeout_ev, rspamd_task_timeout, in rspamd_proxy_self_scan()
1851 ev_timer_start (task->event_loop, &task->timeout_ev); in rspamd_proxy_self_scan()
1856 task->timeout_ev.data = task; in rspamd_proxy_self_scan()
1857 ev_timer_init (&task->timeout_ev, rspamd_task_timeout, in rspamd_proxy_self_scan()
1860 ev_timer_start (task->event_loop, &task->timeout_ev); in rspamd_proxy_self_scan()
/dports/mail/rspamd/rspamd-3.1/src/
H A Dworker.c190 task->timeout_ev.data = task; in rspamd_worker_body_handler()
191 ev_timer_init (&task->timeout_ev, rspamd_task_timeout, in rspamd_worker_body_handler()
194 ev_set_priority (&task->timeout_ev, EV_MAXPRI); in rspamd_worker_body_handler()
195 ev_timer_start (task->event_loop, &task->timeout_ev); in rspamd_worker_body_handler()
/dports/net/kamailio/kamailio-5.4.5/src/modules/janssonrpcc/
H A Djanssonrpc_request.h46 struct event* timeout_ev; /* pkg */ member
/dports/net/openmpi/openmpi-4.1.1/orte/mca/ras/slurm/
H A Dras_slurm_module.c110 opal_event_t timeout_ev; member
845 opal_event_del(&jtrk->timeout_ev); in recv_data()
1089 opal_event_evtimer_set(orte_event_base, &jtrk->timeout_ev, timeout, jtrk); in dyn_allocate()
1092 opal_event_evtimer_add(&jtrk->timeout_ev, &tv); in dyn_allocate()
/dports/net/openmpi3/openmpi-3.1.6/orte/mca/ras/slurm/
H A Dras_slurm_module.c110 opal_event_t timeout_ev; member
845 opal_event_del(&jtrk->timeout_ev); in recv_data()
1089 opal_event_evtimer_set(orte_event_base, &jtrk->timeout_ev, timeout, jtrk); in dyn_allocate()
1092 opal_event_evtimer_add(&jtrk->timeout_ev, &tv); in dyn_allocate()
/dports/databases/webdis/webdis-0.1.18/tests/
H A Dwebsocket.c558 struct event *timeout_ev; in worker_main() local
630 timeout_ev = event_new(wt->base, -1, EV_TIMEOUT, ws_on_timeout, wt); in worker_main()
631 event_add(timeout_ev, &timeout_tv); in worker_main()
/dports/mail/rspamd-devel/rspamd-93430bb/src/libserver/
H A Dtask.h207 struct ev_timer timeout_ev; /**< Global task timeout */ member
/dports/mail/rspamd/rspamd-3.1/src/libserver/
H A Dtask.h207 struct ev_timer timeout_ev; /**< Global task timeout */ member

12