void Objecter::_send_op_map_check(Op *op)
{
+ assert(client_lock.is_locked());
// ask the monitor
if (check_latest_map_ops.count(op->tid) == 0) {
check_latest_map_ops[op->tid] = op;
void Objecter::op_cancel_map_check(Op *op)
{
+ assert(client_lock.is_locked());
map<tid_t, Op*>::iterator iter =
check_latest_map_ops.find(op->tid);
if (iter != check_latest_map_ops.end()) {
void Objecter::resend_mon_ops()
{
+ assert(client_lock.is_locked());
ldout(cct, 10) << "resend_mon_ops" << dendl;
for (map<tid_t,PoolStatOp*>::iterator p = poolstat_ops.begin(); p!=poolstat_ops.end(); ++p) {