1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
*
*/
#ifndef CEPH_MDBALANCER_H
#define CEPH_MDBALANCER_H
#include <list>
#include <map>
using std::list;
using std::map;
#include "include/types.h"
#include "common/Clock.h"
#include "CInode.h"
class MDS;
class Message;
class MHeartbeat;
class CInode;
class Context;
class CDir;
class MDBalancer {
protected:
MDS *mds;
int beat_epoch;
int last_epoch_under;
int last_epoch_over;
utime_t last_heartbeat;
utime_t last_fragment;
utime_t last_sample;
utime_t rebalance_time; //ensure a consistent view of load for rebalance
// todo
set<dirfrag_t> split_queue, merge_queue;
// per-epoch scatter/gathered info
map<int, mds_load_t> mds_load;
map<int, float> mds_meta_load;
map<int, map<int, float> > mds_import_map;
// per-epoch state
double my_load, target_load;
map<int,double> my_targets;
map<int,double> imported;
map<int,double> exported;
map<int32_t, int> old_prev_targets; // # iterations they _haven't_ been targets
bool check_targets();
double try_match(int ex, double& maxex,
int im, double& maxim);
double get_maxim(int im) {
return target_load - mds_meta_load[im] - imported[im];
}
double get_maxex(int ex) {
return mds_meta_load[ex] - target_load - exported[ex];
}
public:
MDBalancer(MDS *m) :
mds(m),
beat_epoch(0),
last_epoch_under(0), last_epoch_over(0) { }
mds_load_t get_load(utime_t);
int proc_message(Message *m);
void send_heartbeat();
void handle_heartbeat(MHeartbeat *m);
void tick();
void do_fragmenting();
void export_empties();
//set up the rebalancing targets for export and do one if the
//MDSMap is up to date
void prep_rebalance(int beat);
/*check if the monitor has recorded the current export targets;
if it has then do the actual export. Otherwise send off our
export targets message again*/
void try_rebalance();
void find_exports(CDir *dir,
double amount,
list<CDir*>& exports,
double& have,
set<CDir*>& already_exporting);
void subtract_export(class CDir *ex, utime_t now);
void add_import(class CDir *im, utime_t now);
void hit_inode(utime_t now, class CInode *in, int type, int who=-1);
void hit_dir(utime_t now, class CDir *dir, int type, int who=-1, double amount=1.0);
void hit_recursive(utime_t now, class CDir *dir, int type, double amount, double rd_adj);
void show_imports(bool external=false);
void queue_split(CDir *dir);
void queue_merge(CDir *dir);
};
#endif
|
