X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fmessages%2FMWatchNotify.h;fp=src%2Fceph%2Fsrc%2Fmessages%2FMWatchNotify.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=15325abf61cb7648e1874c013d35dad6add3bc51;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/messages/MWatchNotify.h b/src/ceph/src/messages/MWatchNotify.h deleted file mode 100644 index 15325ab..0000000 --- a/src/ceph/src/messages/MWatchNotify.h +++ /dev/null @@ -1,92 +0,0 @@ -// -*- 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 { - static const int HEAD_VERSION = 3; - static const int COMPAT_VERSION = 1; - - public: - uint64_t cookie; ///< client unique id for this watch or notify - uint64_t ver; ///< unused - uint64_t notify_id; ///< osd unique id for a notify notification - uint8_t opcode; ///< CEPH_WATCH_EVENT_* - bufferlist bl; ///< notify payload (osd->client) - errorcode32_t return_code; ///< notify result (osd->client) - uint64_t notifier_gid; ///< who sent the notify - - MWatchNotify() - : Message(CEPH_MSG_WATCH_NOTIFY, HEAD_VERSION, COMPAT_VERSION) { } - MWatchNotify(uint64_t c, uint64_t v, uint64_t i, uint8_t o, bufferlist b) - : Message(CEPH_MSG_WATCH_NOTIFY, HEAD_VERSION, COMPAT_VERSION), - cookie(c), - ver(v), - notify_id(i), - opcode(o), - bl(b), - return_code(0), - notifier_gid(0) { } -private: - ~MWatchNotify() override {} - -public: - void decode_payload() override { - 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); - if (msg_ver >= 1) - ::decode(bl, p); - if (header.version >= 2) - ::decode(return_code, p); - else - return_code = 0; - if (header.version >= 3) - ::decode(notifier_gid, p); - else - notifier_gid = 0; - } - void encode_payload(uint64_t features) override { - uint8_t msg_ver = 1; - ::encode(msg_ver, payload); - ::encode(opcode, payload); - ::encode(cookie, payload); - ::encode(ver, payload); - ::encode(notify_id, payload); - ::encode(bl, payload); - ::encode(return_code, payload); - ::encode(notifier_gid, payload); - } - - const char *get_type_name() const override { return "watch-notify"; } - void print(ostream& out) const override { - out << "watch-notify(" - << ceph_watch_event_name(opcode) << " (" << (int)opcode << ")" - << " cookie " << cookie - << " notify " << notify_id - << " ret " << return_code - << ")"; - } -}; - -#endif