Method run

phxsqlproxy/accept_thread.cpp:55–89

}

void AcceptThread::run() {
    co_init_curr_thread_env();
    co_enable_hook_sys();

    static std::default_random_engine random_engine(time (NULL));
    static std::uniform_int_distribution<unsigned> random_range(0, worker_threads_.size() - 1);

    for (;;) {
        struct sockaddr_in addr;  //maybe sockaddr_un;
        memset(&addr, 0, sizeof(addr));
        socklen_t len = sizeof(addr);

        int fd = accept(listen_fd_, (struct sockaddr *) &addr, &len);
        if (fd < 0) {
            if (errno != EAGAIN) {
                MonitorPluginEntry::GetDefault()->GetMonitorPlugin()->AcceptFail();
                LogError("accept failed, ret fd %d, errno (%d:%s)", fd, errno, strerror(errno));
            }
            continue;
        }

        MonitorPluginEntry::GetDefault()->GetMonitorPlugin()->AcceptSuccess();
        SetNonBlock(fd);

        int rand_idx = random_range(random_engine);
        if (worker_threads_[rand_idx]->AssignFD(fd) > 0) {
            MonitorPluginEntry::GetDefault()->GetMonitorPlugin()->ResumeRoutine();
        } else {
            MonitorPluginEntry::GetDefault()->GetMonitorPlugin()->OutOfConn();
            LogError("%s:%d receive connection but no useful io routine", __func__, __LINE__);
            close(fd);
        }
    }
    co_eventloop(co_get_epoll_ct(), 0, 0);
}

}