Function tcp_main_server

net/net_tcp.c:2002–2063

static void tcp_main_server(void)
{
	static unsigned int last_sec = 0;
	struct socket_info_full* sif;
	struct sr_module *m;
	int n;

	/* instruct tls_mgm to initialize all TLS domains */
	for (m=modules; m; m = m->next) {
		if (strcmp(m->exports->name, "tls_mgm") == 0)
			if (init_child(PROC_TCP_MAIN) < 0) {
				LM_ERR("error in init_child for PROC_TCP_MAIN\n");
				goto error;
			}
	}

	/* we run in a separate, dedicated process, with its own reactor
	 * (reactors are per process) */
	if (init_worker_reactor("TCP_main", RCT_PRIO_MAX)<0)
		goto error;

	/* now start watching all the fds */

	/* add all the sockets we listens on for connections */
	for (n = PROTO_FIRST; n < PROTO_LAST; n++)
		if (is_tcp_based_proto(n))
			for (sif = protos[n].listeners; sif; sif = sif->next) {
				struct socket_info* si = &sif->socket_info;
				if (protos[n].tran.bind_listener &&
						protos[n].tran.bind_listener(si) < 0) {
					LM_ERR("failed to bind listener [%.*s], proto %s\n",
						si->name.len, si->name.s, protos[n].name);
					goto error;
				}
				if (si->socket != -1 &&
						reactor_add_reader(si->socket, F_TCP_LISTENER,
							RCT_PRIO_NET, si) < 0) {
					LM_ERR("failed to add listen socket to reactor\n");
					goto error;
				}
			}
	/* init: start watching for the IPC jobs */
	if (reactor_add_reader(IPC_FD_READ_SELF, F_IPC, RCT_PRIO_ASYNC, NULL)<0){
		LM_CRIT("failed to add IPC pipe to reactor\n");
		goto error;
	}

	if (tcp_pool_init() < 0)
		goto error;

	is_tcp_main = 1;

	/* main loop (requires "handle_io()" implementation) */
	reactor_main_loop( TCP_MAIN_SELECT_TIMEOUT, error,
			tcpconn_lifetime(last_sec) );

error:
	tcp_pool_destroy();