X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/db176451b42c9d524f82e6bb9951447e098dd492..7ef49c428ab0209965a09a36ab28b59789aaa4b5:/teshsuite/s4u/pid/pid.cpp diff --git a/teshsuite/s4u/pid/pid.cpp b/teshsuite/s4u/pid/pid.cpp index 4b45749d3e..86dcc627dc 100644 --- a/teshsuite/s4u/pid/pid.cpp +++ b/teshsuite/s4u/pid/pid.cpp @@ -1,5 +1,4 @@ -/* Copyright (c) 2009-2010, 2013-2015. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2009-2017. 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. */ @@ -8,10 +7,6 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_test, "Messages specific for this msg example"); -simgrid::s4u::MailboxPtr mailbox = simgrid::s4u::Mailbox::byName("mailbox"); -double comp_size = 1000; -double comm_size = 100000; - static int my_onexit(smx_process_exit_status_t status, int* pid) { XBT_INFO("Process \"%d\" killed.", *pid); @@ -20,11 +15,13 @@ static int my_onexit(smx_process_exit_status_t status, int* pid) static void sendpid() { - int pid = simgrid::s4u::this_actor::pid(); + simgrid::s4u::MailboxPtr mailbox = simgrid::s4u::Mailbox::byName("mailbox"); + int pid = simgrid::s4u::this_actor::getPid(); + double comm_size = 100000; simgrid::s4u::this_actor::onExit((int_f_pvoid_pvoid_t)my_onexit, &pid); XBT_INFO("Sending pid of \"%d\".", pid); - simgrid::s4u::this_actor::send(mailbox, &pid, comm_size); + mailbox->put(&pid, comm_size); XBT_INFO("Send of pid \"%d\" done.", pid); simgrid::s4u::this_actor::suspend(); @@ -32,8 +29,9 @@ static void sendpid() static void killall() { + simgrid::s4u::MailboxPtr mailbox = simgrid::s4u::Mailbox::byName("mailbox"); for (int i = 0; i < 3; i++) { - int* pid = static_cast(simgrid::s4u::this_actor::recv(mailbox)); + int* pid = static_cast(mailbox->get()); XBT_INFO("Killing process \"%d\".", *pid); simgrid::s4u::Actor::byPid(*pid)->kill(); } @@ -56,5 +54,6 @@ int main(int argc, char* argv[]) e->run(); + delete e; return 0; }