You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
101 lines
2.7 KiB
101 lines
2.7 KiB
5 years ago
|
#if defined(LIBEV_EMBED)
|
||
|
|
#include "ev.c"
|
||
|
|
#undef LIBEV_EMBED
|
||
|
|
#define LIBEV_EMBED 1
|
||
|
|
#define gevent_ev_loop_origflags(loop) ((loop)->origflags)
|
||
|
|
#define gevent_ev_loop_sig_pending(loop) ((loop))->sig_pending
|
||
|
|
#define gevent_ev_loop_backend_fd(loop) ((loop))->backend_fd
|
||
|
|
#define gevent_ev_loop_activecnt(loop) ((loop))->activecnt
|
||
|
|
#if EV_USE_SIGNALFD
|
||
|
|
#define gevent_ev_loop_sigfd(loop) ((loop))->sigfd
|
||
|
|
#else
|
||
|
|
#define gevent_ev_loop_sigfd(loop) -1
|
||
|
|
#endif /* !EV_USE_SIGNALFD */
|
||
|
|
#else /* !LIBEV_EMBED */
|
||
|
|
#include "ev.h"
|
||
|
|
|
||
|
|
#define gevent_ev_loop_origflags(loop) -1
|
||
|
|
#define gevent_ev_loop_sig_pending(loop) -1
|
||
|
|
#define gevent_ev_loop_backend_fd(loop) -1
|
||
|
|
#define gevent_ev_loop_activecnt(loop) -1
|
||
|
|
#define gevent_ev_loop_sigfd(loop) -1
|
||
|
|
|
||
|
|
#define LIBEV_EMBED 0
|
||
|
|
#define EV_USE_FLOOR -1
|
||
|
|
#define EV_USE_CLOCK_SYSCALL -1
|
||
|
|
#define EV_USE_REALTIME -1
|
||
|
|
#define EV_USE_MONOTONIC -1
|
||
|
|
#define EV_USE_NANOSLEEP -1
|
||
|
|
#define EV_USE_INOTIFY -1
|
||
|
|
#define EV_USE_SIGNALFD -1
|
||
|
|
#define EV_USE_EVENTFD -1
|
||
|
|
#define EV_USE_4HEAP -1
|
||
|
|
|
||
|
|
|
||
|
|
#ifndef _WIN32
|
||
|
|
#include <signal.h>
|
||
|
|
#endif /* !_WIN32 */
|
||
|
|
|
||
|
|
#endif /* LIBEV_EMBED */
|
||
|
|
|
||
|
|
#ifndef _WIN32
|
||
|
|
|
||
|
|
static struct sigaction libev_sigchld;
|
||
|
|
/*
|
||
|
|
* Track the state of whether we have installed
|
||
|
|
* the libev sigchld handler specifically.
|
||
|
|
* If it's non-zero, libev_sigchld will be valid and set to the action
|
||
|
|
* that libev needs to do.
|
||
|
|
* If it's 1, we need to install libev_sigchld to make libev
|
||
|
|
* child handlers work (on request).
|
||
|
|
*/
|
||
|
|
static int sigchld_state = 0;
|
||
|
|
|
||
|
|
static struct ev_loop* gevent_ev_default_loop(unsigned int flags)
|
||
|
|
{
|
||
|
|
struct ev_loop* result;
|
||
|
|
struct sigaction tmp;
|
||
|
|
|
||
|
|
if (sigchld_state)
|
||
|
|
return ev_default_loop(flags);
|
||
|
|
|
||
|
|
// Request the old SIGCHLD handler
|
||
|
|
sigaction(SIGCHLD, NULL, &tmp);
|
||
|
|
// Get the loop, which will install a SIGCHLD handler
|
||
|
|
result = ev_default_loop(flags);
|
||
|
|
// XXX what if SIGCHLD received there?
|
||
|
|
// Now restore the previous SIGCHLD handler
|
||
|
|
sigaction(SIGCHLD, &tmp, &libev_sigchld);
|
||
|
|
sigchld_state = 1;
|
||
|
|
return result;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
static void gevent_install_sigchld_handler(void) {
|
||
|
|
if (sigchld_state == 1) {
|
||
|
|
sigaction(SIGCHLD, &libev_sigchld, NULL);
|
||
|
|
sigchld_state = 2;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
static void gevent_reset_sigchld_handler(void) {
|
||
|
|
// We could have any state at this point, depending on
|
||
|
|
// whether the default loop has been used. If it has,
|
||
|
|
// then always be in state 1 ("need to install)
|
||
|
|
if (sigchld_state) {
|
||
|
|
sigchld_state = 1;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
#else /* !_WIN32 */
|
||
|
|
|
||
|
|
#define gevent_ev_default_loop ev_default_loop
|
||
|
|
static void gevent_install_sigchld_handler(void) { }
|
||
|
|
static void gevent_reset_sigchld_handler(void) { }
|
||
|
|
|
||
|
|
// Fake child functions that we can link to.
|
||
|
|
static void ev_child_start(struct ev_loop* loop, ev_child* w) {};
|
||
|
|
static void ev_child_stop(struct ev_loop* loop, ev_child* w) {};
|
||
|
|
|
||
|
|
#endif /* _WIN32 */
|