Class KeepMasterThread

phxqueue/store/keepmasterthread.h:26–43

class KeepMasterThread {
  public:
    KeepMasterThread(Store *const store);
    virtual ~KeepMasterThread();

    void Run();
    void Stop();

  private:
    void DoRun();
    void InitMasterRate();
    void AdjustMasterRate();
    void KeepMaster();
    void UpdatePaxosArgs();

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


}  // namespace store