XBT_INFO("Done dispatching all messages");
/* Now that all message exchanges were initiated, wait for their completion in one single call */
- sg4::Comm::wait_all(&pending_comms);
+ sg4::Comm::wait_all(pending_comms);
XBT_INFO("Goodbye now!");
}
auto received = mbox->get_unique<std::string>();
XBT_INFO("I got a '%s'.", received->c_str());
- sg4::Disk* disk = sg4::Host::current()->get_disks().front();
- sg_size_t write_size = disk->write(4e6);
+ const sg4::Disk* disk = sg4::Host::current()->get_disks().front();
+ sg_size_t write_size = disk->write(4e6);
XBT_INFO("Wrote %llu bytes on '%s'", write_size, disk->get_cname());
}
};
/*************************************************************************************************/
-static sg4::NetZone* create_zone(sg4::NetZone* root, const std::string& id)
+static sg4::NetZone* create_zone(const sg4::NetZone* root, const std::string& id)
{
auto* zone = sg4::create_floyd_zone(id);
zone->set_parent(root);
std::string hostname = id + "-cpu-" + std::to_string(i);
auto* host = zone->create_host(hostname, 1e9);
host->create_disk("disk-" + hostname, 1e9, 1e6);
- auto* link = zone->create_link("link-" + hostname, 1e9);
- zone->add_route(host->get_netpoint(), router, nullptr, nullptr, std::vector<sg4::Link*>{link});
+ const auto* link = zone->create_link("link-" + hostname, 1e9);
+ zone->add_route(host->get_netpoint(), router, nullptr, nullptr, {sg4::LinkInRoute(link)});
}
return zone;
}
auto* root = sg4::create_full_zone("root");
auto* zoneA = create_zone(root, "A");
auto* zoneB = create_zone(root, "B");
- auto* link = root->create_link("root-link", 1e10);
+ const auto* link = root->create_link("root-link", 1e10);
root->add_route(zoneA->get_netpoint(), zoneB->get_netpoint(), e.netpoint_by_name("routerA"),
- e.netpoint_by_name("routerB"), std::vector<sg4::Link*>{link});
+ e.netpoint_by_name("routerB"), {sg4::LinkInRoute(link)});
std::vector<sg4::Host*> host_list = e.get_all_hosts();
/* create the sender actor running on first host */