Function tcp_pool_init

net/net_tcp.c:1332–1412

}

static int tcp_pool_init(void)
{
	int i;
	int started = 0;
	int threads_no;
	long cpu_no;

	if (tcp_threads > 0)
		threads_no = tcp_threads;
	else {
		cpu_no = sysconf(_SC_NPROCESSORS_ONLN);
		if (cpu_no > 0)
			threads_no = (int)cpu_no;
		else if (tcp_workers_no > 0)
			threads_no = tcp_workers_no;
		else
			threads_no = 1;
	}

	if (pipe(tcp_pool.notify_pipe) < 0) {
		LM_ERR("failed to create TCP IO notification pipe: %s\n", strerror(errno));
		goto error;
	}

	if (tcp_set_nonblock(tcp_pool.notify_pipe[0]) < 0 ||
	    tcp_set_nonblock(tcp_pool.notify_pipe[1]) < 0)
		goto error;

	if (reactor_add_reader(tcp_pool.notify_pipe[0],
		F_TCP_NOTIFY, RCT_PRIO_PROC, NULL) < 0) {
		LM_ERR("failed to add TCP IO notify pipe to reactor\n");
		goto error;
	}

	tcp_pool.threads = pkg_malloc(sizeof(*tcp_pool.threads) * threads_no);
	if (!tcp_pool.threads) {
		LM_ERR("oom while allocating TCP IO threads array\n");
		goto error;
	}

	tcp_pool.stop = 0;
	tcp_pool.threads_no = threads_no;

	for (i = 0; i < threads_no; i++) {
		if (pthread_create(&tcp_pool.threads[i], NULL,
				tcp_thread_routine, NULL) != 0) {
			LM_ERR("failed to start TCP IO thread %d/%d\n", i + 1, threads_no);
			goto error;
		}
		started++;
	}

	LM_NOTICE("TCP single IO mode started with %d threads\n", threads_no);
	return 0;

error:
	cond_lock(&tcp_write_queue->cond);
	tcp_pool.stop = 1;