update sources to 12.2.8

[ceph.git] / ceph / src / mds / Migrator.h

diff --git a/ceph/src/mds/Migrator.h b/ceph/src/mds/Migrator.h
index 148b2fb4fd2c01422109e9f36455929c5269a291..59d3a55b9a43727d3177d6766cfbdaac4af85199 100644 (file)
--- a/ceph/src/mds/Migrator.h
+++ b/ceph/src/mds/Migrator.h
@@ -104,6 +104,7 @@ public:
   // -- cons --
   Migrator(MDSRank *m, MDCache *c) : mds(m), cache(c) {
     inject_session_race = g_conf->get_val<bool>("mds_inject_migrator_session_race");
+    inject_message_loss = g_conf->get_val<int64_t>("mds_inject_migrator_message_loss");
   }
 
   void handle_conf_change(const struct md_config_t *conf,
@@ -194,6 +195,7 @@ protected:
   void handle_export_finish(MExportDirFinish *m);
 
   void handle_export_caps(MExportCaps *m);
+  void handle_export_caps_ack(MExportCapsAck *m);
   void logged_import_caps(CInode *in,
                          mds_rank_t from,
                          map<client_t,pair<Session*,uint64_t> >& imported_session_map,
@@ -352,6 +354,7 @@ private:
   MDSRank *mds;
   MDCache *cache;
   bool inject_session_race = false;
+  int inject_message_loss = 0;
 };
 
 #endif