update sources to v12.1.2

[ceph.git] / ceph / src / msg / Message.cc

diff --git a/ceph/src/msg/Message.cc b/ceph/src/msg/Message.cc
index 9d1953d75b195de2cba073061fa21be408294198..7763caf77cd579b5760ecb65b3717dac9cc3a49d 100644 (file)
--- a/ceph/src/msg/Message.cc
+++ b/ceph/src/msg/Message.cc
@@ -84,10 +84,13 @@ using namespace std;
 #include "messages/MOSDScrubReserve.h"
 #include "messages/MOSDRepScrub.h"
 #include "messages/MOSDRepScrubMap.h"
+#include "messages/MOSDForceRecovery.h"
 #include "messages/MOSDPGScan.h"
 #include "messages/MOSDPGBackfill.h"
 #include "messages/MOSDBackoff.h"
 #include "messages/MOSDPGBackfillRemove.h"
+#include "messages/MOSDPGRecoveryDelete.h"
+#include "messages/MOSDPGRecoveryDeleteReply.h"
 
 #include "messages/MRemoveSnaps.h"
 
@@ -400,6 +403,9 @@ Message *decode_message(CephContext *cct, int crcflags,
   case MSG_OSD_RECOVERY_RESERVE:
     m = new MRecoveryReserve;
     break;
+  case MSG_OSD_FORCE_RECOVERY:
+    m = new MOSDForceRecovery;
+    break;
 
   case MSG_ROUTE:
     m = new MRoute;
@@ -545,6 +551,12 @@ Message *decode_message(CephContext *cct, int crcflags,
   case MSG_OSD_PG_PUSH_REPLY:
     m = new MOSDPGPushReply;
     break;
+  case MSG_OSD_PG_RECOVERY_DELETE:
+    m = new MOSDPGRecoveryDelete;
+    break;
+  case MSG_OSD_PG_RECOVERY_DELETE_REPLY:
+    m = new MOSDPGRecoveryDeleteReply;
+    break;
   case MSG_OSD_EC_WRITE:
     m = new MOSDECSubOpWrite;
     break;