Method run

phxsqlproxy/heartbeat_thread.cpp:32–44

}

void HeartBeatThread::run() {
    static int count = 0;
    while (true) {
        std::shared_ptr<PhxBinlogClient> client = PhxBinlogClientPlatformInfo::GetDefault()->GetClientFactory()
                ->CreateClient();
        int ret = client->HeartBeat();
        if ((count++) % 60 == 0) {
            phxsql::LogWarning("%s:%d heartbeat ret %d", __func__, __LINE__, ret);
            count = 1;
        }
        poll(0, 0, 1000);
    }
}

}