Signed-off-by: Sage Weil <sage@redhat.com>
return true;
}
-void MgrClient::wait_on_list(list<Cond*>& ls)
-{
- assert(lock.is_locked_by_me());
-
- Cond cond;
- ls.push_back(&cond);
- cond.Wait(lock);
- ls.remove(&cond);
-}
-
-void MgrClient::signal_cond_list(list<Cond*>& ls)
-{
- for (list<Cond*>::iterator it = ls.begin(); it != ls.end(); ++it)
- (*it)->Signal();
-}
-
int MgrClient::start_command(const vector<string>& cmd, const bufferlist& inbl,
bufferlist *outbl, string *outs,
Context *onfinish)
CommandTable<MgrCommand> command_table;
- void wait_on_list(list<Cond*>& ls);
- void signal_cond_list(list<Cond*>& ls);
-
Context *report_callback;
// If provided, use this to compose an MPGStats to send with