SObjectizer: от простого к сложному. Часть III

Просто логично было бы предположить, что SO будет действовать согласно so_exception_reaction, а не просто вызовет std::terminate.

И тут бы идеально подошел time_limit для состояния st_wait_perform.

class io_performer : public so_5::agent_t {
  struct io_timeout : public so_5::signal_t {};
  ...
  void on_next_operation(mhood_t<start_next_io>) {
    // Начинаем отсчет времени для очередной операции.
    so_5::send_delayed<io_timeout>(*this, ...);
    // Начинаем саму IO-операцию.
    perform_io(...);
  }
  void on_io_result(mhood_t<io_result> cmd) {
    ... // Должным образом обрабатываем результат.
    if(has_more_io_ops())
      so_5::send<start_next_io>(*this, ...);
  }
  void on_timeout(mhood_t<io_timeout>) {
     ... // Обрабатываем тайм-аут текущей операции.
  }
};

class io_performer : public so_5::agent_t {
  struct io_timeout : public so_5::message_t {
    op_id id_;
    io_timeout(op_id id) : id_(std::move(id)) {}
  };
  ...
  void on_next_operation(mhood_t<start_next_io>) {
    // Начинаем отсчет времени для очередной операции.
    current_id_ = create_current_op_id();
    so_5::send_delayed<io_timeout>(*this, ..., current_op_id_);
    // Начинаем саму IO-операцию.
    perform_io(...);
  }
  void on_io_result(mhood_t<io_result> cmd) {
    ... // Должным образом обрабатываем результат.
    current_op_id_ = null_id; // Сбрасываем ID, т.к. текущая операция завершилась.
    if(has_more_io_ops())
      so_5::send<start_next_io>(*this, ...);
  }
  void on_timeout(mhood_t<io_timeout> cmd) {
    if(current_op_id_ == cmd->id_) {
       ... // Обрабатываем тайм-аут текущей операции.
    }
  }
  ...
  op_id current_op_id_;
};