X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/71d215251ec3eeb3e4192c0e14ec6dea8fd97007..2092a7784bc5241f42fdb17432b6b5b393b9b33d:/examples/s4u/platform-failures/s4u-platform-failures.cpp diff --git a/examples/s4u/platform-failures/s4u-platform-failures.cpp b/examples/s4u/platform-failures/s4u-platform-failures.cpp index 22c4d24280..facd5db2ca 100644 --- a/examples/s4u/platform-failures/s4u-platform-failures.cpp +++ b/examples/s4u/platform-failures/s4u-platform-failures.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2019. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -27,21 +27,16 @@ static int master(int argc, char* argv[]) XBT_INFO("Send a message to %s", mailbox->get_cname()); mailbox->put(payload, comm_size, 10.0); XBT_INFO("Send to %s completed", mailbox->get_cname()); + } catch (simgrid::HostFailureException& e) { + XBT_INFO("Gloups. The cpu on which I'm running just turned off!. See you!"); + return -1; + } catch (simgrid::TimeoutError& e) { + delete payload; + XBT_INFO("Mmh. Got timeouted while speaking to '%s'. Nevermind. Let's keep going!", mailbox->get_cname()); } catch (xbt_ex& e) { - switch (e.category) { - case host_error: - XBT_INFO("Gloups. The cpu on which I'm running just turned off!. See you!"); - return -1; - break; - case network_error: - XBT_INFO("Mmh. Something went wrong with '%s'. Nevermind. Let's keep going!", mailbox->get_cname()); - break; - case timeout_error: - XBT_INFO("Mmh. Got timeouted while speaking to '%s'. Nevermind. Let's keep going!", mailbox->get_cname()); - break; - default: - xbt_die("Unexpected behavior"); - } + if (e.category != network_error) + xbt_die("Unexpected behavior"); + XBT_INFO("Mmh. Something went wrong with '%s'. Nevermind. Let's keep going!", mailbox->get_cname()); delete payload; } } @@ -53,21 +48,18 @@ static int master(int argc, char* argv[]) double* payload = new double(-1.0); try { mailbox->put(payload, 0, 1.0); + } catch (simgrid::HostFailureException& e) { + delete payload; + XBT_INFO("Gloups. The cpu on which I'm running just turned off!. See you!"); + return -1; + } catch (simgrid::TimeoutError& e) { + delete payload; + XBT_INFO("Mmh. Got timeouted while speaking to '%s'. Nevermind. Let's keep going!", mailbox->get_cname()); } catch (xbt_ex& e) { delete payload; - switch (e.category) { - case host_error: - XBT_INFO("Gloups. The cpu on which I'm running just turned off!. See you!"); - break; - case network_error: - XBT_INFO("Mmh. Something went wrong with '%s'. Nevermind. Let's keep going!", mailbox->get_cname()); - break; - case timeout_error: - XBT_INFO("Mmh. Got timeouted while speaking to '%s'. Nevermind. Let's keep going!", mailbox->get_cname()); - break; - default: - xbt_die("Unexpected behavior"); - } + if (e.category != network_error) + xbt_die("Unexpected behavior"); + XBT_INFO("Mmh. Something went wrong with '%s'. Nevermind. Let's keep going!", mailbox->get_cname()); } } @@ -86,39 +78,26 @@ static int worker(int argc, char* argv[]) try { XBT_INFO("Waiting a message on %s", mailbox->get_cname()); payload = static_cast(mailbox->get()); - comp_size = *payload; xbt_assert(payload != nullptr, "mailbox->get() failed"); + comp_size = *payload; if (comp_size < 0) { /* - Exit when -1.0 is received */ XBT_INFO("I'm done. See you!"); delete payload; break; } /* - Otherwise, process the task */ - try { - XBT_INFO("Start execution..."); - simgrid::s4u::this_actor::execute(comp_size); - XBT_INFO("Execution complete."); - delete payload; - } catch (xbt_ex& e) { - if (e.category == host_error) { - XBT_INFO("Gloups. The cpu on which I'm running just turned off!. See you!"); - delete payload; - return -1; - } else - xbt_die("Unexpected behavior"); - } + XBT_INFO("Start execution..."); + simgrid::s4u::this_actor::execute(comp_size); + XBT_INFO("Execution complete."); + delete payload; + } catch (simgrid::HostFailureException& e) { + XBT_INFO("Gloups. The cpu on which I'm running just turned off!. See you!"); + delete payload; + return -1; } catch (xbt_ex& e) { - switch (e.category) { - case host_error: - XBT_INFO("Gloups. The cpu on which I'm running just turned off!. See you!"); - delete payload; - return -1; - case network_error: - XBT_INFO("Mmh. Something went wrong. Nevermind. Let's keep going!"); - break; - default: - xbt_die("Unexpected behavior"); - } + if (e.category != network_error) + xbt_die("Unexpected behavior. Category: %s", xbt_ex_catname(e.category)); + XBT_INFO("Mmh. Something went wrong. Nevermind. Let's keep going!"); } } return 0;