mds: hook session version in EImportStart

diff --git a/src/mds/events/EImportStart.h b/src/mds/events/EImportStart.h
index aa3d24ce81ba2e8a50083442d929a84f2750c3f9..6b076a30838461beb5cceea975c666886454f1b0 100644 (file)
--- a/src/mds/events/EImportStart.h
+++ b/src/mds/events/EImportStart.h
@@ -57,6 +57,7 @@ protected:
     ::decode(client_map, bl);
   }
   
+  void update_segment();
   void replay(MDS *mds);
 
 };

diff --git a/src/mds/journal.cc b/src/mds/journal.cc
index fd37186f8405dc0dd0473eef9bf5830d43f10dae..ae88f86cf3cf5cbebd150790ca3606873a334994 100644 (file)
--- a/src/mds/journal.cc
+++ b/src/mds/journal.cc
@@ -875,6 +875,11 @@ void EExport::replay(MDS *mds)
 // -----------------------
 // EImportStart
 
+void EImportStart::update_segment()
+{
+  _segment->sessionmapv = cmapv;
+}
+
 void EImportStart::replay(MDS *mds)
 {
   dout(10) << "EImportStart.replay " << base << dendl;
@@ -898,6 +903,7 @@ void EImportStart::replay(MDS *mds)
     assert(mds->sessionmap.version == cmapv);
     mds->sessionmap.projected = mds->sessionmap.version;
   }
+  _segment->sessionmapv = cmapv;
 }
 
 // -----------------------