]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
osd: queue all transactions under an osr
authorSage Weil <sage@redhat.com>
Mon, 14 Sep 2015 18:37:37 +0000 (14:37 -0400)
committerSage Weil <sage@redhat.com>
Mon, 14 Sep 2015 20:33:28 +0000 (16:33 -0400)
This was missed in e7bbafa3bfbd5e936a8be026a30b83a89f6121c3.

Signed-off-by: Sage Weil <sage@redhat.com>
src/osd/OSD.cc

index 46514f354c03c87737336fa5daa4529ecb945109..76a7cf65b7b6c7ae57816301cb32c23e0c906004 100644 (file)
@@ -2515,7 +2515,7 @@ void OSD::clear_temp_objects()
        dout(20) << "  removing " << *p << " object " << *q << dendl;
        t.remove(*p, *q);
       }
-      store->apply_transaction(t);
+      store->apply_transaction(service.meta_osr.get(), t);
     }
   }
 }
@@ -6446,7 +6446,7 @@ void OSD::handle_osd_map(MOSDMap *m)
   // superblock and commit
   write_superblock(t);
   store->queue_transaction(
-    0,
+    service.meta_osr.get(),
     _t,
     new C_OnMapApply(&service, _t, pinned_maps, osdmap->get_epoch()),
     0, 0);
@@ -6537,7 +6537,7 @@ void OSD::check_osdmap_features(ObjectStore *fs)
       superblock.compat_features.incompat.insert(CEPH_OSD_FEATURE_INCOMPAT_SHARDS);
       ObjectStore::Transaction *t = new ObjectStore::Transaction;
       write_superblock(*t);
-      int err = store->queue_transaction_and_cleanup(NULL, t);
+      int err = store->queue_transaction_and_cleanup(service.meta_osr.get(), t);
       assert(err == 0);
       fs->set_allow_sharded_objects();
     }