Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Use new style logging macros.
[simgrid.git] / examples / msg / mc / centralized_mutex.c
index 7b68ace..bc2e329 100644 (file)
@@ -25,31 +25,31 @@ int coordinator(int argc, char *argv[])
     if (!strcmp(kind, "request")) {     // that's a request
       char *req = MSG_task_get_data(task);
       if (CS_used) {            // need to push the request in the vector
-        INFO0("CS already used. Queue the request");
+        XBT_INFO("CS already used. Queue the request");
         xbt_dynar_push(requests, &req);
       } else {                  // can serve it immediatly
-        INFO0("CS idle. Grant immediatly");
+        XBT_INFO("CS idle. Grant immediatly");
         m_task_t answer = MSG_task_create("grant", 0, 1000, NULL);
         MSG_task_send(answer, req);
         CS_used = 1;
       }
     } else {                    // that's a release. Check if someone was waiting for the lock
       if (xbt_dynar_length(requests) > 0) {
-        INFO1("CS release. Grant to queued requests (queue size: %lu)",
+        XBT_INFO("CS release. Grant to queued requests (queue size: %lu)",
               xbt_dynar_length(requests));
         char *req;
         xbt_dynar_pop(requests, &req);
         MSG_task_send(MSG_task_create("grant", 0, 1000, NULL), req);
         todo--;
       } else {                  // nobody wants it
-        INFO0("CS release. resource now idle");
+        XBT_INFO("CS release. resource now idle");
         CS_used = 0;
         todo--;
       }
     }
     MSG_task_destroy(task);
   }
-  INFO0("Received all releases, quit now");
+  XBT_INFO("Received all releases, quit now");
   return 0;
 }
 
@@ -61,20 +61,20 @@ int client(int argc, char *argv[])
   // request the CS 3 times, sleeping a bit in between
   int i;
   for (i = 0; i < CS_PER_PROCESS; i++) {
-    INFO0("Ask the request");
+    XBT_INFO("Ask the request");
     MSG_task_send(MSG_task_create("request", 0, 1000, my_mailbox),
                   "coordinator");
     // wait the answer
     m_task_t grant = NULL;
     MSG_task_receive(&grant, my_mailbox);
     MSG_task_destroy(grant);
-    INFO0("got the answer. Sleep a bit and release it");
+    XBT_INFO("got the answer. Sleep a bit and release it");
     MSG_process_sleep(1);
     MSG_task_send(MSG_task_create("release", 0, 1000, NULL),
                   "coordinator");
     MSG_process_sleep(my_pid);
   }
-  INFO0("Got all the CS I wanted, quit now");
+  XBT_INFO("Got all the CS I wanted, quit now");
   return 0;
 }