s4u::Io::OpType type_ = s4u::Io::OpType::READ;
sg_size_t performed_ioops_ = 0;
resource::Action* timeout_detector_ = nullptr;
+
public:
IoImpl();
void post() override;
void set_exception(actor::ActorImpl* issuer) override;
void finish() override;
- static void wait_any_for(actor::ActorImpl* issuer, const std::vector<IoImpl*>& ios, double timeout);
};
} // namespace activity
} // namespace kernel