Function kqueue_alloc

lib_fiber/c/src/hook/kqueue.c:218–259

Create one KQUEUE for the specified kqfd. Allocate and initialize a KQUEUE object for a kqueue fd.

// Create one KQUEUE for the specified kqfd.
// Allocate and initialize a KQUEUE object for a kqueue fd.
static KQUEUE *kqueue_alloc(int kqfd)
{ 
	KQUEUE *kq;
	int maxfd = open_limit(0), i;

	if (maxfd <= 0) {
		msg_fatal("%s(%d), %s: open_limit error %s",
			__FILE__, __LINE__, __FUNCTION__, last_serror());
	}

	/* Using thread local to store the kqueue handles for each thread. */
	if (__kqfds == NULL) {
		if (pthread_once(&__once_control, thread_init) != 0) {
			msg_error("%s(%d), %s: pthread_once error %s",
				__FILE__, __LINE__, __FUNCTION__, last_serror());
			return NULL;
		}

		__kqfds = array_create(5, ARRAY_F_UNORDER);
		if (thread_self() == main_thread_self()) {
			__main_kqfds = __kqfds;
			atexit(main_thread_free);
		} else if (pthread_setspecific(__once_key, __kqfds) != 0) {
			msg_error("pthread_setspecific error!");
			return NULL;
		}
	}

	kq = (KQUEUE*) mem_malloc(sizeof(KQUEUE));
	array_append(__kqfds, kq);

	kq->kqfd = kqfd;
	kq->nfds = maxfd;
	kq->fds  = (KQUEUE_CTX **) mem_malloc(maxfd * sizeof(KQUEUE_CTX *));

	for (i = 0; i < maxfd; i++) {
		kq->fds[i] = NULL;
	}

	ring_init(&kq->kes);
	return kq;
}

// Release a KQUEUE object and its fd table.
static void kqueue_free(KQUEUE *kq)