XBT_LOG_NEW_DEFAULT_CATEGORY(async_wait, "Messages specific for this example");
-/* Main function of the Sender process */
+/* Main function of the Sender actor */
static void sender(int argc, char* argv[])
{
xbt_assert(argc == 5, "The sender function expects 4 arguments from the XML deployment file");
}
}
- sg_comm_t comm = sg_mailbox_put_async(mailbox, xbt_strdup("finalize"), 0);
XBT_INFO("Send 'finalize' to 'receiver'");
-
- if (sleep_test_time > 0) {
- while (sg_comm_test(comm) == 0) {
- sg_actor_sleep_for(sleep_test_time);
- }
- } else {
- sg_comm_wait(comm);
- }
+ sg_mailbox_put(mailbox, xbt_strdup("finalize"), 0);
}
-/* Receiver process expects 3 arguments: */
+/* Receiver actor expects 3 arguments: */
static void receiver(int argc, char* argv[])
{
xbt_assert(argc == 3, "The relay_runner function does not accept any parameter from the XML deployment file");