X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f85421b192d9ec5505120536e00df7252dad0cfe..a279c221114b93985c6aa249e71cc4141082b310:/examples/msg/mc/bugged3.c diff --git a/examples/msg/mc/bugged3.c b/examples/msg/mc/bugged3.c index fa81b63e43..5f949c0d45 100644 --- a/examples/msg/mc/bugged3.c +++ b/examples/msg/mc/bugged3.c @@ -1,3 +1,9 @@ +/* Copyright (c) 2010-2014. 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. */ + /**************** Shared buffer between asynchronous receives *****************/ /* Server process assumes that the data from the second communication comm2 */ /* will overwrite the one from the first communication, because of the order */ @@ -8,53 +14,54 @@ /******************************************************************************/ #include -#include +#include -XBT_LOG_NEW_DEFAULT_CATEGORY(bugged3,"this example"); +XBT_LOG_NEW_DEFAULT_CATEGORY(bugged3, "this example"); -int server(int argc,char *argv[]); -int client(int argc,char *argv[]); +int server(int argc, char *argv[]); +int client(int argc, char *argv[]); -int server(int argc,char *argv[]) +int server(int argc, char *argv[]) { - m_task_t task1; + msg_task_t task1; long val1; msg_comm_t comm1, comm2; - comm1 = MSG_task_irecv(&task1,"mymailbox1"); - comm2 = MSG_task_irecv(&task1,"mymailbox2"); + comm1 = MSG_task_irecv(&task1, "mymailbox1"); + comm2 = MSG_task_irecv(&task1, "mymailbox2"); MSG_comm_wait(comm1, -1); MSG_comm_wait(comm2, -1); - val1 = (long)MSG_task_get_data(task1); - INFO1("Received %lu", val1); - + val1 = (long) MSG_task_get_data(task1); + XBT_INFO("Received %lu", val1); + MC_assert(val1 == 2); - - INFO0("OK"); + + XBT_INFO("OK"); return 0; } -int client(int argc,char *argv[]) +int client(int argc, char *argv[]) { msg_comm_t comm; char *mbox; - m_task_t task1 = MSG_task_create("task", 0, 10000, (void *) atol(argv[1])); + msg_task_t task1 = + MSG_task_create("task", 0, 10000, (void *) atol(argv[1])); mbox = bprintf("mymailbox%s", argv[1]); - - INFO1("Send %d!", atoi(argv[1])); - comm = MSG_task_isend(task1,mbox); + + XBT_INFO("Send %d!", atoi(argv[1])); + comm = MSG_task_isend(task1, mbox); MSG_comm_wait(comm, -1); xbt_free(mbox); - + return 0; } -int main(int argc,char*argv[]) +int main(int argc, char *argv[]) { - MSG_global_init(&argc,argv); + MSG_init(&argc, argv); MSG_create_environment("platform.xml");