Function kqueue_try_register

lib_fiber/c/src/hook/kqueue.c:59–101

Maybe called by the fcntl API being hooked.

// Maybe called by the fcntl API being hooked.
int kqueue_try_register(int kqfd)
{
	int sys_kqfd;
	EVENT *ev;
	KQUEUE *kq;

	if (kqfd < 0) {
		return -1;
	}

	ev = fiber_io_event();
	if (ev == NULL) {
		return -1;
	}

	sys_kqfd = (int) event_handle(ev);
	assert(sys_kqfd >= 0);

	if (kqfd != sys_kqfd) {
		ITER iter;
		int found = 0;
		foreach(iter, __kqfds) {
			KQUEUE *tmp = (KQUEUE *) iter.data;
			if (tmp->kqfd == kqfd) {
				found = 1;
				break;
			}
		}
		if (!found) {
			return -1;
		}
	}

	kqfd = kqfd >= 0 ? dup(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);
	return kq->kqfd;
}

/****************************************************************************/