diff options
author | Samuel Just <sam.just@dreamhost.com> | 2012-03-23 22:54:41 -0700 |
---|---|---|
committer | Samuel Just <samuel.just@dreamhost.com> | 2012-03-28 17:15:48 -0700 |
commit | 2486c61af02ee486c2406e3b87999d46ac7c8b7e (patch) | |
tree | c75390dd28bed922954db97645863b77535799d9 /src/os/ObjectStore.h | |
parent | 533bbf7bf552398b540905b143ea3a6c91cd547b (diff) | |
download | ceph-2486c61af02ee486c2406e3b87999d46ac7c8b7e.tar.gz |
FileStore: Pass OpRequestRef into filestore in queue_transaction
This allow us to track op progress through the filestore.
Signed-off-by: Samuel Just <samuel.just@dreamhost.com>
Diffstat (limited to 'src/os/ObjectStore.h')
-rw-r--r-- | src/os/ObjectStore.h | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/src/os/ObjectStore.h b/src/os/ObjectStore.h index 95c08b40744..e6f46f3d4f4 100644 --- a/src/os/ObjectStore.h +++ b/src/os/ObjectStore.h @@ -20,6 +20,7 @@ #include "include/buffer.h" #include "include/types.h" #include "osd/osd_types.h" +#include "common/TrackedOp.h" #include "ObjectMap.h" #include <errno.h> @@ -579,15 +580,15 @@ public: virtual int queue_transaction(Sequencer *osr, Transaction* t) = 0; virtual int queue_transaction(Sequencer *osr, Transaction *t, Context *onreadable, Context *ondisk=0, - Context *onreadable_sync=0) { + Context *onreadable_sync=0, + TrackedOpRef op = TrackedOpRef()) { list<Transaction*> tls; tls.push_back(t); - return queue_transactions(osr, tls, onreadable, ondisk, onreadable_sync); + return queue_transactions(osr, tls, onreadable, ondisk, onreadable_sync, op); } virtual int queue_transactions(Sequencer *osr, list<Transaction*>& tls, Context *onreadable, Context *ondisk=0, - Context *onreadable_sync=0) = 0; - - + Context *onreadable_sync=0, + TrackedOpRef op = TrackedOpRef()) = 0; public: ObjectStore() : logger(NULL) {} |