X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftools%2Frbd_mirror%2Finstance_watcher%2FTypes.h;fp=src%2Fceph%2Fsrc%2Ftools%2Frbd_mirror%2Finstance_watcher%2FTypes.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=70af2f79112b4b5af15ff2d3666a3271732d3634;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/tools/rbd_mirror/instance_watcher/Types.h b/src/ceph/src/tools/rbd_mirror/instance_watcher/Types.h deleted file mode 100644 index 70af2f7..0000000 --- a/src/ceph/src/tools/rbd_mirror/instance_watcher/Types.h +++ /dev/null @@ -1,197 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#ifndef RBD_MIRROR_INSTANCE_WATCHER_TYPES_H -#define RBD_MIRROR_INSTANCE_WATCHER_TYPES_H - -#include -#include -#include - -#include "include/buffer_fwd.h" -#include "include/encoding.h" -#include "include/int_types.h" - -namespace ceph { class Formatter; } - -namespace rbd { -namespace mirror { -namespace instance_watcher { - -enum NotifyOp { - NOTIFY_OP_IMAGE_ACQUIRE = 0, - NOTIFY_OP_IMAGE_RELEASE = 1, - NOTIFY_OP_PEER_IMAGE_REMOVED = 2, - NOTIFY_OP_SYNC_REQUEST = 3, - NOTIFY_OP_SYNC_START = 4 -}; - -struct PayloadBase { - uint64_t request_id; - - PayloadBase() : request_id(0) { - } - - PayloadBase(uint64_t request_id) : request_id(request_id) { - } - - void encode(bufferlist &bl) const; - void decode(__u8 version, bufferlist::iterator &iter); - void dump(Formatter *f) const; -}; - -struct ImagePayloadBase : public PayloadBase { - std::string global_image_id; - - ImagePayloadBase() : PayloadBase() { - } - - ImagePayloadBase(uint64_t request_id, const std::string &global_image_id) - : PayloadBase(request_id), global_image_id(global_image_id) { - } - - void encode(bufferlist &bl) const; - void decode(__u8 version, bufferlist::iterator &iter); - void dump(Formatter *f) const; -}; - -struct ImageAcquirePayload : public ImagePayloadBase { - static const NotifyOp NOTIFY_OP = NOTIFY_OP_IMAGE_ACQUIRE; - - ImageAcquirePayload() { - } - ImageAcquirePayload(uint64_t request_id, const std::string &global_image_id) - : ImagePayloadBase(request_id, global_image_id) { - } -}; - -struct ImageReleasePayload : public ImagePayloadBase { - static const NotifyOp NOTIFY_OP = NOTIFY_OP_IMAGE_RELEASE; - - ImageReleasePayload() { - } - ImageReleasePayload(uint64_t request_id, const std::string &global_image_id) - : ImagePayloadBase(request_id, global_image_id) { - } -}; - -struct PeerImageRemovedPayload : public PayloadBase { - static const NotifyOp NOTIFY_OP = NOTIFY_OP_PEER_IMAGE_REMOVED; - - std::string global_image_id; - std::string peer_mirror_uuid; - - PeerImageRemovedPayload() { - } - PeerImageRemovedPayload(uint64_t request_id, - const std::string& global_image_id, - const std::string& peer_mirror_uuid) - : PayloadBase(request_id), - global_image_id(global_image_id), peer_mirror_uuid(peer_mirror_uuid) { - } - - void encode(bufferlist &bl) const; - void decode(__u8 version, bufferlist::iterator &iter); - void dump(Formatter *f) const; -}; - -struct SyncPayloadBase : public PayloadBase { - std::string sync_id; - - SyncPayloadBase() : PayloadBase() { - } - - SyncPayloadBase(uint64_t request_id, const std::string &sync_id) - : PayloadBase(request_id), sync_id(sync_id) { - } - - void encode(bufferlist &bl) const; - void decode(__u8 version, bufferlist::iterator &iter); - void dump(Formatter *f) const; -}; - -struct SyncRequestPayload : public SyncPayloadBase { - static const NotifyOp NOTIFY_OP = NOTIFY_OP_SYNC_REQUEST; - - SyncRequestPayload() : SyncPayloadBase() { - } - - SyncRequestPayload(uint64_t request_id, const std::string &sync_id) - : SyncPayloadBase(request_id, sync_id) { - } -}; - -struct SyncStartPayload : public SyncPayloadBase { - static const NotifyOp NOTIFY_OP = NOTIFY_OP_SYNC_START; - - SyncStartPayload() : SyncPayloadBase() { - } - - SyncStartPayload(uint64_t request_id, const std::string &sync_id) - : SyncPayloadBase(request_id, sync_id) { - } -}; - -struct UnknownPayload { - static const NotifyOp NOTIFY_OP = static_cast(-1); - - UnknownPayload() { - } - - void encode(bufferlist &bl) const; - void decode(__u8 version, bufferlist::iterator &iter); - void dump(Formatter *f) const; -}; - -typedef boost::variant Payload; - -struct NotifyMessage { - NotifyMessage(const Payload &payload = UnknownPayload()) : payload(payload) { - } - - Payload payload; - - void encode(bufferlist& bl) const; - void decode(bufferlist::iterator& it); - void dump(Formatter *f) const; - - static void generate_test_instances(std::list &o); -}; - -WRITE_CLASS_ENCODER(NotifyMessage); - -std::ostream &operator<<(std::ostream &out, const NotifyOp &op); - -struct NotifyAckPayload { - std::string instance_id; - uint64_t request_id; - int ret_val; - - NotifyAckPayload() : request_id(0), ret_val(0) { - } - - NotifyAckPayload(const std::string &instance_id, uint64_t request_id, - int ret_val) - : instance_id(instance_id), request_id(request_id), ret_val(ret_val) { - } - - void encode(bufferlist &bl) const; - void decode(bufferlist::iterator& it); - void dump(Formatter *f) const; -}; - -WRITE_CLASS_ENCODER(NotifyAckPayload); - -} // namespace instance_watcher -} // namespace mirror -} // namespace librbd - -using rbd::mirror::instance_watcher::encode; -using rbd::mirror::instance_watcher::decode; - -#endif // RBD_MIRROR_INSTANCE_WATCHER_TYPES_H