diff options
| author | Sage Weil <sage@newdream.net> | 2009-08-28 16:48:09 -0700 |
|---|---|---|
| committer | Sage Weil <sage@newdream.net> | 2009-08-28 16:48:09 -0700 |
| commit | afd038b431456e1571689f8ea1b31df6691be974 (patch) | |
| tree | 5bb22c44aceb0db5b141e7ecd0580d6fb92c8546 /src/msg/Message.cc | |
| parent | 7b5670abb9ae252cb335050d8fe4bcc8175135fb (diff) | |
| download | ceph-afd038b431456e1571689f8ea1b31df6691be974.tar.gz | |
mon: add subscribe function
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 e103a1c390c..e1692675b0a 100644 --- a/src/msg/Message.cc +++ b/src/msg/Message.cc @@ -65,6 +65,8 @@ using namespace std; #include "messages/MClientMount.h" #include "messages/MClientMountAck.h" +#include "messages/MMonSubscribe.h" +#include "messages/MMonSubscribeAck.h" #include "messages/MClientSession.h" #include "messages/MClientReconnect.h" #include "messages/MClientRequest.h" @@ -310,6 +312,12 @@ Message *decode_message(ceph_msg_header& header, ceph_msg_footer& footer, case CEPH_MSG_CLIENT_MOUNT_ACK: m = new MClientMountAck; break; + case CEPH_MSG_MON_SUBSCRIBE: + m = new MMonSubscribe; + break; + case CEPH_MSG_MON_SUBSCRIBE_ACK: + m = new MMonSubscribeAck; + break; case CEPH_MSG_CLIENT_SESSION: m = new MClientSession; break; |