]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
os/ObjectStore: remove void *osr from Transaction
authorSage Weil <sage@redhat.com>
Wed, 31 Jan 2018 16:48:45 +0000 (10:48 -0600)
committerSage Weil <sage@redhat.com>
Tue, 6 Feb 2018 20:09:31 +0000 (14:09 -0600)
No longer used!  (It was only needed for an ugly FileStore hack.)

Signed-off-by: Sage Weil <sage@redhat.com>
src/os/ObjectStore.h
src/os/bluestore/BlueStore.cc
src/os/filestore/FileStore.cc
src/os/kstore/KStore.cc

index 7f841e88230261e62fa17207967d500a619c1706..69e63ef4636cb50c82054b0e5bdd58b09b7adaa8 100644 (file)
@@ -435,8 +435,6 @@ public:
   private:
     TransactionData data;
 
-    void *osr {nullptr}; // NULL on replay
-
     map<coll_t, __le32> coll_index;
     map<ghobject_t, __le32> object_index;
 
@@ -466,7 +464,6 @@ public:
     // override default move operations to reset default values
     Transaction(Transaction&& other) noexcept :
       data(std::move(other.data)),
-      osr(other.osr),
       coll_index(std::move(other.coll_index)),
       object_index(std::move(other.object_index)),
       coll_id(other.coll_id),
@@ -477,14 +474,12 @@ public:
       on_applied(std::move(other.on_applied)),
       on_commit(std::move(other.on_commit)),
       on_applied_sync(std::move(other.on_applied_sync)) {
-      other.osr = nullptr;
       other.coll_id = 0;
       other.object_id = 0;
     }
 
     Transaction& operator=(Transaction&& other) noexcept {
       data = std::move(other.data);
-      osr = other.osr;
       coll_index = std::move(other.coll_index);
       object_index = std::move(other.object_index);
       coll_id = other.coll_id;
@@ -495,7 +490,6 @@ public:
       on_applied = std::move(other.on_applied);
       on_commit = std::move(other.on_commit);
       on_applied_sync = std::move(other.on_applied_sync);
-      other.osr = nullptr;
       other.coll_id = 0;
       other.object_id = 0;
       return *this;
@@ -825,14 +819,6 @@ public:
       return data.ops;
     }
 
-    void set_osr(void *s) {
-      osr = s;
-    }
-
-    void *get_osr() {
-      return osr;
-    }
-
     /**
      * iterator
      *
index 9b50d6200d007c6ae3e0afea633aefd7fa86982f..911a6153f07f7ee64d8a2dc3d2c4491b52f79397 100644 (file)
@@ -9013,7 +9013,6 @@ int BlueStore::queue_transactions(
   txc->oncommits.swap(on_commit);
 
   for (vector<Transaction>::iterator p = tls.begin(); p != tls.end(); ++p) {
-    (*p).set_osr(osr);
     txc->bytes += (*p).get_num_bytes();
     _txc_add_transaction(txc, &(*p));
   }
index c50588fdb36ce8c530174711053540692b85cec9..3d2d2c6bee99866318254e306a135e149dadad60 100644 (file)
@@ -2200,11 +2200,6 @@ int FileStore::queue_transactions(CollectionHandle& ch, vector<Transaction>& tls
   OpSequencer *osr = static_cast<OpSequencer*>(ch.get());
   dout(5) << __FUNC__ << ": osr " << osr << " " << *osr << dendl;
 
-  // used to include osr information in tracepoints during transaction apply
-  for (vector<Transaction>::iterator i = tls.begin(); i != tls.end(); ++i) {
-    (*i).set_osr(osr);
-  }
-
   ZTracer::Trace trace;
   if (osd_op && osd_op->pg_trace) {
     osd_op->store_trace.init("filestore op", &trace_endpoint, &osd_op->pg_trace);
index a0a79274eb88c953d6cbab2e2beb4b2d9e33cf4e..0ecf87a5684d28cf1240146dd18758b87ee8657e 100644 (file)
@@ -2145,7 +2145,6 @@ int KStore::queue_transactions(
   txc->oncommit = ondisk;
 
   for (vector<Transaction>::iterator p = tls.begin(); p != tls.end(); ++p) {
-    (*p).set_osr(osr);
     txc->ops += (*p).get_num_ops();
     txc->bytes += (*p).get_num_bytes();
     _txc_add_transaction(txc, &(*p));