From: Greg Farnum <greg@inktank.com>
Date: Tue, 10 Dec 2013 23:51:39 +0000 (-0800)
Subject: MemStore: update for the new ObjectStore interface
X-Git-Tag: v0.74~7
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=b8884e01a05fb65c67e643acd60653598960cd78;p=ceph.git

MemStore: update for the new ObjectStore interface

68fdcfa1cc249af859400a2ce4590fefbb2f525b changed the ObjectStore
interface in the 'next' branch, which was merged into master by
e5a02c33e23e4fbdc7bf0f16a5bbff61f4e37186. Unfortunately the
Memstore (added via the master branch) was not corrected for this
interface change.

Signed-off-by: Greg Farnum <greg@inktank.com>
Reviewed-by: David Zafman <david.zafman@inktank.com>
---

diff --git a/src/os/MemStore.cc b/src/os/MemStore.cc
index fdf3ee5bcf70..0d1303cfb7a0 100644
--- a/src/os/MemStore.cc
+++ b/src/os/MemStore.cc
@@ -640,13 +640,17 @@ ObjectMap::ObjectMapIterator MemStore::get_omap_iterator(coll_t cid,
 
 int MemStore::queue_transactions(Sequencer *osr,
 				 list<Transaction*>& tls,
-				 TrackedOpRef op)
+				 TrackedOpRef op,
+				 ThreadPool::TPHandle *handle)
 {
   // fixme: ignore the Sequencer and serialize everything.
   Mutex::Locker l(apply_lock);
 
-  for (list<Transaction*>::iterator p = tls.begin(); p != tls.end(); ++p)
+  for (list<Transaction*>::iterator p = tls.begin(); p != tls.end(); ++p) {
+    // poke the TPHandle heartbeat just to exercise that code path
+    handle->reset_tp_timeout();
     _do_transaction(**p);
+  }
 
   Context *on_apply = NULL, *on_apply_sync = NULL, *on_commit = NULL;
   ObjectStore::Transaction::collect_contexts(tls, &on_apply, &on_commit,
diff --git a/src/os/MemStore.h b/src/os/MemStore.h
index 9c4d0037a515..423ea7a5555d 100644
--- a/src/os/MemStore.h
+++ b/src/os/MemStore.h
@@ -348,7 +348,8 @@ public:
 
   int queue_transactions(
     Sequencer *osr, list<Transaction*>& tls,
-    TrackedOpRef op = TrackedOpRef());
+    TrackedOpRef op = TrackedOpRef(),
+    ThreadPool::TPHandle *handle = NULL);
 };