Class GroupStatusCache

phxsqlproxy/group_status_cache.h:30–65

} MasterStatus_t;

class GroupStatusCache : public PhxThread {
 public:
    GroupStatusCache(PHXSqlProxyConfig * config, WorkerConfig_t * worker_config);

    virtual ~GroupStatusCache();

    void run();

    int GetMaster(std::string & master_ip);

    bool IsMember(const std::string & ip);

    // use by MasterEnableReadPort=0

    int GetSlave(const std::string & master_ip, std::string & slave_ip);

    void MarkFailure(const std::string & ip);

 private:
    int UpdateMasterStatus();

    int UpdateMembership();

    bool IsMasterValid(const std::string & master_ip, uint32_t expired_time);

 private:
    PHXSqlProxyConfig * config_;
    WorkerConfig_t * worker_config_;

    MasterStatus_t master_status_;
    pthread_rwlock_t master_mutex_;

    std::vector<std::string> membership_;
    std::unordered_map<std::string, uint64_t> last_failure_; // use by MasterEnableReadPort=0
    pthread_rwlock_t membership_mutex_;
};

}