]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
client: adapt to new objecter interface
authorYehuda Sadeh <yehuda@inktank.com>
Fri, 7 Mar 2014 23:35:15 +0000 (15:35 -0800)
committerJohn Spray <john.spray@redhat.com>
Mon, 25 Aug 2014 00:33:40 +0000 (01:33 +0100)
Signed-off-by: Yehuda Sadeh <yehuda@inktank.com>
src/client/Client.cc

index 4cd6f2f170e8ee0f5bf912321a705a06285606c0..b57c44a14efd885c416c0838cf48efdbbb8385bc 100644 (file)
@@ -193,7 +193,7 @@ Client::Client(Messenger *m, MonClient *mc)
   // osd interfaces
   osdmap = new OSDMap;     // initially blank.. see mount()
   mdsmap = new MDSMap;
-  objecter = new Objecter(cct, messenger, monclient, osdmap, client_lock, timer,
+  objecter = new Objecter(cct, messenger, monclient, osdmap,
                          0, 0);
   objecter->set_client_incarnation(0);  // client always 0, for now.
   writeback_handler = new ObjecterWriteback(objecter);
@@ -364,11 +364,9 @@ int Client::init()
   }
 
   client_lock.Unlock();
-  objecter->init_unlocked();
+  objecter->init();
   client_lock.Lock();
 
-  objecter->init_locked();
-
   monclient->set_want_keys(CEPH_ENTITY_TYPE_MDS | CEPH_ENTITY_TYPE_OSD);
   monclient->sub_want("mdsmap", 0, 0);
   monclient->sub_want("osdmap", 0, CEPH_SUBSCRIBE_ONETIME);
@@ -454,9 +452,8 @@ void Client::shutdown()
   assert(initialized);
   initialized = false;
   timer.shutdown();
-  objecter->shutdown_locked();
+  objecter->shutdown();
   client_lock.Unlock();
-  objecter->shutdown_unlocked();
   monclient->shutdown();
 
   if (logger) {