X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/05400c7ba9980ef221912b7cee424a8e0a263866..693f30b46244c152cd79cdf3ad35d4a79b866c9c:/examples/msg/icomms/peer.c diff --git a/examples/msg/icomms/peer.c b/examples/msg/icomms/peer.c index 501ec38462..445a7002e5 100644 --- a/examples/msg/icomms/peer.c +++ b/examples/msg/icomms/peer.c @@ -14,6 +14,17 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test, "Messages specific for this msg example"); +/** @addtogroup MSG_examples + * + * @section MSG_ex_icomms Asynchronous communications + * + * There is several examples of asynchronous communications coming in + * the archive. In addition to the fully documented example \ref + * MSG_ex_asynchronous_communications, there is several other + * examples in the archive: + * + * - msg/icomms/peer.c: basic example of async functions (@ref MSG_task_isend, @ref MSG_task_irecv, @ref MSG_comm_wait) + */ int sender(int argc, char *argv[]); int receiver(int argc, char *argv[]); @@ -86,7 +97,7 @@ int sender(int argc, char *argv[]) int receiver(int argc, char *argv[]) { m_task_t task = NULL; - MSG_error_t res; + _XBT_GNUC_UNUSED MSG_error_t res; int id = -1; char mailbox[80]; msg_comm_t res_irecv; @@ -95,9 +106,9 @@ int receiver(int argc, char *argv[]) XBT_INFO("sleep_start_time : %f , sleep_test_time : %f", sleep_start_time, sleep_test_time); - int read; + _XBT_GNUC_UNUSED int read; read = sscanf(argv[1], "%d", &id); - xbt_assert1(read, + xbt_assert(read, "Invalid argument %s\n", argv[1]); MSG_process_sleep(sleep_start_time); @@ -109,7 +120,7 @@ int receiver(int argc, char *argv[]) if (sleep_test_time == 0) { res = MSG_comm_wait(res_irecv, -1); - xbt_assert0(res == MSG_OK, "MSG_task_get failed"); + xbt_assert(res == MSG_OK, "MSG_task_get failed"); } else { while (MSG_comm_test(res_irecv) == 0) { MSG_process_sleep(sleep_test_time); @@ -141,7 +152,6 @@ MSG_error_t test_all(const char *platform_file, /* MSG_config("workstation/model","KCCFLN05"); */ { /* Simulation setting */ - MSG_set_channel_number(0); MSG_create_environment(platform_file); } { /* Application deployment */ @@ -161,7 +171,7 @@ int main(int argc, char *argv[]) { MSG_error_t res = MSG_OK; - MSG_global_init(&argc, argv); + MSG_init(&argc, argv); if (argc < 3) { printf("Usage: %s platform_file deployment_file\n", argv[0]); printf("example: %s msg_platform.xml msg_deployment.xml\n", argv[0]);