]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
os/FileStore: assert Sequencer is passed in; kill default_osr
authorSage Weil <sage@redhat.com>
Mon, 14 Sep 2015 18:39:35 +0000 (14:39 -0400)
committerSage Weil <sage@redhat.com>
Mon, 14 Sep 2015 20:33:38 +0000 (16:33 -0400)
Signed-off-by: Sage Weil <sage@redhat.com>
src/os/FileStore.cc
src/os/FileStore.h

index 5f175444619372dcfce06ebe3732a1540b53a9da..44cd9fd9e1c7dd0b7db630709c6f2ac11a0d2e48 100644 (file)
@@ -526,7 +526,6 @@ FileStore::FileStore(const std::string &base, const std::string &jdev, osflagbit
   stop(false), sync_thread(this),
   fdcache(g_ceph_context),
   wbthrottle(g_ceph_context),
-  default_osr("default"),
   throttle_ops(g_ceph_context, "filestore_ops",g_conf->filestore_queue_max_ops),
   throttle_bytes(g_ceph_context, "filestore_bytes",g_conf->filestore_queue_max_bytes),
   op_finisher(g_ceph_context),
@@ -1933,8 +1932,7 @@ int FileStore::queue_transactions(Sequencer *posr, list<Transaction*> &tls,
 
   // set up the sequencer
   OpSequencer *osr;
-  if (!posr)
-    posr = &default_osr;
+  assert(posr);
   if (posr->p) {
     osr = static_cast<OpSequencer *>(posr->p.get());
     dout(5) << "queue_transactions existing " << *osr << "/" << osr->parent << dendl; //<< " w/ q " << osr->q << dendl;
index b9480b044cd9d0be9457a42babf350e7ec067a79..3e59827166915a3693d6e218cc69512f3bc54bcb 100644 (file)
@@ -329,7 +329,6 @@ private:
   FDCache fdcache;
   WBThrottle wbthrottle;
 
-  Sequencer default_osr;
   deque<OpSequencer*> op_queue;
   Throttle throttle_ops, throttle_bytes;
   Finisher op_finisher;