1 /* Copyright (c) 2010-2023. The SimGrid Team. All rights reserved. */
3 /* This program is free software; you can redistribute it and/or modify it
4 * under the terms of the license (GNU LGPL) which comes with this package. */
6 #include "simgrid/s4u.hpp"
7 namespace sg4 = simgrid::s4u;
9 XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_torus_multicpu, "Messages specific for this s4u example");
12 long msg_size = 1e6; /* message size in bytes */
13 std::vector<sg4::Host*> hosts_;
16 explicit Sender(const std::vector<sg4::Host*>& hosts) : hosts_{hosts} {}
17 void operator()() const
19 /* Vector in which we store all ongoing communications */
20 sg4::ActivitySet pending_comms;
21 /* Make a vector of the mailboxes to use */
22 std::vector<sg4::Mailbox*> mboxes;
24 std::string msg_content = "Hello, I'm alive and running on " + sg4::this_actor::get_host()->get_name();
25 for (const auto* host : hosts_) {
26 auto* payload = new std::string(msg_content);
27 /* Create a communication representing the ongoing communication, and store it in pending_comms */
28 auto* mbox = sg4::Mailbox::by_name(host->get_name());
29 mboxes.push_back(mbox);
30 sg4::CommPtr comm = mbox->put_async(payload, msg_size);
31 pending_comms.push(comm);
34 XBT_INFO("Done dispatching all messages");
36 /* Now that all message exchanges were initiated, wait for their completion in one single call */
37 pending_comms.wait_all();
39 XBT_INFO("Goodbye now!");
43 /* Receiver actor: wait for 1 message on the mailbox identified by the hostname */
46 void operator()() const
48 auto* mbox = sg4::Mailbox::by_name(sg4::this_actor::get_host()->get_name());
49 auto received = mbox->get_unique<std::string>();
50 XBT_INFO("I got a '%s'.", received->c_str());
52 const sg4::Disk* disk = sg4::Host::current()->get_disks().front();
53 sg_size_t write_size = disk->write(4e6);
54 XBT_INFO("Wrote %llu bytes on '%s'", write_size, disk->get_cname());
58 /*************************************************************************************************/
59 static sg4::NetZone* create_zone(const sg4::NetZone* root, const std::string& id)
61 auto* zone = sg4::create_floyd_zone(id);
62 zone->set_parent(root);
63 constexpr int n_host = 2;
65 auto* router = zone->create_router("router" + id);
66 for (int i = 0; i < n_host; i++) {
67 std::string hostname = id + "-cpu-" + std::to_string(i);
68 auto* host = zone->create_host(hostname, 1e9);
69 host->create_disk("disk-" + hostname, 1e9, 1e6);
70 const auto* link = zone->create_link("link-" + hostname, 1e9);
71 zone->add_route(host->get_netpoint(), router, nullptr, nullptr, {link});
76 /*************************************************************************************************/
78 int main(int argc, char* argv[])
80 sg4::Engine e(&argc, argv);
82 /* create platform: intentionally do not do the seal of objects */
83 auto* root = sg4::create_full_zone("root");
84 auto* zoneA = create_zone(root, "A");
85 auto* zoneB = create_zone(root, "B");
86 const auto* link = root->create_link("root-link", 1e10);
87 root->add_route(zoneA->get_netpoint(), zoneB->get_netpoint(), e.netpoint_by_name("routerA"),
88 e.netpoint_by_name("routerB"), {sg4::LinkInRoute(link)});
90 std::vector<sg4::Host*> host_list = e.get_all_hosts();
91 /* create the sender actor running on first host */
92 sg4::Actor::create("sender", host_list[0], Sender(host_list));
93 /* create receiver in every host */
94 for (auto* host : host_list) {
95 sg4::Actor::create("receiver-" + host->get_name(), host, Receiver());
98 /* runs the simulation */