op.con = conn;
ldout(cct, 4) << __func__ << ": new command op to " << target_gid
- << " tid=" << op.tid << cmd << dendl;
+ << " tid=" << op.tid << " multi_id=" << op.multi_target_id << " "<< cmd << dendl;
// Construct and send MCommand
MessageRef m = op.get_message(monclient->get_fsid());
}
auto &op = command_table.get_command(tid);
- ceph_tid_t multi_id = command_table.get_multi_target_id(tid);
+ ceph_tid_t multi_id = op.multi_target_id;
if (op.outbl) {
if (multi_id != 0 && m->r == 0) {
}
else {
// when this command is the last one
- if (command_table.count_multi_commands(multi_id) <= 1) {
+ if (command_table.count_multi_commands(multi_id) == 1) {
op.outbl->append("]");
}
}
return commands.at(tid);
}
- bool get_multi_target_id(ceph_tid_t tid) const
- {
- return commands.at(tid).multi_target_id;
- }
-
void erase(ceph_tid_t tid)
{
ceph_tid_t multi_id = commands.at(tid).multi_target_id;