static int sender(
int argc,
char *
argv[])
{
xbt_assert(argc==7,
"The sender function expects 6 arguments from the XML deployment file");
long receivers_count =
xbt_str_parse_int(argv[4],
"Invalid amount of receivers: %s");
XBT_INFO(
"sleep_start_time : %f , sleep_test_time : %f", sleep_start_time, sleep_test_time);
for (int i = 0; i < number_of_tasks; i++) {
char mailbox[80];
char taskname[80];
snprintf(mailbox,79, "receiver-%ld", i % receivers_count);
snprintf(taskname,79, "Task_%d", i);
XBT_INFO(
"Send to receiver-%ld Task_%d", i % receivers_count, i);
if (sleep_test_time > 0) {
}
} else {
}
}
for (int i = 0; i < receivers_count; i++) {
char mailbox[80];
snprintf(mailbox,79, "receiver-%ld", i % receivers_count);
XBT_INFO(
"Send to receiver-%ld finalize", i % receivers_count);
if (sleep_test_time > 0) {
}
} else {
}
}
return 0;
}
static int receiver(int argc, char *argv[])
{
xbt_assert(argc==4,
"The relay_runner function does not accept any parameter from the XML deployment file");
XBT_INFO(
"sleep_start_time : %f , sleep_test_time : %f", sleep_start_time, sleep_test_time);
char mailbox[80];
snprintf(mailbox,79, "receiver-%d", id);
while (1) {
if (sleep_test_time > 0) {
}
} else {
}
break;
}
}
return 0;
}
int main(
int argc,
char *argv[])
{
xbt_assert(argc > 2,
"Usage: %s platform_file deployment_file\n" "\tExample: %s msg_platform.xml msg_deployment.xml\n", argv[0], argv[0]);
}