diff options
| author | Yehuda Sadeh <yehuda@hq.newdream.net> | 2008-12-09 13:39:10 -0800 |
|---|---|---|
| committer | Yehuda Sadeh <yehuda@hq.newdream.net> | 2008-12-09 14:12:31 -0800 |
| commit | d216720b584cf8e3df163811abbf9fc3225b68cb (patch) | |
| tree | 4f6508685f3df8d10aa2ef8436cee3c255bf96d8 /src/msg/Message.cc | |
| parent | 8a5f231720575016913e21736011e4bd29e7993f (diff) | |
| download | ceph-d216720b584cf8e3df163811abbf9fc3225b68cb.tar.gz | |
cobserver: utility, observe changes in different maps
Diffstat (limited to 'src/msg/Message.cc')
| -rw-r--r-- | src/msg/Message.cc | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/msg/Message.cc b/src/msg/Message.cc index 3e322a1b40b..62cac0de1c1 100644 --- a/src/msg/Message.cc +++ b/src/msg/Message.cc @@ -19,6 +19,8 @@ using namespace std; #include "messages/MMonCommand.h" #include "messages/MMonCommandAck.h" #include "messages/MMonPaxos.h" +#include "messages/MMonObserve.h" +#include "messages/MMonObserveNotify.h" #include "messages/MMonElection.h" #include "messages/MLog.h" @@ -165,6 +167,12 @@ Message *decode_message(ceph_msg_header& header, ceph_msg_footer& footer, m = new MMonElection; break; + case MSG_MON_OBSERVE: + m = new MMonObserve; + break; + case MSG_MON_OBSERVE_NOTIFY: + m = new MMonObserveNotify; + break; case MSG_LOG: m = new MLog; break; |