Method Run

phxqueue/consumer/freqman.cpp:145–164

}

void FreqMan::Run() {
    comm::RetCode ret;
    pid_t pid = fork();
    if (pid == 0) {
        prctl(PR_SET_PDEATHSIG, SIGHUP);

        while (true) {
            try {
                if (comm::RetCode::RET_OK != (ret =  UpdateLimitInfo())) {
                    QLErr("UpdateLimitInfo ret %d", ret);
                }
                ClearAllConsumeStat();
            } catch (const std::exception& e) {
                QLErr("exception %s", e.what());
            }
            sleep(5);
        }
        exit(0);
    }
}

void FreqMan::ClearAllConsumeStat() {
    comm::RetCode ret;