A
lgorithmique
N
umérique
D
istribuée
Public GIT Repository
projects
/
simgrid.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
| inline |
side by side
further snake_case Actor (::this_actor remains)
[simgrid.git]
/
teshsuite
/
s4u
/
storage_client_server
/
storage_client_server.cpp
diff --git
a/teshsuite/s4u/storage_client_server/storage_client_server.cpp
b/teshsuite/s4u/storage_client_server/storage_client_server.cpp
index
a524e29
..
d3dd770
100644
(file)
--- a/
teshsuite/s4u/storage_client_server/storage_client_server.cpp
+++ b/
teshsuite/s4u/storage_client_server/storage_client_server.cpp
@@
-15,7
+15,7
@@
static void display_storage_properties(simgrid::s4u::Storage* storage)
{
std::map<std::string, std::string>* props = storage->getProperties();
if (not props->empty()) {
- XBT_INFO("\tProperties of mounted storage: %s", storage->get
C
name());
+ XBT_INFO("\tProperties of mounted storage: %s", storage->get
_c
name());
for (auto const& elm : *props) {
XBT_INFO(" %s->%s", elm.first.c_str(), elm.second.c_str());
@@
-30,7
+30,7
@@
static sg_size_t write_local_file(const std::string& dest, sg_size_t file_size)
simgrid::s4u::File file(dest, nullptr);
sg_size_t written = file.write(file_size);
XBT_INFO("%llu bytes on %llu bytes have been written by %s on /sd1", written, file_size,
- simgrid::s4u::Actor::self()->get
C
name());
+ simgrid::s4u::Actor::self()->get
_c
name());
return written;
}
@@
-39,7
+39,7
@@
static sg_size_t read_local_file(const std::string& src)
simgrid::s4u::File file(src, nullptr);
sg_size_t file_size = file.size();
sg_size_t read = file.read(file_size);
- XBT_INFO("%s has read %llu on %s", simgrid::s4u::Actor::self()->get
C
name(), read, src.c_str());
+ XBT_INFO("%s has read %llu on %s", simgrid::s4u::Actor::self()->get
_c
name(), read, src.c_str());
return read;
}
@@
-50,7
+50,7
@@
static void hsm_put(const std::string& remote_host, const std::string& src, cons
sg_size_t read_size = read_local_file(src);
// Send file
- XBT_INFO("%s sends %llu to %s", simgrid::s4u::this_actor::get
C
name(), read_size, remote_host.c_str());
+ XBT_INFO("%s sends %llu to %s", simgrid::s4u::this_actor::get
_c
name(), read_size, remote_host.c_str());
std::string* payload = new std::string(simgrid::xbt::string_printf("%s %llu", dest.c_str(), read_size));
simgrid::s4u::MailboxPtr mailbox = simgrid::s4u::Mailbox::byName(remote_host);
mailbox->put(payload, static_cast<double>(read_size));
@@
-59,7
+59,7
@@
static void hsm_put(const std::string& remote_host, const std::string& src, cons
static void display_storage_content(simgrid::s4u::Storage* storage)
{
- XBT_INFO("Print the content of the storage element: %s", storage->get
C
name());
+ XBT_INFO("Print the content of the storage element: %s", storage->get
_c
name());
std::map<std::string, sg_size_t>* content = storage->extension<simgrid::s4u::FileSystemStorageExt>()->getContent();
if (not content->empty()) {
for (auto const& entry : *content)
@@
-94,25
+94,25
@@
static void dump_platform_storages()
std::vector<simgrid::s4u::Storage*> storages = simgrid::s4u::Engine::getInstance()->getAllStorages();
for (auto const& s : storages) {
- XBT_INFO("Storage %s is attached to %s", s->get
Cname(), s->getHost()->getC
name());
+ XBT_INFO("Storage %s is attached to %s", s->get
_cname(), s->getHost()->get_c
name());
s->setProperty("other usage", "gpfs");
}
}
static void storage_info(simgrid::s4u::Host* host)
{
- XBT_INFO("*** Storage info on %s ***", host->get
C
name());
+ XBT_INFO("*** Storage info on %s ***", host->get
_c
name());
for (auto const& elm : host->getMountedStorages()) {
const std::string& mount_name = elm.first;
simgrid::s4u::Storage* storage = elm.second;
- XBT_INFO("\tStorage name: %s, mount name: %s", storage->get
C
name(), mount_name.c_str());
+ XBT_INFO("\tStorage name: %s, mount name: %s", storage->get
_c
name(), mount_name.c_str());
XBT_INFO("\t\tFree size: %llu bytes", sg_storage_get_size_free(storage));
XBT_INFO("\t\tUsed size: %llu bytes", sg_storage_get_size_used(storage));
display_storage_properties(storage);
- dump_storage_by_name(storage->get
C
name());
+ dump_storage_by_name(storage->get
_c
name());
}
}
@@
-131,7
+131,7
@@
static void client()
static void server()
{
storage_info(simgrid::s4u::this_actor::getHost());
- simgrid::s4u::MailboxPtr mailbox = simgrid::s4u::Mailbox::byName(simgrid::s4u::this_actor::getHost()->get
C
name());
+ simgrid::s4u::MailboxPtr mailbox = simgrid::s4u::Mailbox::byName(simgrid::s4u::this_actor::getHost()->get
_c
name());
XBT_INFO("Server waiting for transfers ...");
while (1) {
@@
-159,8
+159,8
@@
int main(int argc, char* argv[])
xbt_assert(argc == 2, "Usage: %s platform_file\n", argv[0]);
e.loadPlatform(argv[1]);
- simgrid::s4u::Actor::create
Actor
("server", simgrid::s4u::Host::by_name("alice"), server);
- simgrid::s4u::Actor::create
Actor
("client", simgrid::s4u::Host::by_name("bob"), client);
+ simgrid::s4u::Actor::create("server", simgrid::s4u::Host::by_name("alice"), server);
+ simgrid::s4u::Actor::create("client", simgrid::s4u::Host::by_name("bob"), client);
e.run();