1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 #ifndef RBD_MIRROR_INSTANCE_WATCHER_TYPES_H
5 #define RBD_MIRROR_INSTANCE_WATCHER_TYPES_H
9 #include <boost/variant.hpp>
11 #include "include/buffer_fwd.h"
12 #include "include/encoding.h"
13 #include "include/int_types.h"
15 namespace ceph { class Formatter; }
19 namespace instance_watcher {
22 NOTIFY_OP_IMAGE_ACQUIRE = 0,
23 NOTIFY_OP_IMAGE_RELEASE = 1,
24 NOTIFY_OP_PEER_IMAGE_REMOVED = 2,
25 NOTIFY_OP_SYNC_REQUEST = 3,
26 NOTIFY_OP_SYNC_START = 4
32 PayloadBase() : request_id(0) {
35 PayloadBase(uint64_t request_id) : request_id(request_id) {
38 void encode(bufferlist &bl) const;
39 void decode(__u8 version, bufferlist::iterator &iter);
40 void dump(Formatter *f) const;
43 struct ImagePayloadBase : public PayloadBase {
44 std::string global_image_id;
46 ImagePayloadBase() : PayloadBase() {
49 ImagePayloadBase(uint64_t request_id, const std::string &global_image_id)
50 : PayloadBase(request_id), global_image_id(global_image_id) {
53 void encode(bufferlist &bl) const;
54 void decode(__u8 version, bufferlist::iterator &iter);
55 void dump(Formatter *f) const;
58 struct ImageAcquirePayload : public ImagePayloadBase {
59 static const NotifyOp NOTIFY_OP = NOTIFY_OP_IMAGE_ACQUIRE;
61 ImageAcquirePayload() {
63 ImageAcquirePayload(uint64_t request_id, const std::string &global_image_id)
64 : ImagePayloadBase(request_id, global_image_id) {
68 struct ImageReleasePayload : public ImagePayloadBase {
69 static const NotifyOp NOTIFY_OP = NOTIFY_OP_IMAGE_RELEASE;
71 ImageReleasePayload() {
73 ImageReleasePayload(uint64_t request_id, const std::string &global_image_id)
74 : ImagePayloadBase(request_id, global_image_id) {
78 struct PeerImageRemovedPayload : public PayloadBase {
79 static const NotifyOp NOTIFY_OP = NOTIFY_OP_PEER_IMAGE_REMOVED;
81 std::string global_image_id;
82 std::string peer_mirror_uuid;
84 PeerImageRemovedPayload() {
86 PeerImageRemovedPayload(uint64_t request_id,
87 const std::string& global_image_id,
88 const std::string& peer_mirror_uuid)
89 : PayloadBase(request_id),
90 global_image_id(global_image_id), peer_mirror_uuid(peer_mirror_uuid) {
93 void encode(bufferlist &bl) const;
94 void decode(__u8 version, bufferlist::iterator &iter);
95 void dump(Formatter *f) const;
98 struct SyncPayloadBase : public PayloadBase {
101 SyncPayloadBase() : PayloadBase() {
104 SyncPayloadBase(uint64_t request_id, const std::string &sync_id)
105 : PayloadBase(request_id), sync_id(sync_id) {
108 void encode(bufferlist &bl) const;
109 void decode(__u8 version, bufferlist::iterator &iter);
110 void dump(Formatter *f) const;
113 struct SyncRequestPayload : public SyncPayloadBase {
114 static const NotifyOp NOTIFY_OP = NOTIFY_OP_SYNC_REQUEST;
116 SyncRequestPayload() : SyncPayloadBase() {
119 SyncRequestPayload(uint64_t request_id, const std::string &sync_id)
120 : SyncPayloadBase(request_id, sync_id) {
124 struct SyncStartPayload : public SyncPayloadBase {
125 static const NotifyOp NOTIFY_OP = NOTIFY_OP_SYNC_START;
127 SyncStartPayload() : SyncPayloadBase() {
130 SyncStartPayload(uint64_t request_id, const std::string &sync_id)
131 : SyncPayloadBase(request_id, sync_id) {
135 struct UnknownPayload {
136 static const NotifyOp NOTIFY_OP = static_cast<NotifyOp>(-1);
141 void encode(bufferlist &bl) const;
142 void decode(__u8 version, bufferlist::iterator &iter);
143 void dump(Formatter *f) const;
146 typedef boost::variant<ImageAcquirePayload,
148 PeerImageRemovedPayload,
151 UnknownPayload> Payload;
153 struct NotifyMessage {
154 NotifyMessage(const Payload &payload = UnknownPayload()) : payload(payload) {
159 void encode(bufferlist& bl) const;
160 void decode(bufferlist::iterator& it);
161 void dump(Formatter *f) const;
163 static void generate_test_instances(std::list<NotifyMessage *> &o);
166 WRITE_CLASS_ENCODER(NotifyMessage);
168 std::ostream &operator<<(std::ostream &out, const NotifyOp &op);
170 struct NotifyAckPayload {
171 std::string instance_id;
175 NotifyAckPayload() : request_id(0), ret_val(0) {
178 NotifyAckPayload(const std::string &instance_id, uint64_t request_id,
180 : instance_id(instance_id), request_id(request_id), ret_val(ret_val) {
183 void encode(bufferlist &bl) const;
184 void decode(bufferlist::iterator& it);
185 void dump(Formatter *f) const;
188 WRITE_CLASS_ENCODER(NotifyAckPayload);
190 } // namespace instance_watcher
191 } // namespace mirror
192 } // namespace librbd
194 using rbd::mirror::instance_watcher::encode;
195 using rbd::mirror::instance_watcher::decode;
197 #endif // RBD_MIRROR_INSTANCE_WATCHER_TYPES_H