Lines Matching refs:base
122 evsig_set_base(struct event_base *base) in evsig_set_base() argument
125 evsig_base = base; in evsig_set_base()
126 evsig_base_n_signals_added = base->sig.ev_n_signals_added; in evsig_set_base()
127 evsig_base_fd = base->sig.ev_signal_pair[0]; in evsig_set_base()
139 struct event_base *base; in evsig_cb() local
141 base = arg; in evsig_cb()
163 EVBASE_ACQUIRE_LOCK(base, th_base_lock); in evsig_cb()
166 evmap_signal_active(base, i, ncaught[i]); in evsig_cb()
168 EVBASE_RELEASE_LOCK(base, th_base_lock); in evsig_cb()
172 evsig_init(struct event_base *base) in evsig_init() argument
180 AF_UNIX, SOCK_STREAM, 0, base->sig.ev_signal_pair) == -1) { in evsig_init()
191 evutil_make_socket_closeonexec(base->sig.ev_signal_pair[0]); in evsig_init()
192 evutil_make_socket_closeonexec(base->sig.ev_signal_pair[1]); in evsig_init()
193 base->sig.sh_old = NULL; in evsig_init()
194 base->sig.sh_old_max = 0; in evsig_init()
196 evutil_make_socket_nonblocking(base->sig.ev_signal_pair[0]); in evsig_init()
197 evutil_make_socket_nonblocking(base->sig.ev_signal_pair[1]); in evsig_init()
199 event_assign(&base->sig.ev_signal, base, base->sig.ev_signal_pair[1], in evsig_init()
200 EV_READ | EV_PERSIST, evsig_cb, base); in evsig_init()
202 base->sig.ev_signal.ev_flags |= EVLIST_INTERNAL; in evsig_init()
203 event_priority_set(&base->sig.ev_signal, 0); in evsig_init()
205 base->evsigsel = &evsigops; in evsig_init()
213 _evsig_set_handler(struct event_base *base, in _evsig_set_handler() argument
221 struct evsig_info *sig = &base->sig; in _evsig_set_handler()
279 evsig_add(struct event_base *base, evutil_socket_t evsignal, short old, short events, void *p) in evsig_add() argument
281 struct evsig_info *sig = &base->sig; in evsig_add()
288 if (evsig_base != base && evsig_base_n_signals_added) { in evsig_add()
295 base, evsig_base, base->evsel->name); in evsig_add()
297 evsig_base = base; in evsig_add()
299 evsig_base_fd = base->sig.ev_signal_pair[0]; in evsig_add()
303 if (_evsig_set_handler(base, (int)evsignal, evsig_handler) == -1) { in evsig_add()
325 _evsig_restore_handler(struct event_base *base, int evsignal) in _evsig_restore_handler() argument
328 struct evsig_info *sig = &base->sig; in _evsig_restore_handler()
356 evsig_del(struct event_base *base, evutil_socket_t evsignal, short old, short events, void *p) in evsig_del() argument
365 --base->sig.ev_n_signals_added; in evsig_del()
368 return (_evsig_restore_handler(base, (int)evsignal)); in evsig_del()
401 evsig_dealloc(struct event_base *base) in evsig_dealloc() argument
404 if (base->sig.ev_signal_added) { in evsig_dealloc()
405 event_del(&base->sig.ev_signal); in evsig_dealloc()
406 base->sig.ev_signal_added = 0; in evsig_dealloc()
410 event_debug_unassign(&base->sig.ev_signal); in evsig_dealloc()
413 if (i < base->sig.sh_old_max && base->sig.sh_old[i] != NULL) in evsig_dealloc()
414 _evsig_restore_handler(base, i); in evsig_dealloc()
417 if (base == evsig_base) { in evsig_dealloc()
424 if (base->sig.ev_signal_pair[0] != -1) { in evsig_dealloc()
425 evutil_closesocket(base->sig.ev_signal_pair[0]); in evsig_dealloc()
426 base->sig.ev_signal_pair[0] = -1; in evsig_dealloc()
428 if (base->sig.ev_signal_pair[1] != -1) { in evsig_dealloc()
429 evutil_closesocket(base->sig.ev_signal_pair[1]); in evsig_dealloc()
430 base->sig.ev_signal_pair[1] = -1; in evsig_dealloc()
432 base->sig.sh_old_max = 0; in evsig_dealloc()
435 if (base->sig.sh_old) { in evsig_dealloc()
436 mm_free(base->sig.sh_old); in evsig_dealloc()
437 base->sig.sh_old = NULL; in evsig_dealloc()