Method run

phxsqlproxy/connection_dispatcher.cpp:44–71

}

int ConnectionDispatcher::run() {
    co_enable_hook_sys();
    while (true) {
        char buffer[512] = { 0 };
        int n = RoutineReadWithTimeout(socket_pair_fd_[1], buffer, sizeof(buffer), 1000);
        if (n > 0) {
            for (int i = 0; i < n; i += sizeof(int)) {
                int fd = 0;
                memcpy(&fd, buffer + i, sizeof(int));
                if (fd) {
                    SetNonBlock(fd);
                    IORoutine * io_routine = NULL;
                    int get_routine_ret = io_routine_mgr_->GetIORoutine(&io_routine);
                    if (get_routine_ret == 0 && io_routine != NULL) {
                        MonitorPluginEntry::GetDefault()->GetMonitorPlugin()->ResumeRoutine();
                        io_routine->SetClientFD(fd);
                        io_routine->resume();
                    } else {
                        MonitorPluginEntry::GetDefault()->GetMonitorPlugin()->OutOfConn();
                        LogError("%s:%d receive connection but no useful io routine", __func__, __LINE__);
                        close(fd);
                    }
                }
            }
        }
    }
    return 0;
}

int ConnectionDispatcher::AssignFD(int fd) {
    return RoutineWriteWithTimeout(socket_pair_fd_[0], (const char *) (&fd), sizeof(int), 1000);