blob: bf9cb05cea5e9448e88411bcfc64de412f3f1247 (
plain)
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
|
#ifndef MONITOR_HH
#define MONITOR_HH
#include <memory>
#include <string>
class Looper;
class Monitor {
public:
enum State {
SEARCHING,
CONNECTED,
};
struct Machine {
std::string name;
unsigned max_jobs;
Machine()
: max_jobs(0) {
}
};
class Observer {
public:
virtual ~Observer() {}
virtual void state(Monitor* monitor, State state) = 0;
virtual void added_machine(Monitor* monitor, uint32_t id) = 0;
virtual void updated_machine(Monitor* monitor, uint32_t id) = 0;
virtual void removed_machine(Monitor* monitor, uint32_t id) = 0;
virtual void added_job(Monitor* monitor, uint32_t source_id,
uint32_t target_id) = 0;
virtual void removed_job(Monitor* monitor, uint32_t source_id,
uint32_t target_id) = 0;
protected:
Observer() {}
};
virtual ~Monitor() {}
static std::unique_ptr<Monitor> create(std::shared_ptr<Looper> const& looper);
virtual void connect(std::string const& netname = std::string(),
std::string const& scheduler = std::string(),
uint16_t port = 0) = 0;
virtual void disconnect() = 0;
virtual size_t machines() const = 0;
virtual uint32_t id(size_t index) const = 0;
virtual Machine machine_at(size_t index) const = 0;
virtual Machine machine(uint32_t id) const = 0;
virtual void add_observer(Observer* observer) = 0;
virtual void remove_observer(Observer* observer) = 0;
#if FAKE_MONITOR
virtual void toggle_fakes() = 0;
#endif
protected:
Monitor() {}
Monitor(Monitor const&) = delete;
Monitor& operator=(Monitor const&) = delete;
};
#endif // MONITOR_HH
|
