Function accept_thread

net/net.c:5575–5873

}

static void *accept_thread(void *arg)
{
    comdb2_name_thread(__func__);
    netinfo_type *netinfo_ptr;
    struct pollfd pol;
    int rc;
    int listenfd = 0;
    int polltm;
    struct linger linger_data;
    struct sockaddr_in cliaddr;
    connect_and_accept_t *ca;
    pthread_t tid;
    char paddr[64];
    socklen_t clilen;
    socklen_t len;
    int new_fd;
    int flag = 1;
    SBUF2 *sb;
    portmux_fd_t *portmux_fds = NULL;
    unsigned int last_stat_dump_time = comdb2_time_epochms();

    thrman_register(THRTYPE_GENERIC);
    thread_started("net accept");
    ENABLE_PER_THREAD_MALLOC(__func__);

    netinfo_ptr = (netinfo_type *)arg;

    netinfo_ptr->accept_thread_arch_tid = getarchtid();

    logmsg(LOGMSG_INFO, "%s: starting, tid=%" PRIxPTR ".\n", __func__,
           (intptr_t) netinfo_ptr->accept_thread_arch_tid);

    if (netinfo_ptr->start_thread_callback)
        netinfo_ptr->start_thread_callback(netinfo_ptr->callback_data);

    logmsg(LOGMSG_INFO, "net %s my port is %d fd is %d\n", netinfo_ptr->service,
            netinfo_ptr->myport, netinfo_ptr->myfd);

    if (gbl_pmux_route_enabled) {
        portmux_fds =
            portmux_listen_setup(netinfo_ptr->app, netinfo_ptr->service,
                                 netinfo_ptr->instance, netinfo_ptr->myfd);
        if (!portmux_fds) {
            logmsg(LOGMSG_FATAL, "Could not get portmux_fds\n");
            exit(1);
        }
    } else {
        /* We used to listen here. We now listen way earlier and get a file
         * descriptor passed in. This is to prevent 2 instances from coming up
         * against the same data.  */
        if (netinfo_ptr->myfd != -1)
            listenfd = netinfo_ptr->myfd;
        else
            listenfd = netinfo_ptr->myfd = net_listen(netinfo_ptr->myport);
        if (listenfd < 0) {
            logmsg(LOGMSG_FATAL, "Could not get listenfd\n");
            exit(1);
        }