Class KeepMasterThread

phxqueue/scheduler/keepmasterthread.h:23–41

class KeepMasterThread {
  public:
    KeepMasterThread(Scheduler *const scheduler);
    virtual ~KeepMasterThread();

    void Run();
    void Stop();

    comm::RetCode InitMasterRate();
    comm::RetCode AdjustMasterRate();
    comm::RetCode KeepMaster();

  private:
    void DoRun();
    comm::RetCode GetLockID(int &lock_id);

    class KeepMasterThreadImpl;
    std::unique_ptr<KeepMasterThreadImpl> impl_;
};


}  // namespace scheduler