diff options
| -rw-r--r-- | src/osd/OSD.cc | 1 | ||||
| -rw-r--r-- | src/osd/OSD.h | 1 | ||||
| -rw-r--r-- | src/osd/ReplicatedPG.cc | 13 |
3 files changed, 11 insertions, 4 deletions
diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc index 68ba722bb4c..dcd27486aa0 100644 --- a/src/osd/OSD.cc +++ b/src/osd/OSD.cc @@ -172,6 +172,7 @@ OSDService::OSDService(OSD *osd) : scrub_wq(osd->scrub_wq), scrub_finalize_wq(osd->scrub_finalize_wq), rep_scrub_wq(osd->rep_scrub_wq), + push_wq("push_wq", cct->_conf->osd_recovery_thread_timeout, &osd->recovery_tp), class_handler(osd->class_handler), publish_lock("OSDService::publish_lock"), pre_publish_lock("OSDService::pre_publish_lock"), diff --git a/src/osd/OSD.h b/src/osd/OSD.h index 8aad81a4521..79212688993 100644 --- a/src/osd/OSD.h +++ b/src/osd/OSD.h @@ -309,6 +309,7 @@ public: ThreadPool::WorkQueue<PG> &scrub_wq; ThreadPool::WorkQueue<PG> &scrub_finalize_wq; ThreadPool::WorkQueue<MOSDRepScrub> &rep_scrub_wq; + GenContextWQ push_wq; ClassHandler *&class_handler; void dequeue_pg(PG *pg, list<OpRequestRef> *dequeued); diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc index 74472cfcf9b..dc96e44a6d9 100644 --- a/src/osd/ReplicatedPG.cc +++ b/src/osd/ReplicatedPG.cc @@ -1593,14 +1593,14 @@ void ReplicatedBackend::_do_push(OpRequestRef op) get_parent()->queue_transaction(t); } -struct C_ReplicatedBackend_OnPullComplete : Context { +struct C_ReplicatedBackend_OnPullComplete : GenContext<ThreadPool::TPHandle&> { ReplicatedBackend *bc; list<pair<hobject_t, ObjectContextRef> > to_continue; int priority; C_ReplicatedBackend_OnPullComplete(ReplicatedBackend *bc, int priority) : bc(bc), priority(priority) {} - void finish(int) { + void finish(ThreadPool::TPHandle &handle) { ReplicatedBackend::RPGHandle *h = bc->_open_recovery_op(); for (list<pair<hobject_t, ObjectContextRef> >::iterator i = to_continue.begin(); @@ -1610,6 +1610,7 @@ struct C_ReplicatedBackend_OnPullComplete : Context { bc->get_parent()->on_global_recover( i->first); } + handle.reset_tp_timeout(); } bc->run_recovery_op(h, priority); } @@ -1638,7 +1639,9 @@ void ReplicatedBackend::_do_pull_response(OpRequestRef op) m->get_priority()); c->to_continue.swap(to_continue); t->register_on_complete( - get_parent()->bless_context(c)); + new QueueInWQ( + &osd->push_wq, + get_parent()->bless_gencontext(c))); } replies.erase(replies.end() - 1); @@ -6858,7 +6861,9 @@ void ReplicatedBackend::sub_op_push(OpRequestRef op) op->request->get_priority()); c->to_continue.swap(to_continue); t->register_on_complete( - get_parent()->bless_context(c)); + new QueueInWQ( + &osd->push_wq, + get_parent()->bless_gencontext(c))); } run_recovery_op(h, op->request->get_priority()); } else { |