From 15ffbc8df10c714aa0589a4e3991a5e7920c420e Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Thu, 11 Nov 2010 17:17:22 -0800 Subject: [PATCH] makefile: add missing MWatchNotify.h Signed-off-by: Sage Weil --- src/Makefile.am | 1 + src/messages/MWatchNotify.h | 60 +++++++++++++++++++++++++++++++++++++ 2 files changed, 61 insertions(+) create mode 100644 src/messages/MWatchNotify.h diff --git a/src/Makefile.am b/src/Makefile.am index 87b3652c44075..4bfded0efc5d9 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -785,6 +785,7 @@ noinst_HEADERS = \ messages/MForward.h\ messages/MStatfs.h\ messages/MStatfsReply.h\ + messages/MWatchNotify.h\ messages/PaxosServiceMessage.h\ mon/AuthMonitor.h\ mon/ClassMonitor.h\ diff --git a/src/messages/MWatchNotify.h b/src/messages/MWatchNotify.h new file mode 100644 index 0000000000000..59f7bf477d490 --- /dev/null +++ b/src/messages/MWatchNotify.h @@ -0,0 +1,60 @@ +// -*- 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 + * + * 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_MWATCHNOTIFY_H +#define CEPH_MWATCHNOTIFY_H + +#include "msg/Message.h" + + +class MWatchNotify : public Message { + public: + uint64_t cookie; + uint64_t ver; + uint64_t notify_id; + uint8_t opcode; + + MWatchNotify() : Message(CEPH_MSG_WATCH_NOTIFY) { } + MWatchNotify(uint64_t c, uint64_t v, uint64_t i, uint8_t o) : Message(CEPH_MSG_WATCH_NOTIFY), + cookie(c), ver(v), notify_id(i), opcode(o) { } +private: + ~MWatchNotify() {} + +public: + void decode_payload() { + uint8_t msg_ver; + bufferlist::iterator p = payload.begin(); + ::decode(msg_ver, p); + ::decode(opcode, p); + ::decode(cookie, p); + ::decode(ver, p); + ::decode(notify_id, p); + } + void encode_payload() { + uint8_t msg_ver = 0; + ::encode(msg_ver, payload); + ::encode(opcode, payload); + ::encode(cookie, payload); + ::encode(ver, payload); + ::encode(notify_id, payload); + } + + const char *get_type_name() { return "watch-notify"; } + void print(ostream& out) { + out << "watch-notify(c=" << cookie << " v=" << ver << " i=" << notify_id << " opcode=" << (int)opcode << ")"; + } +}; + +#endif -- 2.39.5