Function kqueue

lib_fiber/c/src/hook/kqueue.c:369–409

Hook the system API to create one kqueue fd.

// Hook the system API to create one kqueue fd.
int kqueue(void)
{
	EVENT *ev;
	KQUEUE *kq;
	int    sys_kqfd, kqfd;

	if (sys_kqueue == NULL) {
		hook_once();
	}

	if (!var_hook_sys_api) {
		return sys_kqueue ? (*sys_kqueue)() : -1;
	}

	ev = fiber_io_event();
	assert(ev);

	// Get the current thread's kqueue fd.
	sys_kqfd = (int) event_handle(ev);
	if (sys_kqfd < 0) {
		msg_info("%s(%d), %s: no event_handle %d",
			__FILE__, __LINE__, __FUNCTION__, sys_kqfd);
	}

	// Duplicate sys_kqfd and return a new fd to the caller.
	kqfd = sys_kqfd >= 0 ? dup(sys_kqfd) : socket(AF_INET, SOCK_STREAM, 0);
	if (kqfd < 0) {
		msg_error("%s(%d): create fd error: %s",
			__FILE__, __LINE__, last_serror());
		return -1;
	}

	kq = kqueue_alloc(kqfd);
	if (kq == NULL) {
		msg_error("%s(%d): can't alloc KQUEUE for kqfd=%d",
			__FUNCTION__, __LINE__, kqfd);
		return -1;
	}

	return kq->kqfd;
}

// Event callback for readable fd in kqueue hook mode.
static void read_callback(EVENT *ev, FILE_EVENT *fe)