static int sender(
int argc,
char *
argv[])
{
xbt_assert(argc==5,
"This function expects 4 parameters from the XML deployment file");
long receivers_count =
xbt_str_parse_int(argv[4],
"Invalid amount of receivers: %s");
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);
}
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);
}
for (int i = 0; i < number_of_tasks + receivers_count; i++)
return 0;
}
static int receiver(int argc, char *argv[])
{
xbt_assert(argc==2,
"This function expects 1 parameter from the XML deployment file");
int id =
xbt_str_parse_int(argv[1],
"Any process of this example must have a numerical name, not %s");
char mailbox[80];
snprintf(mailbox,79, "receiver-%d", id);
while (1) {
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]);
}