/dports/www/nginx-full/nchan-1.2.12/src/subscribers/ |
H A D | memstore_ipc.c | 26 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 D | internal.c | 57 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 D | http-raw-stream.c | 41 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 D | longpoll.c | 56 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 D | http-chunked.c | 57 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 D | http-multipart-mixed.c | 91 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 D | longpoll-private.h | 13 ngx_event_t timeout_ev; member
|
H A D | internal.h | 11 ngx_event_t timeout_ev; member
|
H A D | eventsource.c | 123 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 D | getmsg_proxy.c | 19 ngx_event_t timeout_ev; member
|
H A D | websocket.c | 191 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 D | SessionTimer.cpp | 69 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 D | SessionTimer.h | 155 void onTimeoutEvent(AmTimeoutEvent* timeout_ev);
|
/dports/mail/rspamd-devel/rspamd-93430bb/src/lua/ |
H A D | lua_redis.c | 136 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 D | lua_redis.c | 137 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 D | ldap.c | 295 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 D | worker.c | 190 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 D | rspamd_proxy.c | 1847 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 D | worker.c | 190 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 D | janssonrpc_request.h | 46 struct event* timeout_ev; /* pkg */ member
|
/dports/net/openmpi/openmpi-4.1.1/orte/mca/ras/slurm/ |
H A D | ras_slurm_module.c | 110 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 D | ras_slurm_module.c | 110 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 D | websocket.c | 558 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 D | task.h | 207 struct ev_timer timeout_ev; /**< Global task timeout */ member
|
/dports/mail/rspamd/rspamd-3.1/src/libserver/ |
H A D | task.h | 207 struct ev_timer timeout_ev; /**< Global task timeout */ member
|