s->put();
}
-int Objecter::submit_command(CommandOp *c, ceph_tid_t *ptid)
+void Objecter::submit_command(CommandOp *c, ceph_tid_t *ptid)
{
shunique_lock sul(rwlock, ceph::acquire_unique);
*ptid = tid;
logger->inc(l_osdc_command_active);
-
- return 0;
}
int Objecter::_calc_command_target(CommandOp *c, shunique_lock& sul)
};
- int submit_command(CommandOp *c, ceph_tid_t *ptid);
+ void submit_command(CommandOp *c, ceph_tid_t *ptid);
int _calc_command_target(CommandOp *c, shunique_lock &sul);
void _assign_command_session(CommandOp *c, shunique_lock &sul);
void _send_command(CommandOp *c);
epoch_t op_cancel_writes(int r, int64_t pool=-1);
// commands
- int osd_command(int osd, vector<string>& cmd,
+ void osd_command(int osd, vector<string>& cmd,
const bufferlist& inbl, ceph_tid_t *ptid,
bufferlist *poutbl, string *prs, Context *onfinish) {
assert(osd >= 0);
poutbl,
prs,
onfinish);
- return submit_command(c, ptid);
+ submit_command(c, ptid);
}
- int pg_command(pg_t pgid, vector<string>& cmd,
+ void pg_command(pg_t pgid, vector<string>& cmd,
const bufferlist& inbl, ceph_tid_t *ptid,
bufferlist *poutbl, string *prs, Context *onfinish) {
CommandOp *c = new CommandOp(
poutbl,
prs,
onfinish);
- return submit_command(c, ptid);
+ submit_command(c, ptid);
}
// mid-level helpers