| 4493 | } |
| 4494 | |
| 4495 | void Objecter::pool_op_submit(PoolOp *op) |
| 4496 | { |
| 4497 | // rwlock is locked |
| 4498 | if (mon_timeout > timespan(0)) { |
| 4499 | op->ontimeout = timer.add_event(mon_timeout, |
| 4500 | [this, op]() { |
| 4501 | pool_op_cancel(op->tid, -ETIMEDOUT); }); |
| 4502 | } |
| 4503 | _pool_op_submit(op); |
| 4504 | } |
| 4505 | |
| 4506 | void Objecter::_pool_op_submit(PoolOp *op) |
| 4507 | { |