dst_buff_size_ = size;
return this;
}
-Comm* Comm::set_payload_size(double bytes)
+CommPtr Comm::set_payload_size(double bytes)
{
- set_remaining(bytes);
+ Activity::set_remaining(bytes);
return this;
}
return res;
}
+
CommPtr Comm::sendto_async(Host* from, Host* to, double simulated_size_in_bytes)
{
- auto res = Comm::sendto_init(from, to);
- res->set_remaining(simulated_size_in_bytes)->start();
+ auto res = Comm::sendto_init(from, to)->set_payload_size(simulated_size_in_bytes);
+ res->vetoable_start();
return res;
}