working_ = false;
count_++;
});
- end_func_(this);
+ if (end_func_)
+ end_func_(this);
Operation::on_end(this);
for (auto const& op : successors_)
op->receive(this);
*/
void ExecOp::execute()
{
- start_func_(this);
+ if (start_func_)
+ start_func_(this);
Operation::on_start(this);
simgrid::kernel::actor::simcall_answered([this] {
working_ = true;
*/
void CommOp::execute()
{
- start_func_(this);
+ if (start_func_)
+ start_func_(this);
Operation::on_start(this);
simgrid::kernel::actor::simcall_answered([this] {
working_ = true;