messenger(msgr),
mon_client(monc),
beat_epoch(0),
- last_epoch_under(0), last_epoch_over(0), my_load(0.0), target_load(0.0)
+ last_epoch_under(0), my_load(0.0), target_load(0.0)
{ }
mds_load_t get_load(utime_t);
*/
void maybe_fragment(CDir *dir, bool hot);
+ void handle_mds_failure(mds_rank_t who);
+
private:
typedef struct {
std::map<mds_rank_t, double> targets;
void export_empties();
int localize_balancer();
- bool check_targets(const balance_state_t& state);
- void hit_targets(const balance_state_t& state);
void send_heartbeat();
void handle_heartbeat(MHeartbeat *m);
void find_exports(CDir *dir,
int beat_epoch;
int last_epoch_under;
- int last_epoch_over;
string bal_code;
string bal_version;