XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test,
"Messages specific for this msg example");
+/** @addtogroup MSG_examples
+ *
+ * - <b>msg/icomms/peer3.c</b>: demonstrates the @ref MSG_comm_waitany function
+ */
+
int sender(int argc, char *argv[]);
int receiver(int argc, char *argv[]);
sprintf(mailbox, "finalize");
msg_comm_t res_irecv;
- MSG_error_t res_wait;
+ _XBT_GNUC_UNUSED MSG_error_t res_wait;
for (i = 0; i < receivers_count; i++) {
task = NULL;
res_irecv = MSG_task_irecv(&(task), mailbox);
int tasks = atof(argv[2]);
m_task_t *task = xbt_new(m_task_t, tasks);
- int read;
+ _XBT_GNUC_UNUSED int read;
read = sscanf(argv[1], "%d", &id);
xbt_assert(read, "Invalid argument %s\n", argv[1]);
sprintf(mailbox, "receiver-%d", id);
/* Here we are waiting for the receiving of all communications */
m_task_t task_com;
while (!xbt_dynar_is_empty(comms)) {
- MSG_error_t err;
+ _XBT_GNUC_UNUSED MSG_error_t err;
xbt_dynar_remove_at(comms, MSG_comm_waitany(comms), &res_irecv);
task_com = MSG_comm_get_task(res_irecv);
MSG_comm_destroy(res_irecv);
/* MSG_config("workstation/model","KCCFLN05"); */
{ /* Simulation setting */
- MSG_set_channel_number(0);
MSG_create_environment(platform_file);
}
{ /* Application deployment */