messages/MPGCreated: add MPGCreated

add a new message type MPGCreated. osd is supposed to send this message
to monitor to inform that any pg(s) is created and activated.

Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/src/messages/MOSDPGCreated.h b/src/messages/MOSDPGCreated.h
new file mode 100644 (file)
index 0000000..13ec10f
--- /dev/null
+++ b/src/messages/MOSDPGCreated.h
@@ -0,0 +1,32 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#pragma once
+
+#include "osd/osd_types.h"
+#include "messages/PaxosServiceMessage.h"
+
+class MOSDPGCreated : public PaxosServiceMessage {
+public:
+  pg_t pgid;
+  MOSDPGCreated()
+    : PaxosServiceMessage(MSG_OSD_PG_CREATED, 0)
+  {}
+  MOSDPGCreated(pg_t pgid)
+    : PaxosServiceMessage(MSG_OSD_PG_CREATED, 0),
+      pgid(pgid)
+  {}
+  const char *get_type_name() const override { return "pg_created"; }
+  void print(ostream& out) const override {
+    out << "osd_pg_created(" << pgid << ")";
+  }
+  void encode_payload(uint64_t features) override {
+    paxos_encode();
+    ::encode(pgid, payload);
+  }
+  void decode_payload() override {
+    auto p = payload.begin();
+    paxos_decode(p);
+    ::decode(pgid, p);
+  }
+};

diff --git a/src/msg/Message.cc b/src/msg/Message.cc
index 8b5cb0a98f0c37f5568b0bcd336409831053a526..c80ddf0fe00f3b5920ca8fb0a5e2fed28b6c635c 100644 (file)
--- a/src/msg/Message.cc
+++ b/src/msg/Message.cc
@@ -72,6 +72,7 @@ using namespace std;
 #include "messages/MOSDMap.h"
 #include "messages/MMonGetOSDMap.h"
 
+#include "messages/MOSDPGCreated.h"
 #include "messages/MOSDPGNotify.h"
 #include "messages/MOSDPGQuery.h"
 #include "messages/MOSDPGLog.h"
@@ -462,6 +463,9 @@ Message *decode_message(CephContext *cct, int crcflags,
   case MSG_OSD_REPOPREPLY:
     m = new MOSDRepOpReply();
     break;
+  case MSG_OSD_PG_CREATED:
+    m = new MOSDPGCreated();
+    break;
   case MSG_OSD_PG_UPDATE_LOG_MISSING:
     m = new MOSDPGUpdateLogMissing();
     break;

diff --git a/src/msg/Message.h b/src/msg/Message.h
index da35ce08ef2ba5000656f08f36fd0a920559d22f..a3c3ffa4b0707ea49d07afdb636fb69f2d6c5e14 100644 (file)
--- a/src/msg/Message.h
+++ b/src/msg/Message.h
@@ -114,6 +114,7 @@
 #define MSG_OSD_PG_UPDATE_LOG_MISSING  114
 #define MSG_OSD_PG_UPDATE_LOG_MISSING_REPLY  115
 
+#define MSG_OSD_PG_CREATED      116
 
 // *** MDS ***