]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mds: kill export finish waiters
authorYan, Zheng <zyan@redhat.com>
Tue, 7 Feb 2017 04:36:11 +0000 (12:36 +0800)
committerYan, Zheng <zyan@redhat.com>
Mon, 20 Feb 2017 08:12:36 +0000 (16:12 +0800)
this code is unused

Signed-off-by: "Yan, Zheng" <zyan@redhat.com>
src/mds/Migrator.cc
src/mds/Migrator.h

index 98279d0f2f5a05736d14d6c60c0f0e6da344c603..8af8344c21a409c222afbe54c8e27fd7b8a32562 100644 (file)
@@ -345,9 +345,6 @@ void Migrator::export_try_cancel(CDir *dir, bool notify_peer)
 
   // finish clean-up?
   if (it->second.state == EXPORT_CANCELLED) {
-    // wake up any waiters
-    mds->queue_waiters(it->second.waiting_for_finish);
-
     MutationRef mut = it->second.mut;
 
     export_state.erase(it);
@@ -944,7 +941,6 @@ void Migrator::export_frozen(CDir *dir, uint64_t tid)
     // .. unwind ..
     dir->unfreeze_tree();
     dir->state_clear(CDir::STATE_EXPORTING);
-    mds->queue_waiters(it->second.waiting_for_finish);
 
     mds->send_message_mds(new MExportDirCancel(dir->dirfrag(), it->second.tid), it->second.peer);
 
@@ -1860,9 +1856,6 @@ void Migrator::export_finish(CDir *dir)
   // discard delayed expires
   cache->discard_delayed_expire(dir);
 
-  // queue finishers
-  mds->queue_waiters(it->second.waiting_for_finish);
-
   MutationRef mut = it->second.mut;
   // remove from exporting list, clean up state
   export_state.erase(it);
index 75561442183425713a48ad89d8040cddb7369f15..3c6cc602b87d52db3531d2494574b4d2ac371ae5 100644 (file)
@@ -89,7 +89,6 @@ protected:
     set<mds_rank_t> warning_ack_waiting;
     set<mds_rank_t> notify_ack_waiting;
     map<inodeno_t,map<client_t,Capability::Import> > peer_imported;
-    list<MDSInternalContextBase*> waiting_for_finish;
     MutationRef mut;
     // for freeze tree deadlock detection
     utime_t last_cum_auth_pins_change;
@@ -263,11 +262,6 @@ public:
                         map<inodeno_t,map<client_t,Capability::Import> >& peer_imported,
                         list<MDSInternalContextBase*>& finished, int *num_dentries);
 
-  void add_export_finish_waiter(CDir *dir, MDSInternalContextBase *c) {
-    map<CDir*, export_state_t>::iterator it = export_state.find(dir);
-    assert(it != export_state.end());
-    it->second.waiting_for_finish.push_back(c);
-  }
   void clear_export_proxy_pins(CDir *dir);
 
   void export_caps(CInode *in);