Method loop

libapp2sys/src/main/cpp/udp.h:589–646

    }

    int loop() {
        while (m_fd > 0 || m_eventTimerList.size()) {
            const int64_t start = getMillisecond();

            const int checkCount = checkSendQueue();
            const int64_t timeout = m_eventTimerList.size() ? (*m_eventTimerList.begin())->timeout - start : 0;

            pdbg("startLoop ,timeout:%d timer:%d sender:%d checkcnt:[sq:%d %d run:%d] ",
                 TOINT(timeout), (int)m_eventTimerList.size(), (int)m_mapSender.size(), (int)sendQueue.size(), checkCount, TOINT(getMillisecond() - start));

            if (m_eventTimerList.size() && timeout <= 0) { //timeout
                const std::list<TimeoutEvent *>::iterator it = m_eventTimerList.begin();
                int ret = processTimeout(*it);
                pdbg("processTimeout: timeout:%d ret:%d run:%d %s", TOINT(timeout), ret, TOINT(getMillisecond() - start), (*it)->toString().c_str());
                m_eventTimerList.erase(it);
                if (ret < 0) {
                    return -1;
                }
                continue;
            }

            fd_set fdset;
            FD_ZERO(&fdset);
            FD_SET(m_fd, &fdset);
            FD_SET(m_pipefd[0], &fdset);

            struct timeval diff, *pdiff = NULL;
            if (m_eventTimerList.size() && timeout > 0) {
                diff.tv_sec = timeout / 1000;
                diff.tv_usec = (timeout % 1000) * 1000;
                pdiff = &diff;
            }
            const int selectRet = select(std::max(m_fd, m_pipefd[0]) + 1, &fdset, NULL, NULL, pdiff);
            pdbg("SelectRet:%d err:%d time:%d realTime:%d diff[%d %d]", selectRet, errno, TOINT(timeout), TOINT(getMillisecond() - start),
                 TOINT(diff.tv_sec), TOINT(diff.tv_usec));

            if (selectRet == -1 && errno != EINTR) {
                pdbg("eventloop: select errno:%d", errno);
                continue;
            }

            if (FD_ISSET(m_fd, &fdset)) {
                int ret = processReceive();
                pdbg("eventloop: processReceive ret:%d  run:%d", ret, TOINT(getMillisecond() - start));
                if (ret < 0) {
                    return -1;
                }
            }

            if (FD_ISSET(m_pipefd[0], &fdset)) {
                int i = 0;
                int ret = read(m_pipefd[0], &i, sizeof(int));
                pdbg("read pipe ret:%d run:%d ", ret, TOINT(getMillisecond() - start));
            }
        }
        pdbg("end loop , fd:%d timer:%d", m_fd, (int)m_eventTimerList.size());
        return 0;
    }