comm = mbox->put_init(msg, size)->set_rate(mig_speed)->wait_for(timeout);
else
comm = mbox->put_async(msg, size)->wait_for(timeout);
- } catch (const xbt_ex&) {
+ } catch (const Exception&) {
if (comm) {
sg_size_t remaining = static_cast<sg_size_t>(comm->get_remaining());
XBT_VERB("timeout (%lf s) in sending_migration_data, remaining %llu bytes of %llu", timeout, remaining, size);
} else if (sent > ramsize)
XBT_CRITICAL("bug");
- } catch (const xbt_ex&) {
+ } catch (const Exception&) {
// hostfailure (if you want to know whether this is the SRC or the DST check directly in send_migration_data code)
// Stop the dirty page tracking an return (there is no memory space to release)
sg_vm_stop_dirty_page_tracking(vm_);
try {
XBT_DEBUG("Stage 2, gonna send %llu", updated_size);
sent = sendMigrationData(updated_size, 2, stage2_round, mig_speed, mig_timeout);
- } catch (const xbt_ex&) {
+ } catch (const Exception&) {
// hostfailure (if you want to know whether this is the SRC or the DST check directly in send_migration_data
// code)
// Stop the dirty page tracking an return (there is no memory space to release)
try {
XBT_DEBUG("Stage 3: Gonna send %zu bytes", remaining_size);
sendMigrationData(remaining_size, 3, 0, mig_speed, -1);
- } catch (const xbt_ex&) {
+ } catch (const Exception&) {
// hostfailure (if you want to know whether this is the SRC or the DST check directly in send_migration_data code)
// Stop the dirty page tracking an return (there is no memory space to release)
vm_->resume();