diff options
| author | Greg Farnum <greg@inktank.com> | 2013-10-18 16:24:27 -0700 |
|---|---|---|
| committer | Greg Farnum <greg@inktank.com> | 2013-10-18 16:24:27 -0700 |
| commit | 6dff9261518b3e8684e25c5e9603b3bf5a5da4f8 (patch) | |
| tree | 67819129e17be8cfb584a1f0e1b8b4a432bc6bf6 | |
| parent | 09bd6bbe3b5e66a281da762d34ec71f27f038ac6 (diff) | |
| download | ceph-6dff9261518b3e8684e25c5e9603b3bf5a5da4f8.tar.gz | |
PG: add a requeue_op() function to complement requeue_ops().
Signed-off-by: Greg Farnum <greg@inktank.com>
| -rw-r--r-- | src/osd/PG.cc | 5 | ||||
| -rw-r--r-- | src/osd/PG.h | 1 |
2 files changed, 6 insertions, 0 deletions
diff --git a/src/osd/PG.cc b/src/osd/PG.cc index 8f7d3ccb684..8ba5b6cc2ff 100644 --- a/src/osd/PG.cc +++ b/src/osd/PG.cc @@ -2507,6 +2507,11 @@ void PG::requeue_object_waiters(map<hobject_t, list<OpRequestRef> >& m) m.clear(); } +void PG::requeue_op(OpRequestRef op) +{ + osd->op_wq.queue_front(make_pair(PGRef(this), op)); +} + void PG::requeue_ops(list<OpRequestRef> &ls) { dout(15) << " requeue_ops " << ls << dendl; diff --git a/src/osd/PG.h b/src/osd/PG.h index 9b42ff4272b..dc11638fd4b 100644 --- a/src/osd/PG.h +++ b/src/osd/PG.h @@ -535,6 +535,7 @@ protected: void split_ops(PG *child, unsigned split_bits); void requeue_object_waiters(map<hobject_t, list<OpRequestRef> >& m); + void requeue_op(OpRequestRef op); void requeue_ops(list<OpRequestRef> &l); // stats that persist lazily |