Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Use new style logging macros.
authoragiersch <agiersch@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Thu, 17 Feb 2011 16:11:56 +0000 (16:11 +0000)
committeragiersch <agiersch@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Thu, 17 Feb 2011 16:11:56 +0000 (16:11 +0000)
git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@9653 48e7efb5-ca39-0410-a469-dd3cf9ba447f

217 files changed:
examples/amok/bandwidth/bandwidth.c
examples/amok/saturate/env.c
examples/amok/saturate/saturate.c
examples/gras/all2all/all2all.c
examples/gras/chrono/chrono.c
examples/gras/chrono/chrono2.c
examples/gras/console/ping_client.c
examples/gras/console/ping_common.c
examples/gras/console/ping_server.c
examples/gras/mmrpc/mmrpc.c
examples/gras/mmrpc/mmrpc_client.c
examples/gras/mmrpc/mmrpc_server.c
examples/gras/mutual_exclusion/simple_token/simple_token.c
examples/gras/p2p/can/can.c
examples/gras/p2p/can/can_tests.c
examples/gras/p2p/chord/chord.c
examples/gras/ping/ping_client.c
examples/gras/ping/ping_common.c
examples/gras/ping/ping_server.c
examples/gras/pmm/pmm.c
examples/gras/properties/properties.c
examples/gras/replay/replay.c
examples/gras/rpc/rpc.c
examples/gras/spawn/spawn.c
examples/gras/synchro/philosopher.c
examples/gras/timer/timer.c
examples/msg/actions/actions.c
examples/msg/alias/masterslave_forwarder_with_alias.c
examples/msg/chord/chord.c
examples/msg/gtnets/gtnets.c
examples/msg/icomms/peer.c
examples/msg/icomms/peer2.c
examples/msg/icomms/peer3.c
examples/msg/masterslave/masterslave_bypass.c
examples/msg/masterslave/masterslave_cluster.c
examples/msg/masterslave/masterslave_console.c
examples/msg/masterslave/masterslave_failure.c
examples/msg/masterslave/masterslave_forwarder.c
examples/msg/masterslave/masterslave_mailbox.c
examples/msg/mc/bugged1.c
examples/msg/mc/bugged2.c
examples/msg/mc/bugged3.c
examples/msg/mc/centralized_mutex.c
examples/msg/mc/random_test.c
examples/msg/migration/migration.c
examples/msg/parallel_contexts/pcontexts.c
examples/msg/parallel_contexts/pcontexts2.c
examples/msg/parallel_task/parallel_task.c
examples/msg/parallel_task/test_ptask.c
examples/msg/priority/priority.c
examples/msg/properties/msg_prop.c
examples/msg/sendrecv/sendrecv.c
examples/msg/suspend/suspend.c
examples/msg/token_ring/ring_call.c
examples/msg/trace/test_trace_integration.c
examples/msg/tracing/categories.c
examples/msg/tracing/ms.c
examples/msg/tracing/procmig.c
examples/msg/tracing/tasks.c
examples/msg/tracing/volume.c
examples/simdag/dax/dax_test.c
examples/simdag/dot/dot_test.c
examples/simdag/dot/dot_test2.c
examples/simdag/dot/simulate_dot.c
examples/simdag/metaxml/sd_meta.c
examples/simdag/properties/sd_prop.c
examples/simdag/scheduling/minmin_test.c
examples/simdag/sd_seq_access.c
examples/simdag/sd_test.c
examples/simdag/sd_test2.c
examples/simdag/sd_test_console.c
examples/simdag/simdag_trace.c
examples/xbt/sem_basic.c
examples/xbt/sem_sched.c
include/xbt/dynar.h
include/xbt/log.h
src/amok/Bandwidth/bandwidth.c
src/amok/Bandwidth/saturate.c
src/amok/PeerManagement/peermanagement.c
src/bindings/lua/lua_console.c
src/bindings/lua/simgrid_lua.c
src/bindings/ruby/rb_application_handler.c
src/bindings/ruby/rb_msg_task.c
src/bindings/ruby/simgrid_ruby.c
src/bindings/rubyDag/rb_simdag.c
src/gras/DataDesc/cbps.c
src/gras/DataDesc/datadesc.c
src/gras/DataDesc/ddt_convert.c
src/gras/DataDesc/ddt_create.c
src/gras/DataDesc/ddt_exchange.c
src/gras/DataDesc/ddt_parse.c
src/gras/DataDesc/ddt_parse.yy.c
src/gras/DataDesc/ddt_parse.yy.h
src/gras/DataDesc/ddt_parse.yy.l
src/gras/Msg/gras_msg_exchange.c
src/gras/Msg/gras_msg_listener.c
src/gras/Msg/gras_msg_mod.c
src/gras/Msg/gras_msg_types.c
src/gras/Msg/rl_msg.c
src/gras/Msg/rpc.c
src/gras/Msg/sg_msg.c
src/gras/Msg/timer.c
src/gras/Transport/rl_transport.c
src/gras/Transport/sg_transport.c
src/gras/Transport/transport.c
src/gras/Transport/transport_plugin_file.c
src/gras/Transport/transport_plugin_sg.c
src/gras/Transport/transport_plugin_tcp.c
src/gras/Virtu/gras_module.c
src/gras/Virtu/process.c
src/gras/Virtu/rl_process.c
src/gras/Virtu/sg_emul.c
src/gras/Virtu/sg_process.c
src/gras/gras.c
src/instr/instr_config.c
src/instr/instr_interface.c
src/instr/instr_msg_task.c
src/instr/instr_paje.c
src/instr/instr_paje_trace.c
src/instr/instr_resource_utilization.c
src/mc/mc_dpor.c
src/mc/mc_global.c
src/msg/gos.c
src/msg/m_process.c
src/msg/msg_actions.c
src/msg/msg_mailbox.c
src/msg/task.c
src/simdag/sd_daxloader.c
src/simdag/sd_dotloader.c
src/simdag/sd_global.c
src/simdag/sd_task.c
src/simdag/sd_workstation.c
src/simix/smx_context_raw.c
src/simix/smx_context_ruby.c
src/simix/smx_context_sysv.c
src/simix/smx_context_thread.c
src/simix/smx_deployment.c
src/simix/smx_environment.c
src/simix/smx_global.c
src/simix/smx_host.c
src/simix/smx_network.c
src/simix/smx_process.c
src/simix/smx_smurf.c
src/simix/smx_synchro.c
src/smpi/smpi_base.c
src/smpi/smpi_bench.c
src/smpi/smpi_coll.c
src/smpi/smpi_global.c
src/surf/cpu.c
src/surf/cpu_im.c
src/surf/cpu_ti.c
src/surf/fair_bottleneck.c
src/surf/gtnets/gtnets_interface.cc
src/surf/gtnets/gtnets_simulator.cc
src/surf/gtnets/gtnets_topology.cc
src/surf/lagrange.c
src/surf/maxmin.c
src/surf/network.c
src/surf/network_constant.c
src/surf/network_gtnets.c
src/surf/network_im.c
src/surf/surf.c
src/surf/surf_action.c
src/surf/surf_config.c
src/surf/surf_routing.c
src/surf/surfxml_parse.c
src/surf/trace_mgr.c
src/surf/workstation_ptask_L07.c
src/xbt/asserts.c
src/xbt/backtrace_linux.c
src/xbt/config.c
src/xbt/dict.c
src/xbt/dict_cursor.c
src/xbt/dict_multi.c
src/xbt/dynar.c
src/xbt/ex.c
src/xbt/fifo.c
src/xbt/graph.c
src/xbt/graphxml_parse.c
src/xbt/log.c
src/xbt/mallocator.c
src/xbt/parmap.c
src/xbt/set.c
src/xbt/xbt_main.c
src/xbt/xbt_matrix.c
src/xbt/xbt_os_thread.c
src/xbt/xbt_queue.c
src/xbt/xbt_replay_trace_reader.c
src/xbt/xbt_rl_synchro.c
src/xbt/xbt_strbuff.c
src/xbt/xbt_synchro.c
teshsuite/gras/datadesc/datadesc_structs.c
teshsuite/gras/datadesc/datadesc_usage.c
teshsuite/gras/datadesc/mk_datadesc_structs.pl
teshsuite/gras/msg_handle/msg_handle.c
teshsuite/gras/small_sleep/small_sleep.c
teshsuite/msg/get_sender.c
teshsuite/simdag/basic0.c
teshsuite/simdag/basic1.c
teshsuite/simdag/basic2.c
teshsuite/simdag/basic3.c
teshsuite/simdag/basic4.c
teshsuite/simdag/basic5.c
teshsuite/simdag/basic6.c
teshsuite/simdag/platforms/flatifier.c
teshsuite/xbt/log_large_test.c
teshsuite/xbt/parallel_log_crashtest.c
testsuite/surf/lmm_usage.c
testsuite/surf/surf_usage.c
testsuite/surf/surf_usage2.c
testsuite/surf/trace_usage.c
testsuite/xbt/graphxml_usage.c
testsuite/xbt/log_usage.c
tools/graphicator/graphicator.c
tools/gras/stub_generator.c
tools/tesh/run_context.c
tools/tesh/tesh.c

index 5ef8a16..0bcdde5 100644 (file)
@@ -33,7 +33,7 @@ int sensor(int argc, char *argv[])
   amok_pm_init();
 
   mysock = gras_socket_server_range(3000, 9999, 0, 0);
-  INFO1("Sensor starting (on port %d)", gras_os_myport());
+  XBT_INFO("Sensor starting (on port %d)", gras_os_myport());
   while (connection_try > 0 && master == NULL) {
     int connected = 0;
     TRY {
@@ -81,14 +81,14 @@ int maestro(int argc, char *argv[])
   amok_bw_init();
   amok_pm_init();
 
-  INFO0("Maestro starting");
+  XBT_INFO("Maestro starting");
   if (argc != 2) {
-    ERROR0("Usage: maestro port\n");
+    XBT_ERROR("Usage: maestro port\n");
     return 1;
   }
   mysock = gras_socket_server(atoi(argv[1]));
   group = amok_pm_group_new("bandwidth");
-  INFO0("Wait for peers for 5 sec");
+  XBT_INFO("Wait for peers for 5 sec");
   gras_msg_handleall(5);        /* friends, we're ready. Come and play */
 
   if (xbt_dynar_length(group) < 2) {
@@ -106,22 +106,22 @@ int maestro(int argc, char *argv[])
     h2 = h_temp;
   }
 
-  INFO2("Contact %s:%d", h1->name, h1->port);
+  XBT_INFO("Contact %s:%d", h1->name, h1->port);
   peer = gras_socket_client(h1->name, h1->port);
 
-  INFO0("Test the BW between me and one of the sensors");
+  XBT_INFO("Test the BW between me and one of the sensors");
   amok_bw_test(peer, buf_size, msg_size, msg_amount, min_duration, &sec,
                &bw);
-  INFO7
+  XBT_INFO
       ("Experience between me and %s:%d (initially %d msgs of %d bytes, maybe modified to fill the pipe at least %.1fs) took %f sec, achieving %f kb/s",
        h1->name, h1->port, msg_amount, msg_size, min_duration, sec,
        ((double) bw) / 1024.0);
 
-  INFO4("Test the BW between %s:%d and %s:%d", h1->name, h1->port,
+  XBT_INFO("Test the BW between %s:%d and %s:%d", h1->name, h1->port,
         h2->name, h2->port);
   amok_bw_request(h1->name, h1->port, h2->name, h2->port, buf_size,
                   msg_size, msg_amount, min_duration, &sec, &bw);
-  INFO6
+  XBT_INFO
       ("Experience between %s:%d and %s:%d took took %f sec, achieving %f kb/s",
        h1->name, h1->port, h2->name, h2->port, sec,
        ((double) bw) / 1024.0);
index 9309cba..02cd27a 100644 (file)
@@ -42,18 +42,18 @@ static void env_hosttohost_bw(int argc, char *argv[])
     xbt_host_t host = xbt_new(s_xbt_host_t, 1);
     host->name = strdup(argv[i]);
     host->port = atoi(argv[i + 1]);
-    INFO2("New sensor: %s:%d", host->name, host->port);
+    XBT_INFO("New sensor: %s:%d", host->name, host->port);
     xbt_dynar_push(hosts, &host);
   }
   nb_hosts = xbt_dynar_length(hosts);
 
-  INFO0(">>> start Test1: ENV end to end mesurements");
+  XBT_INFO(">>> start Test1: ENV end to end mesurements");
 
   xbt_dynar_foreach(hosts, i, h1) {
     peer = gras_socket_client(h1->name, h1->port);
     amok_bw_test(peer, buf_size, exp_size, msg_size, min_duration, &sec,
                  &bw);
-    INFO6
+    XBT_INFO
         ("Bandwidth between me and %s:%d (%d bytes in msgs of %d bytes) took %f sec, achieving %.3f kb/s",
          h1->name, h1->port, exp_size, msg_size, sec,
          ((double) bw) / 1024.0);
@@ -89,18 +89,18 @@ static void env_Pairwisehost_bw(int argc, char *argv[])
   /* wait to ensure that all server sockets are there before starting the experiment */
   gras_os_sleep(0.5);
 
-  INFO1(">>>>>< le maestro est: %s ", argv[0]);
+  XBT_INFO(">>>>>< le maestro est: %s ", argv[0]);
   /* Get the sensor location from argc/argv */
   for (i = 1; i < argc - 1; i += 2) {
     xbt_host_t host = xbt_new(s_xbt_host_t, 1);
     host->name = strdup(argv[i]);
     host->port = atoi(argv[i + 1]);
-    INFO2("New sensor: %s:%d", host->name, host->port);
+    XBT_INFO("New sensor: %s:%d", host->name, host->port);
     xbt_dynar_push(hosts, &host);
   }
   nb_hosts = xbt_dynar_length(hosts);
 
-  INFO0(">>> start Test2: ENV pairwise host bandwidth mesurements");
+  XBT_INFO(">>> start Test2: ENV pairwise host bandwidth mesurements");
   xbt_dynar_foreach(hosts, i, h1) {
 
     TRY {
@@ -119,7 +119,7 @@ static void env_Pairwisehost_bw(int argc, char *argv[])
       peer = gras_socket_client(h2->name, h2->port);
       amok_bw_test(peer, buf_size, exp_size, msg_size, min_duration, &sec,
                    &bw);
-      INFO6
+      XBT_INFO
           ("Bandwidth between me and %s // measurement between me and %s (%d bytes in msgs of %d bytes) took %f sec, achieving %.3f kb/s",
            h2->name, h1->name, exp_size, msg_size, sec,
            ((double) bw) / 1024.0);
index 1b77417..6bb54ae 100644 (file)
@@ -36,7 +36,7 @@ int sensor(int argc, char *argv[])
   amok_pm_init();
 
   mysock = gras_socket_server_range(3000, 9999, 0, 0);
-  INFO1("Sensor starting (on port %d)", gras_os_myport());
+  XBT_INFO("Sensor starting (on port %d)", gras_os_myport());
   gras_os_sleep(2);             /* let the master get ready */
   master = gras_socket_client_from_string(argv[1]);
 
@@ -73,7 +73,7 @@ static double XP(const char *bw1, const char *bw2,
   /* Test BW without saturation */
   amok_bw_request(bw1, 4000, bw2, 4000,
                   buf_size, msg_size, msg_amount, min_duration, &sec, &bw);
-  INFO4("BW(%s,%s) => %f sec, achieving %f Mb/s",
+  XBT_INFO("BW(%s,%s) => %f sec, achieving %f Mb/s",
         bw1, bw2, sec, (bw / 1024.0 / 1024.0));
 
 
@@ -84,16 +84,16 @@ static double XP(const char *bw1, const char *bw2,
   amok_bw_request(bw1, 4000, bw2, 4000,
                   buf_size, msg_size, msg_amount, min_duration, &sec_sat,
                   &bw_sat);
-  INFO6("BW(%s,%s//%s,%s) => %f sec, achieving %f Mb/s", bw1, bw2, sat1,
+  XBT_INFO("BW(%s,%s//%s,%s) => %f sec, achieving %f Mb/s", bw1, bw2, sat1,
         sat2, sec, bw / 1024.0 / 1024.0);
 
   amok_bw_saturate_stop(sat1, 4000, NULL, NULL);
 
   if (bw_sat / bw < 0.7) {
-    INFO0("THERE IS SOME INTERFERENCE !!!");
+    XBT_INFO("THERE IS SOME INTERFERENCE !!!");
   }
   if (bw / bw_sat < 0.7) {
-    INFO0("THERE IS SOME INTERFERENCE (and I'm an idiot) !!!");
+    XBT_INFO("THERE IS SOME INTERFERENCE (and I'm an idiot) !!!");
   }
   return bw_sat / bw;
 }
@@ -145,24 +145,24 @@ static void simple_saturation(int argc, char *argv[])
   xbt_dynar_get_cpy(peers, 1, &h2);
 
   /* Start saturation */
-  INFO4("Start saturation between %s:%d and %s:%d",
+  XBT_INFO("Start saturation between %s:%d and %s:%d",
         h1->name, h1->port, h2->name, h2->port);
 
   amok_bw_saturate_start(h1->name, h1->port, h2->name, h2->port, 0,     /* Be a nice boy, compute msg_size yourself */
                          30 /* 5 sec timeout */ );
 
   /* Stop it after a while */
-  INFO0("Have a rest");
+  XBT_INFO("Have a rest");
   gras_os_sleep(1);
   TRY {
-    INFO0("Stop the saturation");
+    XBT_INFO("Stop the saturation");
     amok_bw_saturate_stop(h1->name, h1->port, &duration, &bw);
   }
   CATCH(e) {
-    INFO0("Ooops, stoping the saturation raised an exception");
+    XBT_INFO("Ooops, stoping the saturation raised an exception");
     xbt_ex_free(e);
   }
-  INFO2("Saturation took %.2fsec, achieving %fb/s", duration, bw);
+  XBT_INFO("Saturation took %.2fsec, achieving %fb/s", duration, bw);
 
   /* Game is over, friends */
   amok_pm_group_shutdown("saturate");
@@ -198,7 +198,7 @@ static void full_fledged_saturation(int argc, char *argv[])
   gras_msg_handle(60);
   nb_peers = xbt_dynar_length(peers);
 
-  INFO0("Let's go for the bw_matrix");
+  XBT_INFO("Let's go for the bw_matrix");
 
   /* Do the test without saturation */
   begin = time(NULL);
@@ -206,7 +206,7 @@ static void full_fledged_saturation(int argc, char *argv[])
 
   bw = amok_bw_matrix(peers, buf_size, msg_size, msg_amount, min_duration);
 
-  INFO2("Did all BW tests in %ld sec (%.2f simulated(?) sec)",
+  XBT_INFO("Did all BW tests in %ld sec (%.2f simulated(?) sec)",
         (long int) (time(NULL) - begin), gras_os_time() - begin_simulated);
 
   /* Do the test with saturation */
@@ -236,14 +236,14 @@ static void full_fledged_saturation(int argc, char *argv[])
           if (i == l || j == l || k == l)
             continue;
 
-          VERB4("TEST %s %s // %s %s",
+          XBT_VERB("TEST %s %s // %s %s",
                 h1->name, h2->name, h3->name, h4->name);
           amok_bw_request(h3->name, h3->port, h4->name, h4->port,
                           buf_size, msg_size, msg_amount, min_duration,
                           NULL, &(bw_sat[k * nb_peers + l]));
 
           ratio = bw_sat[k * nb_peers + l] / bw[k * nb_peers + l];
-          INFO8("SATURATED BW XP(%s %s // %s %s) => %f (%f vs %f)%s",
+          XBT_INFO("SATURATED BW XP(%s %s // %s %s) => %f (%f vs %f)%s",
                 h1->name, h2->name, h3->name, h4->name,
                 ratio,
                 bw[k * nb_peers + l], bw_sat[k * nb_peers + l],
@@ -252,11 +252,11 @@ static void full_fledged_saturation(int argc, char *argv[])
       }
       amok_bw_saturate_stop(h1->name, h1->port, &time1, &bw1);
 
-      INFO2
+      XBT_INFO
           ("Did an iteration on saturation pair in %ld sec (%.2f simulated sec)",
            (long int) (time(NULL) - begin),
            gras_os_time() - begin_simulated);
-      INFO2
+      XBT_INFO
           ("the duration of the experiment >>>>> %.3f sec (%.3f bandwidth)",
            time1, bw1);
     }
index 8e5d607..db1504b 100644 (file)
@@ -48,7 +48,7 @@ int receiver(int argc, char *argv[])
   mysock = gras_socket_server(myport);
 
   /* Get the data */
-  INFO2("Listening on port %d (expecting %d messages)",
+  XBT_INFO("Listening on port %d (expecting %d messages)",
         gras_socket_my_port(mysock), todo);
   while (todo > 0) {
     gras_msg_wait(60 /* wait up to one minute */ ,
@@ -56,7 +56,7 @@ int receiver(int argc, char *argv[])
     todo--;
     free(data);
 
-    INFO3("Got Data from %s:%d (still %d to go)",
+    XBT_INFO("Got Data from %s:%d (still %d to go)",
           gras_socket_peer_name(expeditor),
           gras_socket_peer_port(expeditor), todo);
 
@@ -104,7 +104,7 @@ int sender(int argc, char *argv[])
   memset(data, 32, datasize);
   data[datasize] = '\0';
 
-  INFO0("Launch current node");
+  XBT_INFO("Launch current node");
 
   /* Register the known messages */
   gras_msgtype_declare("data", gras_datadesc_by_name("string"));
@@ -129,9 +129,9 @@ int sender(int argc, char *argv[])
     }
     gras_msg_send(peer, "data", &data);
     if (gras_if_SG()) {
-      INFO2("  Sent Data from %s to %s", gras_os_myname(), h->name);
+      XBT_INFO("  Sent Data from %s to %s", gras_os_myname(), h->name);
     } else {
-      INFO0("  Sent Data");
+      XBT_INFO("  Sent Data");
     }
 
     gras_socket_close(peer);
index 29eee56..8dba577 100644 (file)
@@ -31,7 +31,7 @@ int multiplier(int argc, char *argv[])
 
   start = now = gras_os_time();
 
-  INFO1("Begin matrix multiplication loop (time: %g)", start);
+  XBT_INFO("Begin matrix multiplication loop (time: %g)", start);
 
   for (l = 0; l < 4; l++) {
     now = gras_os_time();
@@ -50,15 +50,15 @@ int multiplier(int argc, char *argv[])
 
     GRAS_BENCH_ONCE_RUN_ONCE_END();
     now = gras_os_time() - now;
-    INFO2("Iteration %d : %g ", l, now);
+    XBT_INFO("Iteration %d : %g ", l, now);
   }
 
   now = gras_os_time() - start;
-  INFO2("End matrix multiplication loop (time: %g; Duration: %g)",
+  XBT_INFO("End matrix multiplication loop (time: %g; Duration: %g)",
         gras_os_time(), now);
 
   start = now = gras_os_time();
-  INFO1("Begin malloc loop (time: %g)", start);
+  XBT_INFO("Begin malloc loop (time: %g)", start);
   for (l = 0; l < 4; l++) {
     now = gras_os_time();
     GRAS_BENCH_ONCE_RUN_ONCE_BEGIN();
@@ -66,11 +66,11 @@ int multiplier(int argc, char *argv[])
     A = malloc(n * n * sizeof(double));
     GRAS_BENCH_ONCE_RUN_ONCE_END();
     now = gras_os_time() - now;
-    INFO2("Iteration %d : %g ", l, now);
+    XBT_INFO("Iteration %d : %g ", l, now);
   }
 
   start = now = gras_os_time();
-  INFO1("Begin integer incrementation loop (time: %g)", start);
+  XBT_INFO("Begin integer incrementation loop (time: %g)", start);
   for (l = 0; l < 4; l++) {
     GRAS_BENCH_ONCE_RUN_ONCE_BEGIN();
     j++;
index 5a0e1fd..a64936a 100644 (file)
@@ -35,8 +35,8 @@ static int mat_mult(int n)
 
   start = now = gras_os_time();
 
-  INFO1("Matrix size: %d", n);
-/*   INFO1("Before computation: %lg", start); */
+  XBT_INFO("Matrix size: %d", n);
+/*   XBT_INFO("Before computation: %lg", start); */
 
   for (l = 0; l < 40; l++) {
     now = gras_os_time();
@@ -53,11 +53,11 @@ static int mat_mult(int n)
                 1.0, A, n, B, n, 0.0, C, n);
     GRAS_BENCH_ONCE_RUN_ONCE_END();
     now = gras_os_time() - now;
-/*     INFO2("Iteration %d : %lg ", l, now); */
+/*     XBT_INFO("Iteration %d : %lg ", l, now); */
   }
 
   now = gras_os_time() - start;
-  INFO1("Duration: %lg ", now);
+  XBT_INFO("Duration: %lg ", now);
 
   free(A);
   free(B);
index 701499f..da1abfd 100644 (file)
@@ -30,7 +30,7 @@ int client(int argc, char *argv[])
     port = atoi(argv[2]);
   }
 
-  INFO2("Launch client (server on %s:%d)", host, port);
+  XBT_INFO("Launch client (server on %s:%d)", host, port);
 
   /* 3. Create a socket to speak to the server */
   while (!connected) {
@@ -47,14 +47,14 @@ int client(int argc, char *argv[])
     }
   }
 
-  INFO2("Connected to %s:%d.", host, port);
+  XBT_INFO("Connected to %s:%d.", host, port);
 
   /* 4. Register the messages.
      See, it doesn't have to be done completely at the beginning, only before use */
   ping_register_messages();
 
   /* 5. Keep the user informed of what's going on */
-  INFO2(">>>>>>>> Connected to server which is on %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Connected to server which is on %s:%d <<<<<<<<",
         gras_socket_peer_name(toserver), gras_socket_peer_port(toserver));
 
   /* 6. Prepare and send the ping message to the server */
@@ -66,7 +66,7 @@ int client(int argc, char *argv[])
     gras_socket_close(toserver);
     RETHROW0("Failed to send PING to server: %s");
   }
-  INFO3(">>>>>>>> Message PING(%d) sent to %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Message PING(%d) sent to %s:%d <<<<<<<<",
         ping,
         gras_socket_peer_name(toserver), gras_socket_peer_port(toserver));
 
@@ -80,12 +80,12 @@ int client(int argc, char *argv[])
   }
 
   /* 8. Keep the user informed of what's going on, again */
-  INFO3(">>>>>>>> Got PONG(%d) from %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Got PONG(%d) from %s:%d <<<<<<<<",
         pong, gras_socket_peer_name(from), gras_socket_peer_port(from));
 
   /* 9. Free the allocated resources, and shut GRAS down */
   gras_socket_close(toserver);
-  INFO0("Done.");
+  XBT_INFO("Done.");
   gras_exit();
   return 0;
 }                               /* end_of_client */
index 046f81e..41e6b80 100644 (file)
@@ -14,5 +14,5 @@ void ping_register_messages(void)
 {
   gras_msgtype_declare("ping", gras_datadesc_by_name("int"));
   gras_msgtype_declare("pong", gras_datadesc_by_name("int"));
-  INFO0("Messages registered");
+  XBT_INFO("Messages registered");
 }
index 03e0317..64819df 100644 (file)
@@ -31,7 +31,7 @@ static int server_cb_ping_handler(gras_msg_cb_ctx_t ctx, void *payload)
   globals->endcondition = 0;
 
   /* 3. Log which client connected */
-  INFO3(">>>>>>>> Got message PING(%d) from %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Got message PING(%d) from %s:%d <<<<<<<<",
         msg,
         gras_socket_peer_name(expeditor),
         gras_socket_peer_port(expeditor));
@@ -48,7 +48,7 @@ static int server_cb_ping_handler(gras_msg_cb_ctx_t ctx, void *payload)
     RETHROW0("Unable answer with PONG: %s");
   }
 
-  INFO0(">>>>>>>> Answered with PONG(4321) <<<<<<<<");
+  XBT_INFO(">>>>>>>> Answered with PONG(4321) <<<<<<<<");
 
   /* 7. Set the endcondition boolean to true (and make sure the server stops after receiving it). */
   globals->endcondition = 1;
@@ -72,7 +72,7 @@ int server(int argc, char *argv[])
     port = atoi(argv[1]);
   }
 
-  INFO1("Launch server (port=%d)", port);
+  XBT_INFO("Launch server (port=%d)", port);
 
   /* 3. Create my master socket */
   globals->sock = gras_socket_server(port);
@@ -85,7 +85,7 @@ int server(int argc, char *argv[])
   /* 5. Register my callback */
   gras_cb_register("ping", &server_cb_ping_handler);
 
-  INFO1(">>>>>>>> Listening on port %d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Listening on port %d <<<<<<<<",
         gras_socket_my_port(globals->sock));
   globals->endcondition = 0;
 
@@ -94,13 +94,13 @@ int server(int argc, char *argv[])
 
   /* 7. Housekeeping */
   if (!globals->endcondition)
-    WARN0
+    XBT_WARN
         ("An error occured, the endcondition was not set by the callback");
 
   /* 8. Free the allocated resources, and shut GRAS down */
   gras_socket_close(globals->sock);
   free(globals);
-  INFO0("Done.");
+  XBT_INFO("Done.");
   gras_exit();
 
   return 0;
index bfad502..c64f323 100644 (file)
@@ -68,7 +68,7 @@ int server(int argc, char *argv[])
   }
 
   /* 3. Create my master socket */
-  INFO1("Launch server (port=%d)", port);
+  XBT_INFO("Launch server (port=%d)", port);
   TRY {
     sock = gras_socket_server(port);
   }
@@ -89,7 +89,7 @@ int server(int argc, char *argv[])
   gras_socket_close(sock);
   gras_exit();
 
-  INFO0("Done.");
+  XBT_INFO("Done.");
   return 0;
 }                               /* end_of_server */
 
@@ -116,7 +116,7 @@ int client(int argc, char *argv[])
     port = atoi(argv[2]);
   }
 
-  INFO2("Launch client (server on %s:%d)", host, port);
+  XBT_INFO("Launch client (server on %s:%d)", host, port);
 
   /* 3. Wait for the server startup */
   gras_os_sleep(1);
@@ -128,14 +128,14 @@ int client(int argc, char *argv[])
   CATCH(e) {
     RETHROW0("Unable to connect to the server: %s");
   }
-  INFO2("Connected to %s:%d.", host, port);
+  XBT_INFO("Connected to %s:%d.", host, port);
 
 
   /* 5. Register the messages (before use) */
   mmrpc_register_messages();
 
   /* 6. Keep the user informed of what's going on */
-  INFO2(">>>>>>>> Connected to server which is on %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Connected to server which is on %s:%d <<<<<<<<",
         gras_socket_peer_name(toserver), gras_socket_peer_port(toserver));
 
   /* 7. Prepare and send the request to the server */
@@ -152,7 +152,7 @@ int client(int argc, char *argv[])
 
   xbt_matrix_free(request[0]);
 
-  INFO2(">>>>>>>> Request sent to %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Request sent to %s:%d <<<<<<<<",
         gras_socket_peer_name(toserver), gras_socket_peer_port(toserver));
 
   /* 8. Wait for the answer from the server, and deal with issues */
@@ -170,7 +170,7 @@ int client(int argc, char *argv[])
                   xbt_matrix_get_as(request[1], i, j, double));
 
   /* 9. Keep the user informed of what's going on, again */
-  INFO2(">>>>>>>> Got answer from %s:%d (values are right) <<<<<<<<",
+  XBT_INFO(">>>>>>>> Got answer from %s:%d (values are right) <<<<<<<<",
         gras_socket_peer_name(from), gras_socket_peer_port(from));
 
   /* 10. Free the allocated resources, and shut GRAS down */
@@ -178,6 +178,6 @@ int client(int argc, char *argv[])
   xbt_matrix_free(answer);
   gras_socket_close(toserver);
   gras_exit();
-  INFO0("Done.");
+  XBT_INFO("Done.");
   return 0;
 }                               /* end_of_client */
index 405c5c9..171369d 100644 (file)
@@ -35,7 +35,7 @@ int client(int argc, char *argv[])
     port = atoi(argv[2]);
   }
 
-  INFO2("Launch client (server on %s:%d)", host, port);
+  XBT_INFO("Launch client (server on %s:%d)", host, port);
 
   /* 3. Create a socket to speak to the server */
   while (!connected) {
@@ -50,14 +50,14 @@ int client(int argc, char *argv[])
       gras_os_sleep(0.05);
     }
   }
-  INFO2("Connected to %s:%d.", host, port);
+  XBT_INFO("Connected to %s:%d.", host, port);
 
 
   /* 4. Register the messages (before use) */
   mmrpc_register_messages();
 
   /* 5. Keep the user informed of what's going on */
-  INFO2(">>>>>>>> Connected to server which is on %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Connected to server which is on %s:%d <<<<<<<<",
         gras_socket_peer_name(toserver), gras_socket_peer_port(toserver));
 
   /* 6. Prepare and send the request to the server */
@@ -74,7 +74,7 @@ int client(int argc, char *argv[])
 
   xbt_matrix_free(request[0]);
 
-  INFO2(">>>>>>>> Request sent to %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Request sent to %s:%d <<<<<<<<",
         gras_socket_peer_name(toserver), gras_socket_peer_port(toserver));
 
   /* 7. Wait for the answer from the server, and deal with issues */
@@ -92,7 +92,7 @@ int client(int argc, char *argv[])
                   xbt_matrix_get_as(request[1], i, j, double));
 
   /* 8. Keep the user informed of what's going on, again */
-  INFO2(">>>>>>>> Got answer from %s:%d (values are right) <<<<<<<<",
+  XBT_INFO(">>>>>>>> Got answer from %s:%d (values are right) <<<<<<<<",
         gras_socket_peer_name(from), gras_socket_peer_port(from));
 
   /* 9. Free the allocated resources, and shut GRAS down */
index 32adb14..5072264 100644 (file)
@@ -53,7 +53,7 @@ int server(int argc, char *argv[])
   }
 
   /* 3. Create my master socket */
-  INFO1("Launch server (port=%d)", port);
+  XBT_INFO("Launch server (port=%d)", port);
   TRY {
     sock = gras_socket_server(port);
   }
index f045b71..686d7ec 100644 (file)
@@ -57,9 +57,9 @@ static int node_cb_stoken_handler(gras_msg_cb_ctx_t ctx, void *payload)
     supersteps = 1;
   }
   if (globals->create && (!(globals->remaining_loop % supersteps))) {
-    INFO1("Begin a new loop. Still to do: %d", globals->remaining_loop);
+    XBT_INFO("Begin a new loop. Still to do: %d", globals->remaining_loop);
   } else if (!(globals->remaining_loop % supersteps)) {
-    VERB3("Got token(%d) from %s remaining_loop=%d",
+    XBT_VERB("Got token(%d) from %s remaining_loop=%d",
           msg, gras_socket_peer_name(expeditor), globals->remaining_loop);
   }
 
@@ -67,7 +67,7 @@ static int node_cb_stoken_handler(gras_msg_cb_ctx_t ctx, void *payload)
   if (globals->remaining_loop > 0) {
     msg += 1;
 
-    DEBUG3("Send token(%d) to %s:%d", msg,
+    XBT_DEBUG("Send token(%d) to %s:%d", msg,
            gras_socket_peer_name(globals->tosuccessor),
            gras_socket_peer_port(globals->tosuccessor));
 
@@ -94,8 +94,8 @@ static int node_cb_stoken_handler(gras_msg_cb_ctx_t ctx, void *payload)
   /* 8. Repport the hop number to the user at the end */
   if (globals->remaining_loop == -1 && globals->create) {
     double elapsed = gras_os_time() - globals->start_time;
-    INFO1("Shut down the token-ring. There was %d hops.", msg);
-    VERB1("Elapsed time: %g", elapsed);
+    XBT_INFO("Shut down the token-ring. There was %d hops.", msg);
+    XBT_VERB("Elapsed time: %g", elapsed);
   }
 
   /* 9. Tell GRAS that we consummed this message */
@@ -134,7 +134,7 @@ int node(int argc, char *argv[])
   globals->tosuccessor = NULL;
 
   if (!gras_os_getpid() % 100 || gras_if_RL())
-    INFO3("Launch node listening on %d (successor on %s:%d)",
+    XBT_INFO("Launch node listening on %d (successor on %s:%d)",
           myport, host, peerport);
 
   /* 4. Register the known messages.  */
@@ -145,7 +145,7 @@ int node(int argc, char *argv[])
   gras_os_sleep(1.0);           /* Make sure all server sockets are created */
 
   /* 6. Create socket to the successor on the ring */
-  DEBUG2("Connect to my successor on %s:%d", host, peerport);
+  XBT_DEBUG("Connect to my successor on %s:%d", host, peerport);
 
   globals->tosuccessor = gras_socket_client(host, peerport);
 
@@ -165,7 +165,7 @@ int node(int argc, char *argv[])
 
     globals->remaining_loop = NBLOOPS - 1;
 
-    INFO3("Create the token (with value %d) and send it to %s:%d",
+    XBT_INFO("Create the token (with value %d) and send it to %s:%d",
           token, host, peerport);
 
     TRY {
@@ -179,7 +179,7 @@ int node(int argc, char *argv[])
   while (globals->remaining_loop > (globals->create ? -1 : 0)) {
     gras_msg_handle(-1);
 
-    DEBUG1("looping (remaining_loop=%d)", globals->remaining_loop);
+    XBT_DEBUG("looping (remaining_loop=%d)", globals->remaining_loop);
   }
 
   gras_os_sleep(1.0);           /* FIXME: if the sender quited, receive fail */
index 4c359f0..4fafde0 100644 (file)
@@ -54,7 +54,7 @@ static void forward_get_suc(get_suc_t msg, char host[1024], int port)
 {
   gras_socket_t temp_sock = NULL;
   xbt_ex_t e;                   // the error variable used in TRY.. CATCH tokens.
-  //INFO2("Transmiting message to %s:%d",host,port);      
+  //XBT_INFO("Transmiting message to %s:%d",host,port);
   TRY {
     temp_sock = gras_socket_client(host, port);
   } CATCH(e) {
@@ -65,7 +65,7 @@ static void forward_get_suc(get_suc_t msg, char host[1024], int port)
   } CATCH(e) {
     RETHROW0("Unable to send!: %s");
   }
-  INFO3("Forwarding a get_successor message to %s for (%d;%d)", host,
+  XBT_INFO("Forwarding a get_successor message to %s for (%d;%d)", host,
         msg.xId, msg.yId);
   gras_socket_close(temp_sock);
 }
@@ -78,9 +78,9 @@ static int node_get_suc_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
   xbt_ex_t e;                   // the error variable used in TRY.. CATCH tokens.
   node_data_t *globals = (node_data_t *) gras_userdata_get();
   gras_socket_t temp_sock = NULL;
-  INFO3("Received a get_successor message from %s for (%d;%d)",
+  XBT_INFO("Received a get_successor message from %s for (%d;%d)",
         gras_socket_peer_name(expeditor), incoming->xId, incoming->yId);
-  //INFO4("My area is [%d;%d;%d;%d]",globals->x1,globals->x2,globals->y1,globals->y2);
+  //XBT_INFO("My area is [%d;%d;%d;%d]",globals->x1,globals->x2,globals->y1,globals->y2);
   if (incoming->xId < globals->x1)      // test if the message must be forwarded to a neighbour.
     forward_get_suc(*incoming, globals->west_host, globals->west_port);
   else if (incoming->xId > globals->x2)
@@ -92,7 +92,7 @@ static int node_get_suc_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
   else {                        // if the message must not be forwarded, then the area is splitted in half and one half is assignated to the new node.
     rep_suc_t outgoing;
     int validate = 0;
-    INFO4
+    XBT_INFO
         ("Spliting my area between me (%d;%d) and the inserting node (%d;%d)!",
          globals->xId, globals->yId, incoming->xId, incoming->yId);
     if ((globals->x2 - globals->x1) > (globals->y2 - globals->y1)) {    // the height of the area is smaller than its width.
@@ -173,7 +173,7 @@ static int node_get_suc_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
       }
     }
     if (validate == 1) {        // the area for the new node has been defined, then send theses informations to the new node.
-      INFO2("Sending environment informations to node %s:%d",
+      XBT_INFO("Sending environment informations to node %s:%d",
             incoming->host, incoming->port);
 
       TRY {
@@ -185,7 +185,7 @@ static int node_get_suc_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
       }
       TRY {
         gras_msg_send(temp_sock, "can_rep_suc", &outgoing);
-        INFO0("Environment informations sent!");
+        XBT_INFO("Environment informations sent!");
       }
       CATCH(e) {
         RETHROW2("%s:Timeout sending environment informations to %s: %s",
@@ -193,7 +193,7 @@ static int node_get_suc_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
       }
       gras_socket_close(temp_sock);
     } else                      // we have a problem!
-      INFO0("An error occurded!!!!!!!!!!!!!");
+      XBT_INFO("An error occurded!!!!!!!!!!!!!");
 
   }
   gras_socket_close(expeditor); // spare
@@ -201,9 +201,9 @@ static int node_get_suc_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
     gras_msg_handle(10000.0);   // wait a bit in case of someone want to ask me for something.
   }
   CATCH(e) {
-    INFO4("My area is [%d;%d;%d;%d]", globals->x1, globals->x2,
+    XBT_INFO("My area is [%d;%d;%d;%d]", globals->x1, globals->x2,
           globals->y1, globals->y2);
-    //INFO0("Closing node, all has been done!");
+    //XBT_INFO("Closing node, all has been done!");
   }
   return 0;
 }
@@ -223,7 +223,7 @@ int node(int argc, char **argv)
   get_suc_t get_suc_msg;        // building the "get_suc" message.
   gras_socket_t temp_sock2 = NULL;
 
-  INFO0("Starting");
+  XBT_INFO("Starting");
 
   /* 1. Init the GRAS infrastructure and declare my globals */
   gras_init(&argc, argv);
@@ -239,14 +239,14 @@ int node(int argc, char **argv)
   globals->version = 0;         // node version (used for fun)
 
   /* 2. Inserting the Node */
-  INFO2("Inserting node %s:%d", globals->host, globals->port);
+  XBT_INFO("Inserting node %s:%d", globals->host, globals->port);
   if (argc == 4) {              // the node is a server, then he has the whole area.
     globals->x1 = 0;
     globals->x2 = 1000;
     globals->y1 = 0;
     globals->y2 = 1000;
   } else {                      // asking for an area.
-    INFO1("Contacting %s so as to request for an area", argv[4]);
+    XBT_INFO("Contacting %s so as to request for an area", argv[4]);
 
     TRY {
       temp_sock = gras_socket_client(argv[4], atoi(argv[5]));
@@ -272,7 +272,7 @@ int node(int argc, char **argv)
 
 
     TRY {                       // waiting for a reply.
-      INFO0("Waiting for reply!");
+      XBT_INFO("Waiting for reply!");
       gras_msg_wait(6000, "can_rep_suc", &temp_sock2, &rep_suc_msg);
     }
     CATCH(e) {
@@ -295,7 +295,7 @@ int node(int argc, char **argv)
 
     gras_socket_close(temp_sock);       // spare
   }
-  INFO2("Node %s:%d inserted", globals->host, globals->port);
+  XBT_INFO("Node %s:%d inserted", globals->host, globals->port);
 
   // associating messages to handlers.
   register_messages();
@@ -306,9 +306,9 @@ int node(int argc, char **argv)
     gras_msg_handle(10000.0);   // waiting.. in case of someone has something to say.
   }
   CATCH(e) {
-    INFO4("My area is [%d;%d;%d;%d]", globals->x1, globals->x2,
+    XBT_INFO("My area is [%d;%d;%d;%d]", globals->x1, globals->x2,
           globals->y1, globals->y2);
-    //INFO0("Closing node, all has been done!");
+    //XBT_INFO("Closing node, all has been done!");
   }
 
   gras_socket_close(globals->sock);     // spare.
index 8742379..6997622 100644 (file)
@@ -67,7 +67,7 @@ static int send_nuke(nuke_t * msg, int xId, int yId)
 
   if (xId >= globals->x1 && xId <= globals->x2 && yId >= globals->y1
       && yId <= globals->y2) {
-    INFO0("Nuclear launch missed");
+    XBT_INFO("Nuclear launch missed");
     return 0;
   } else {
     char host[1024];
@@ -98,7 +98,7 @@ static int send_nuke(nuke_t * msg, int xId, int yId)
     CATCH(e) {
       RETHROW0("Unable to connect the nuke!: %s");
     }
-    //INFO4("%s ON %s %d %d <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<",globals->host,host,xId,yId);
+    //XBT_INFO("%s ON %s %d %d <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<",globals->host,host,xId,yId);
     TRY {
       gras_msg_send(temp_sock, "can_nuke", msg);
     }
@@ -106,7 +106,7 @@ static int send_nuke(nuke_t * msg, int xId, int yId)
       RETHROW0("Unable to send the nuke!: %s");
     }
     gras_socket_close(temp_sock);
-    INFO4("Nuke launched by %s to %s for (%d;%d)", globals->host, host,
+    XBT_INFO("Nuke launched by %s to %s for (%d;%d)", globals->host, host,
           msg->xId, msg->yId);
     return 1;
   }
@@ -127,7 +127,7 @@ static int node_nuke_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
 
 
   if (incoming->xId == -1) {    // i must start the War
-    INFO2("%s:%d declare the WAR!!!!!!!!!!!!!!!!!", globals->host,
+    XBT_INFO("%s:%d declare the WAR!!!!!!!!!!!!!!!!!", globals->host,
           globals->port);
     srand((unsigned int) time((time_t *) NULL));
 
@@ -139,13 +139,13 @@ static int node_nuke_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
 
   } else if (incoming->xId >= globals->x1 && incoming->xId <= globals->x2 && incoming->yId >= globals->y1 && incoming->yId <= globals->y2) {    // the nuke crash on my area..
     if (globals->version == incoming->version)  // ..but i'm dead.
-      INFO0("I'm already dead :p");
+      XBT_INFO("I'm already dead :p");
     else if ((incoming->xId - globals->xId) / 60 == 0 && (incoming->yId - globals->yId) / 60 == 0) {    // ..and it's on me, so i die :X.
       globals->version = incoming->version;
-      INFO2("Euuuaarrrgghhhh...   %s killed %s !!!!!!!!!!!!!!!!!",
+      XBT_INFO("Euuuaarrrgghhhh...   %s killed %s !!!!!!!!!!!!!!!!!",
             incoming->host, globals->host);
     } else {                    // and it miss me, i angry and i send my own nuke!
-      INFO1("%s was missed, and counteract!", globals->host);
+      XBT_INFO("%s was missed, and counteract!", globals->host);
       /*int x1=(int)(1000.0*rand()/(RAND_MAX+1.0));
          int y1=(int)(1000.0*rand()/(RAND_MAX+1.0));
          int x2=(int)(1000.0*rand()/(RAND_MAX+1.0));
@@ -199,7 +199,7 @@ static int node_nuke_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
     CATCH(e) {
       RETHROW0("Unable to send the nuke!: %s");
     }
-    INFO4("Nuke re-aimed by %s to %s for (%d;%d)", globals->host, host,
+    XBT_INFO("Nuke re-aimed by %s to %s for (%d;%d)", globals->host, host,
           incoming->xId, incoming->yId);
     gras_socket_close(temp_sock);
   }
@@ -209,9 +209,9 @@ static int node_nuke_handler(gras_msg_cb_ctx_t ctx, void *payload_data)
     gras_msg_handle(10000.0);   // wait a bit, in case of..
   }
   CATCH(e) {
-    INFO4("My area is [%d;%d;%d;%d]", globals->x1, globals->x2,
+    XBT_INFO("My area is [%d;%d;%d;%d]", globals->x1, globals->x2,
           globals->y1, globals->y2);
-    //INFO0("Closing node, all has been done!");
+    //XBT_INFO("Closing node, all has been done!");
   }
   return 0;
 }
index f70b5ce..6538b1d 100644 (file)
@@ -103,7 +103,7 @@ int node(int argc, char **argv);
 
   node_data_t *globals=(node_data_t*)gras_userdata_get();
 
-  INFO4(">>> %d : received %d message from %s to %d <<<",globals->id,pbio_i.type,gras_socket_peer_name(expeditor),pbio_i.dest);
+  XBT_INFO(">>> %d : received %d message from %s to %d <<<",globals->id,pbio_i.type,gras_socket_peer_name(expeditor),pbio_i.dest);
 
 
 
@@ -117,7 +117,7 @@ static int node_cb_get_suc_handler(gras_msg_cb_ctx_t ctx,
   get_suc_t incoming = *(get_suc_t *) payload_data;
   rep_suc_t outgoing;
   node_data_t *globals = (node_data_t *) gras_userdata_get();
-  INFO2("Received a get_successor message from %s for %d",
+  XBT_INFO("Received a get_successor message from %s for %d",
         gras_socket_peer_name(expeditor), incoming.id);
   if ((globals->id == globals->finger[0].id) ||
       (incoming.id > globals->id
@@ -125,7 +125,7 @@ static int node_cb_get_suc_handler(gras_msg_cb_ctx_t ctx,
     outgoing.id = globals->finger[0].id;
     snprintf(outgoing.host, 1024, globals->finger[0].host);
     outgoing.port = globals->finger[0].port;
-    INFO0("My successor is his successor!");
+    XBT_INFO("My successor is his successor!");
   } else {
     gras_socket_t temp_sock;
     int contact = closest_preceding_node(incoming.id);
@@ -133,7 +133,7 @@ static int node_cb_get_suc_handler(gras_msg_cb_ctx_t ctx,
       outgoing.id = globals->finger[0].id;
       snprintf(outgoing.host, 1024, globals->finger[0].host);
       outgoing.port = globals->finger[0].port;
-      INFO0("My successor is his successor!");
+      XBT_INFO("My successor is his successor!");
     } else {
       get_suc_t asking;
       asking.id = incoming.id;
@@ -156,7 +156,7 @@ static int node_cb_get_suc_handler(gras_msg_cb_ctx_t ctx,
 
   TRY {
     gras_msg_send(expeditor, "chord_rep_suc", &outgoing);
-    INFO0("Successor information sent!");
+    XBT_INFO("Successor information sent!");
   }
   CATCH(e) {
     RETHROW2("%s:Timeout sending successor information to %s: %s",
@@ -186,14 +186,14 @@ static int node_cb_notify_handler(gras_msg_cb_ctx_t ctx,
   /*xbt_ex_t e; */
   notify_t incoming = *(notify_t *) payload_data;
   node_data_t *globals = (node_data_t *) gras_userdata_get();
-  INFO2("Received a notifying message from %s as %d",
+  XBT_INFO("Received a notifying message from %s as %d",
         gras_socket_peer_name(expeditor), incoming.id);
   if (globals->pre_id == -1 ||
       (incoming.id > globals->pre_id && incoming.id < globals->id)) {
     globals->pre_id = incoming.id;
     snprintf(globals->pre_host, 1024, incoming.host);
     globals->pre_port = incoming.port;
-    INFO0("Set as my new predecessor!");
+    XBT_INFO("Set as my new predecessor!");
   }
   return 0;
 }
@@ -222,7 +222,7 @@ static void fix_fingers()
   }
 
   TRY {
-    INFO0("Waiting for reply!");
+    XBT_INFO("Waiting for reply!");
     gras_msg_wait(6000, "chord_rep_suc", &temp_sock2, &rep_suc_msg);
   } CATCH(e) {
     RETHROW1("%s: Error waiting for successor:%s", globals->host);
@@ -230,7 +230,7 @@ static void fix_fingers()
   globals->finger[0].id = rep_suc_msg.id;
   snprintf(globals->finger[0].host, 1024, rep_suc_msg.host);
   globals->finger[0].port = rep_suc_msg.port;
-  INFO1("→ Finger %d fixed!", globals->next_to_fix);
+  XBT_INFO("→ Finger %d fixed!", globals->next_to_fix);
   gras_socket_close(temp_sock);
 
   globals->next_to_fix = (++globals->next_to_fix == globals->fingers) ?
@@ -322,15 +322,15 @@ int node(int argc, char **argv)
   register_messages();
 
   globals->finger = (finger_elem *) calloc(1, sizeof(finger_elem));
-  INFO2("Launching node %s:%d", globals->host, globals->port);
+  XBT_INFO("Launching node %s:%d", globals->host, globals->port);
   if (create) {
-    INFO0("→Creating ring");
+    XBT_INFO("→Creating ring");
     globals->finger[0].id = globals->id;
     snprintf(globals->finger[0].host, 1024, globals->host);
     globals->finger[0].port = globals->port;
   } else {
-    INFO2("→Known node %s:%d", other_host, other_port);
-    INFO0("→Contacting to determine successor");
+    XBT_INFO("→Known node %s:%d", other_host, other_port);
+    XBT_INFO("→Contacting to determine successor");
     TRY {
       temp_sock = gras_socket_client(other_host, other_port);
     }
@@ -348,7 +348,7 @@ int node(int argc, char **argv)
     }
 
     TRY {
-      INFO0("Waiting for reply!");
+      XBT_INFO("Waiting for reply!");
       gras_msg_wait(10., "chord_rep_suc", &temp_sock2, &rep_suc_msg);
     }
     CATCH(e) {
@@ -357,7 +357,7 @@ int node(int argc, char **argv)
     globals->finger[0].id = rep_suc_msg.id;
     snprintf(globals->finger[0].host, 1024, rep_suc_msg.host);
     globals->finger[0].port = rep_suc_msg.port;
-    INFO3("→Got successor : %d-%s:%d", globals->finger[0].id,
+    XBT_INFO("→Got successor : %d-%s:%d", globals->finger[0].id,
           globals->finger[0].host, globals->finger[0].port);
     gras_socket_close(temp_sock);
     TRY {
@@ -397,6 +397,6 @@ int node(int argc, char **argv)
   gras_socket_close(globals->sock);
   free(globals);
   gras_exit();
-  INFO0("Done");
+  XBT_INFO("Done");
   return (0);
 }
index 3d0796c..1c34881 100644 (file)
@@ -30,7 +30,7 @@ int client(int argc, char *argv[])
     port = atoi(argv[2]);
   }
 
-  INFO2("Launch client (server on %s:%d)", host, port);
+  XBT_INFO("Launch client (server on %s:%d)", host, port);
 
   /* 3. Create a socket to speak to the server */
   while (!connected) {
@@ -47,14 +47,14 @@ int client(int argc, char *argv[])
     }
   }
 
-  INFO2("Connected to %s:%d.", host, port);
+  XBT_INFO("Connected to %s:%d.", host, port);
 
   /* 4. Register the messages.
      See, it doesn't have to be done completely at the beginning, only before use */
   ping_register_messages();
 
   /* 5. Keep the user informed of what's going on */
-  INFO2(">>>>>>>> Connected to server which is on %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Connected to server which is on %s:%d <<<<<<<<",
         gras_socket_peer_name(toserver), gras_socket_peer_port(toserver));
 
   /* 6. Prepare and send the ping message to the server */
@@ -66,7 +66,7 @@ int client(int argc, char *argv[])
     gras_socket_close(toserver);
     RETHROW0("Failed to send PING to server: %s");
   }
-  INFO3(">>>>>>>> Message PING(%d) sent to %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Message PING(%d) sent to %s:%d <<<<<<<<",
         ping, gras_socket_peer_name(toserver), gras_socket_peer_port(toserver));
 
   /* 7. Wait for the answer from the server, and deal with issues */
@@ -79,12 +79,12 @@ int client(int argc, char *argv[])
   }
 
   /* 8. Keep the user informed of what's going on, again */
-  INFO3(">>>>>>>> Got PONG(%d) from %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Got PONG(%d) from %s:%d <<<<<<<<",
         pong, gras_socket_peer_name(from), gras_socket_peer_port(from));
 
   /* 9. Free the allocated resources, and shut GRAS down */
   gras_socket_close(toserver);
-  INFO0("Done.");
+  XBT_INFO("Done.");
   gras_exit();
   return 0;
 }                               /* end_of_client */
index 046f81e..41e6b80 100644 (file)
@@ -14,5 +14,5 @@ void ping_register_messages(void)
 {
   gras_msgtype_declare("ping", gras_datadesc_by_name("int"));
   gras_msgtype_declare("pong", gras_datadesc_by_name("int"));
-  INFO0("Messages registered");
+  XBT_INFO("Messages registered");
 }
index d75975a..d70e875 100644 (file)
@@ -31,7 +31,7 @@ static int server_cb_ping_handler(gras_msg_cb_ctx_t ctx, void *payload)
   globals->endcondition = 0;
 
   /* 3. Log which client connected */
-  INFO3(">>>>>>>> Got message PING(%d) from %s:%d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Got message PING(%d) from %s:%d <<<<<<<<",
         msg,
         gras_socket_peer_name(expeditor),
         gras_socket_peer_port(expeditor));
@@ -48,7 +48,7 @@ static int server_cb_ping_handler(gras_msg_cb_ctx_t ctx, void *payload)
     RETHROW0("Unable answer with PONG: %s");
   }
 
-  INFO0(">>>>>>>> Answered with PONG(4321) <<<<<<<<");
+  XBT_INFO(">>>>>>>> Answered with PONG(4321) <<<<<<<<");
 
   /* 7. Set the endcondition boolean to true (and make sure the server stops after receiving it). */
   globals->endcondition = 1;
@@ -72,7 +72,7 @@ int server(int argc, char *argv[])
     port = atoi(argv[1]);
   }
 
-  INFO1("Launch server (port=%d)", port);
+  XBT_INFO("Launch server (port=%d)", port);
 
   /* 3. Create my master socket */
   globals->sock = gras_socket_server(port);
@@ -85,7 +85,7 @@ int server(int argc, char *argv[])
   /* 5. Register my callback */
   gras_cb_register("ping", &server_cb_ping_handler);
 
-  INFO1(">>>>>>>> Listening on port %d <<<<<<<<",
+  XBT_INFO(">>>>>>>> Listening on port %d <<<<<<<<",
         gras_socket_my_port(globals->sock));
   globals->endcondition = 0;
 
@@ -94,13 +94,13 @@ int server(int argc, char *argv[])
 
   /* 7. Housekeeping */
   if (!globals->endcondition)
-    WARN0
+    XBT_WARN
         ("An error occured, the endcondition was not set by the callback");
 
   /* 8. Free the allocated resources, and shut GRAS down */
   gras_socket_close(globals->sock);
   free(globals);
-  INFO0("Done.");
+  XBT_INFO("Done.");
   gras_exit();
 
   return 0;
index 8205689..bb48e39 100644 (file)
@@ -113,14 +113,14 @@ int master(int argc, char *argv[])
   peers = amok_pm_group_new("pmm");
 
   /* friends, we're ready. Come and play */
-  INFO0("Wait for peers for 2 sec");
+  XBT_INFO("Wait for peers for 2 sec");
   gras_msg_handleall(2);
   while (xbt_dynar_length(peers) < SLAVE_COUNT) {
-    INFO2("Got only %ld pals (of %d). Wait 2 more seconds",
+    XBT_INFO("Got only %ld pals (of %d). Wait 2 more seconds",
         xbt_dynar_length(peers),SLAVE_COUNT);
     gras_msg_handleall(2);
   }
-  INFO1("Good. Got %ld pals", xbt_dynar_length(peers));
+  XBT_INFO("Good. Got %ld pals", xbt_dynar_length(peers));
 
   for (i = 0; i < xbt_dynar_length(peers) && i < SLAVE_COUNT; i++) {
     xbt_dynar_get_cpy(peers, i, &grid[i]);
@@ -135,7 +135,7 @@ int master(int argc, char *argv[])
     xbt_peer_t h;
 
     xbt_dynar_remove_at(peers, i, &h);
-    INFO2("Too much slaves. Killing %s:%d", h->name, h->port);
+    XBT_INFO("Too much slaves. Killing %s:%d", h->name, h->port);
     amok_pm_kill_hp(h->name, h->port);
     free(h);
   }
@@ -143,7 +143,7 @@ int master(int argc, char *argv[])
 
   /* Assign job to slaves */
   int row = 0, line = 0;
-  INFO0("XXXXXXXXXXXXXXXXXXXXXX begin Multiplication");
+  XBT_INFO("XXXXXXXXXXXXXXXXXXXXXX begin Multiplication");
   for (i = 0; i < SLAVE_COUNT; i++) {
     s_pmm_assignment_t assignment;
     int j, k;
@@ -196,7 +196,7 @@ int master(int argc, char *argv[])
   /* Retrieve the results */
   for (i = 0; i < SLAVE_COUNT; i++) {
     gras_msg_wait(6000, "result", &from, &result);
-    VERB2("%d slaves are done already. Waiting for %d", i + 1,
+    XBT_VERB("%d slaves are done already. Waiting for %d", i + 1,
           SLAVE_COUNT);
     xbt_matrix_copy_values(C, result.C, submatrix_size, submatrix_size,
                            submatrix_size * result.linepos,
@@ -206,14 +206,14 @@ int master(int argc, char *argv[])
   /*    end of gather   */
 
   if (xbt_matrix_double_is_seq(C))
-    INFO0("XXXXXXXXXXXXXXXXXXXXXX Ok, the result matches expectations");
+    XBT_INFO("XXXXXXXXXXXXXXXXXXXXXX Ok, the result matches expectations");
   else {
-    WARN0("the result seems wrong");
+    XBT_WARN("the result seems wrong");
     if (DATA_MATRIX_SIZE < 30) {
-      INFO0("The Result of Multiplication is :");
+      XBT_INFO("The Result of Multiplication is :");
       xbt_matrix_dump(C, "C:res", 0, xbt_matrix_dump_display_double);
     } else {
-      INFO1("Matrix size too big (%d>30) to be displayed here",
+      XBT_INFO("Matrix size too big (%d>30) to be displayed here",
             DATA_MATRIX_SIZE);
     }
   }
@@ -273,9 +273,9 @@ static int pmm_worker_cb(gras_msg_cb_ctx_t ctx, void *payload)
   mydataB = assignment.B;
 
   if (gras_if_RL())
-    INFO0("Receive my pos and assignment");
+    XBT_INFO("Receive my pos and assignment");
   else
-    INFO2("Receive my pos (%d,%d) and assignment", myline, myrow);
+    XBT_INFO("Receive my pos (%d,%d) and assignment", myline, myrow);
 
   /* Get my neighborhood from the assignment message (skipping myself) */
   for (i = 0; i < PROC_MATRIX_SIZE - 1; i++) {
@@ -295,10 +295,10 @@ static int pmm_worker_cb(gras_msg_cb_ctx_t ctx, void *payload)
 
     /* a line brodcast */
     if (myline == step) {
-      VERB2("LINE: step(%d) = Myline(%d). Broadcast my data.", step,
+      XBT_VERB("LINE: step(%d) = Myline(%d). Broadcast my data.", step,
             myline);
       for (l = 0; l < PROC_MATRIX_SIZE - 1; l++) {
-        VERB1("LINE:   Send to %s", gras_socket_peer_name(socket_row[l]));
+        XBT_VERB("LINE:   Send to %s", gras_socket_peer_name(socket_row[l]));
         gras_msg_send(socket_row[l], "dataB", &mydataB);
       }
 
@@ -314,15 +314,15 @@ static int pmm_worker_cb(gras_msg_cb_ctx_t ctx, void *payload)
       CATCH(e) {
         RETHROW0("Can't get a data message from line : %s");
       }
-      VERB3("LINE: step(%d) <> Myline(%d). Receive data from %s", step,
+      XBT_VERB("LINE: step(%d) <> Myline(%d). Receive data from %s", step,
             myline, gras_socket_peer_name(from));
     }
 
     /* a row brodcast */
     if (myrow == step) {
-      VERB2("ROW: step(%d)=myrow(%d). Broadcast my data.", step, myrow);
+      XBT_VERB("ROW: step(%d)=myrow(%d). Broadcast my data.", step, myrow);
       for (l = 1; l < PROC_MATRIX_SIZE; l++) {
-        VERB1("ROW:   Send to %s",
+        XBT_VERB("ROW:   Send to %s",
               gras_socket_peer_name(socket_line[l - 1]));
         gras_msg_send(socket_line[l - 1], "dataA", &mydataA);
       }
@@ -337,7 +337,7 @@ static int pmm_worker_cb(gras_msg_cb_ctx_t ctx, void *payload)
       CATCH(e) {
         RETHROW0("Can't get a data message from row : %s");
       }
-      VERB3("ROW: step(%d)<>myrow(%d). Receive data from %s", step, myrow,
+      XBT_VERB("ROW: step(%d)<>myrow(%d). Receive data from %s", step, myrow,
             gras_socket_peer_name(from));
     }
     xbt_matrix_double_addmult(bA, bB, bC);
@@ -355,7 +355,7 @@ static int pmm_worker_cb(gras_msg_cb_ctx_t ctx, void *payload)
   CATCH(e) {
     RETHROW0("Failed to send answer to server: %s");
   }
-  VERB2(">>>>>>>> Result sent to %s:%d <<<<<<<<",
+  XBT_VERB(">>>>>>>> Result sent to %s:%d <<<<<<<<",
         gras_socket_peer_name(master), gras_socket_peer_port(master));
   /*  Free the allocated resources, and shut GRAS down */
 
@@ -401,7 +401,7 @@ int slave(int argc, char *argv[])
 
   /* Create the connexions */
   mysock = gras_socket_server_range(3000, 9999, 0, 0);
-  INFO1("Sensor %d starting", rank);
+  XBT_INFO("Sensor %d starting", rank);
   while (!connected) {
     xbt_ex_t e;
     TRY {
index ce8372e..8f93be0 100644 (file)
@@ -26,21 +26,21 @@ int alice(int argc, char *argv[])
   /* Let the other process change the host props */
   gras_os_sleep(1);
 
-  INFO0("== Dump all the properties of current host");
+  XBT_INFO("== Dump all the properties of current host");
   xbt_dict_foreach(host_props, cursor, key, data)
-      INFO2("  Host property: '%s' has value: '%s'", key, data);
+      XBT_INFO("  Host property: '%s' has value: '%s'", key, data);
 
-  INFO0("== Dump all the properties of alice");
+  XBT_INFO("== Dump all the properties of alice");
   xbt_dict_foreach(process_props, cursor, key, data)
       if (!strncmp(key, "SG_TEST_", 8))
-    INFO2("  Process property: '%s' has value: '%s'", key, data);
+    XBT_INFO("  Process property: '%s' has value: '%s'", key, data);
 
-  INFO0("== Try to get a process property that does not exist");
+  XBT_INFO("== Try to get a process property that does not exist");
   value = gras_process_property_value("Nonexisting");
   xbt_assert0(!value, "nonexisting property exists!!");
 
   /* Modify an existing property. First check it exists */
-  INFO0("== Trying to modify a process property");
+  XBT_INFO("== Trying to modify a process property");
   value = gras_process_property_value("new prop");
   xbt_assert0(!value, "Property 'new prop' exists before I add it!");
   xbt_dict_set(process_props, "new prop", xbt_strdup("new value"),
@@ -66,23 +66,23 @@ int bob(int argc, char *argv[])
   char *key, *data;
   const char *value;
 
-  INFO0("== Dump all the properties of host1");
+  XBT_INFO("== Dump all the properties of host1");
   xbt_dict_foreach(host_props, cursor, key, data)
-      INFO2("  Host property: '%s' has value: '%s'", key, data);
+      XBT_INFO("  Host property: '%s' has value: '%s'", key, data);
 
-  INFO0("== Try to get a property that does not exist");
+  XBT_INFO("== Try to get a property that does not exist");
   value = gras_os_host_property_value("non existing key");
   xbt_assert1(value == NULL,
               "The key 'non existing key' exists (with value '%s')!!",
               value);
 
-  INFO0
+  XBT_INFO
       ("== Set a host property that alice will try to retrieve in SG (from bob->hello)");
   xbt_dict_set(host_props, "from bob", xbt_strdup("hello"), xbt_free_f);
 
-  INFO0("== Dump all the properties of host1 again to check the addition");
+  XBT_INFO("== Dump all the properties of host1 again to check the addition");
   xbt_dict_foreach(host_props, cursor, key, data)
-      INFO2("  Host property: '%s' has value: '%s'", key, data);
+      XBT_INFO("  Host property: '%s' has value: '%s'", key, data);
 
   gras_os_sleep(1);             /* KILLME once bug on empty main is solved */
   gras_exit();
index a0a42e9..e47c1ba 100644 (file)
@@ -68,7 +68,7 @@ int master(int argc, char *argv[])
   }
 
   /* friends, we're ready. Come and play */
-  INFO1("Wait for peers for a while. I need %d peers",
+  XBT_INFO("Wait for peers for a while. I need %d peers",
         xbt_dict_size(pals_int));
   while (xbt_dynar_length(peers) < xbt_dict_size(pals_int)) {
     TRY {
@@ -81,19 +81,19 @@ int master(int argc, char *argv[])
       char *peer_name;
       void *data;
       xbt_dict_foreach(pals_int, dict_cursor, peer_name, data) {
-        INFO1("Peer %s didn't showed up", peer_name);
+        XBT_INFO("Peer %s didn't showed up", peer_name);
       }
       RETHROW;
     }
   }
-  INFO1("Got my %ld peers", xbt_dynar_length(peers));
+  XBT_INFO("Got my %ld peers", xbt_dynar_length(peers));
   xbt_dict_free(&pals_int);
 
   /* Check who came */
   xbt_dict_t pals = xbt_dict_new();
   gras_socket_t pal;
   xbt_dynar_foreach(peers, cursor, peer) {
-    //INFO1("%s is here",peer->name);
+    //XBT_INFO("%s is here",peer->name);
     gras_socket_t sock = gras_socket_client(peer->name, peer->port);
     xbt_dict_set(pals, peer->name, sock, NULL);
   }
@@ -101,7 +101,7 @@ int master(int argc, char *argv[])
   xbt_dynar_foreach(cmds, cursor, cmd) {
     pal = xbt_dict_get_or_null(pals, cmd->who);
     if (!pal) {
-      CRITICAL1("Process %s didn't came! Abording!", cmd->who);
+      XBT_CRITICAL("Process %s didn't came! Abording!", cmd->who);
       amok_pm_group_shutdown("replay");
       xbt_dynar_free(&cmds);
       gras_exit();
@@ -113,12 +113,12 @@ int master(int argc, char *argv[])
   xbt_dict_foreach(pals, dict_cursor, pal_name, pal) {
     gras_msg_send(pal, "commands", &cmds);
   }
-  INFO0("Sent commands to every processes. Let them start now");
+  XBT_INFO("Sent commands to every processes. Let them start now");
   xbt_dict_cursor_t dict_it;
   xbt_dict_foreach(pals, dict_it, pal_name, pal) {
     gras_msg_send(pal, "go", NULL);
   }
-  INFO0("They should be started by now. Wait for their completion.");
+  XBT_INFO("They should be started by now. Wait for their completion.");
 
   for (cursor = 0; cursor < xbt_dynar_length(peers); cursor++) {
     gras_msg_wait(-1, "go", NULL, NULL);
@@ -143,7 +143,7 @@ static gras_socket_t get_peer_sock(char *peer)
   worker_data_t g = gras_userdata_get();
   gras_socket_t peer_sock = xbt_dict_get_or_null(g->peers, peer);
   if (!peer_sock) {
-    INFO1("Create a socket to %s", peer);
+    XBT_INFO("Create a socket to %s", peer);
     peer_sock = gras_socket_client(peer, 4000);
     xbt_dict_set(g->peers, peer, peer_sock, NULL);      //gras_socket_close_voidp);
   }
@@ -166,13 +166,13 @@ static void do_command(int rank, void *c)
   if (cmd->action == XBT_WORKLOAD_SEND) {
     gras_socket_t sock = get_peer_sock(cmd->str_arg);
     chunk = xbt_workload_data_chunk_new((int) (cmd->d_arg));
-    INFO4("Send %.f bytes to %s %s:%d", cmd->d_arg, cmd->str_arg,
+    XBT_INFO("Send %.f bytes to %s %s:%d", cmd->d_arg, cmd->str_arg,
           gras_socket_peer_name(sock), gras_socket_peer_port(sock));
     gras_msg_send_(sock, gras_msgtype_by_name("chunk"), &chunk);
-    INFO2("Done sending %.f bytes to %s", cmd->d_arg, cmd->str_arg);
+    XBT_INFO("Done sending %.f bytes to %s", cmd->d_arg, cmd->str_arg);
 
   } else if (cmd->action == XBT_WORKLOAD_RECV) {
-    INFO2("Recv %.f bytes from %s", cmd->d_arg, cmd->str_arg);
+    XBT_INFO("Recv %.f bytes from %s", cmd->d_arg, cmd->str_arg);
     TRY {
       gras_msg_wait(1000000, "chunk", NULL, &chunk);
     }
@@ -182,7 +182,7 @@ static void do_command(int rank, void *c)
                cmd->d_arg, cmd->str_arg);
     }
     xbt_workload_data_chunk_free(chunk);
-    INFO2("Done receiving %.f bytes from %s", cmd->d_arg, cmd->str_arg);
+    XBT_INFO("Done receiving %.f bytes from %s", cmd->d_arg, cmd->str_arg);
 
   } else {
     xbt_die(bprintf
@@ -206,7 +206,7 @@ int worker(int argc, char *argv[])
   globals->peers = xbt_dict_new();
 
   if (gras_if_RL())
-    INFO2("Sensor %s starting. Connecting to master on %s",
+    XBT_INFO("Sensor %s starting. Connecting to master on %s",
           gras_os_myname(), argv[1]);
   while (!connected) {
     xbt_ex_t e;
@@ -218,7 +218,7 @@ int worker(int argc, char *argv[])
       if (e.category != system_error)
         RETHROW;
       xbt_ex_free(e);
-      INFO0("Failed to connect. Retry in 0.5 second");
+      XBT_INFO("Failed to connect. Retry in 0.5 second");
       gras_os_sleep(0.5);
     }
   }
@@ -237,7 +237,7 @@ int worker(int argc, char *argv[])
     xbt_dynar_foreach(g->commands, cursor, cmd) {
       if (!strcmp(cmd->who, myname)) {
         char *c = xbt_workload_elm_to_string(cmd);
-        //      INFO1("TODO: %s",c);
+        //      XBT_INFO("TODO: %s",c);
         free(c);
 
         switch (cmd->action) {
@@ -251,12 +251,12 @@ int worker(int argc, char *argv[])
             CATCH(e) {
               SIMIX_display_process_status();
             }
-            INFO0("Communications all done");
+            XBT_INFO("Communications all done");
             xbt_dynar_reset(cmd_to_go);
           }
-          INFO1("Compute %.f flops", cmd->d_arg);
+          XBT_INFO("Compute %.f flops", cmd->d_arg);
           gras_cpu_burn(cmd->d_arg);
-          INFO1("Done computing %.f flops", cmd->d_arg);
+          XBT_INFO("Done computing %.f flops", cmd->d_arg);
           break;
         case XBT_WORKLOAD_SEND:
           /* Create the socket from main thread since it seems to fails when done from dopar thread */
@@ -269,7 +269,7 @@ int worker(int argc, char *argv[])
       }
     }
     /* do in parallel any communication still queued */
-    INFO1("Do %ld pending communications after end of TODO list",
+    XBT_INFO("Do %ld pending communications after end of TODO list",
           xbt_dynar_length(cmd_to_go));
     if (xbt_dynar_length(cmd_to_go)) {
       xbt_dynar_dopar(cmd_to_go, do_command);
index 4c8e4fd..42b716f 100644 (file)
@@ -84,7 +84,7 @@ int client(int argc, char *argv[])
     host = argv[1];
     port = atoi(argv[2]);
   }
-  INFO2("Launch client (server on %s:%d)", host, port);
+  XBT_INFO("Launch client (server on %s:%d)", host, port);
 
   exception_catching();
 
@@ -100,7 +100,7 @@ int client(int argc, char *argv[])
   CATCH(e) {
     RETHROW0("Unable to connect to the server: %s");
   }
-  INFO2("Connected to %s:%d.", host, port);
+  XBT_INFO("Connected to %s:%d.", host, port);
 
 
   /* 5. Register the messages.
@@ -110,7 +110,7 @@ int client(int argc, char *argv[])
   register_messages();
 
   /* 6. Keep the user informed of what's going on */
-  INFO2("Connected to server which is on %s:%d",
+  XBT_INFO("Connected to server which is on %s:%d",
         gras_socket_peer_name(toserver), gras_socket_peer_port(toserver));
 
   /* 7. Prepare and send the ping message to the server */
@@ -126,13 +126,13 @@ int client(int argc, char *argv[])
   exception_catching();
 
   /* 8. Keep the user informed of what's going on, again */
-  INFO4("The answer to PING(%d) on %s:%d is PONG(%d)",
+  XBT_INFO("The answer to PING(%d) on %s:%d is PONG(%d)",
         ping,
         gras_socket_peer_name(toserver), gras_socket_peer_port(toserver),
         pong);
 
   /* 9. Call a RPC which raises an exception (to test exception propagation) */
-  INFO0("Call the exception raising RPC");
+  XBT_INFO("Call the exception raising RPC");
   TRY {
     gras_msg_rpccall(toserver, 6000.0, "raise exception", NULL, NULL);
   }
@@ -144,7 +144,7 @@ int client(int argc, char *argv[])
     xbt_assert1(e.value == 42, "Got wrong value: %d (!=42)", e.value);
     xbt_assert1(!strncmp(e.msg, exception_msg, strlen(exception_msg)),
                 "Got wrong message: %s", e.msg);
-    INFO0
+    XBT_INFO
         ("Got the expected exception when calling the exception raising RPC");
     xbt_ex_free(e);
   }
@@ -152,13 +152,13 @@ int client(int argc, char *argv[])
   if (!gotit)
     THROW0(unknown_error, 0, "Didn't got the remote exception!");
 
-  INFO0("Called the exception raising RPC");
+  XBT_INFO("Called the exception raising RPC");
   exception_catching();
 
   /* doxygen_ignore */
   for (i = 0; i < 5; i++) {
 
-    INFO1("Call the exception raising RPC (i=%d)", i);
+    XBT_INFO("Call the exception raising RPC (i=%d)", i);
     TRY {
       gras_msg_rpccall(toserver, 6000.0, "raise exception", NULL, NULL);
     }
@@ -174,7 +174,7 @@ int client(int argc, char *argv[])
 
   /* 9. Call a RPC which raises an exception (to test that exception propagation works) */
   for (i = 0; i < 5; i++) {
-    INFO1("Call the exception raising RPC on the forwarder (i=%d)", i);
+    XBT_INFO("Call the exception raising RPC on the forwarder (i=%d)", i);
     TRY {
       gras_msg_rpccall(toforwarder, 6000.0, "forward exception", NULL,
                        NULL);
@@ -191,23 +191,23 @@ int client(int argc, char *argv[])
     xbt_assert2(e.category == unknown_error,
                 "Got wrong category: %d (instead of %d)",
                 e.category, unknown_error);
-    INFO0
+    XBT_INFO
         ("Got the expected exception when calling the exception raising RPC");
     xbt_ex_free(e);
     exception_catching();
   }
 
-  INFO2("Ask %s:%d to die", gras_socket_peer_name(toforwarder),
+  XBT_INFO("Ask %s:%d to die", gras_socket_peer_name(toforwarder),
         gras_socket_peer_port(toforwarder));
   gras_msg_send(toforwarder, "kill", NULL);
-  INFO2("Ask %s:%d to die", gras_socket_peer_name(toserver),
+  XBT_INFO("Ask %s:%d to die", gras_socket_peer_name(toserver),
         gras_socket_peer_port(toserver));
   gras_msg_send(toserver, "kill", NULL);
 
   /* 11. Cleanup the place before leaving */
   gras_socket_close(toserver);
   gras_socket_close(toforwarder);
-  INFO0("Done.");
+  XBT_INFO("Done.");
   gras_exit();
   return 0;
 }                               /* end_of_client */
@@ -225,7 +225,7 @@ static int forwarder_cb_kill(gras_msg_cb_ctx_t ctx, void *payload_data)
 {
   forward_data_t fdata;
   gras_socket_t expeditor = gras_msg_cb_ctx_from(ctx);
-  INFO2("Asked to die by %s:%d", gras_socket_peer_name(expeditor),
+  XBT_INFO("Asked to die by %s:%d", gras_socket_peer_name(expeditor),
         gras_socket_peer_port(expeditor));
   fdata = gras_userdata_get();
   fdata->done = 1;
@@ -237,7 +237,7 @@ static int forwarder_cb_forward_ex(gras_msg_cb_ctx_t ctx,
 {
   forward_data_t fdata = gras_userdata_get();
 
-  INFO0("Forward a request");
+  XBT_INFO("Forward a request");
   gras_msg_rpccall(fdata->server, 60, "raise exception", NULL, NULL);
   return 0;
 }
@@ -256,7 +256,7 @@ int forwarder(int argc, char *argv[])
   fdata->done = 0;
   port = atoi(argv[1]);
 
-  INFO1("Launch forwarder (port=%d)", port);
+  XBT_INFO("Launch forwarder (port=%d)", port);
   mysock = gras_socket_server(port);
 
   gras_os_sleep(1);             /* wait for the server to be ready */
@@ -273,7 +273,7 @@ int forwarder(int argc, char *argv[])
   gras_socket_close(mysock);
   gras_socket_close(fdata->server);
   free(fdata);
-  INFO0("Done.");
+  XBT_INFO("Done.");
   gras_exit();
   return 0;
 }
@@ -291,7 +291,7 @@ static int server_cb_kill(gras_msg_cb_ctx_t ctx, void *payload_data)
   gras_socket_t expeditor = gras_msg_cb_ctx_from(ctx);
   server_data_t sdata;
 
-  INFO2("Asked to die by %s:%d", gras_socket_peer_name(expeditor),
+  XBT_INFO("Asked to die by %s:%d", gras_socket_peer_name(expeditor),
         gras_socket_peer_port(expeditor));
 
   sdata = gras_userdata_get();
@@ -313,7 +313,7 @@ static int server_cb_ping(gras_msg_cb_ctx_t ctx, void *payload_data)
   gras_socket_t expeditor = gras_msg_cb_ctx_from(ctx);
 
   /* 2. Log which client connected */
-  INFO3("Got message PING(%d) from %s:%d",
+  XBT_INFO("Got message PING(%d) from %s:%d",
         msg,
         gras_socket_peer_name(expeditor),
         gras_socket_peer_port(expeditor));
@@ -323,7 +323,7 @@ static int server_cb_ping(gras_msg_cb_ctx_t ctx, void *payload_data)
 
   /* 5. Return as result */
   gras_msg_rpcreturn(6000, ctx, &msg);
-  INFO0("Answered with PONG(4321)");
+  XBT_INFO("Answered with PONG(4321)");
 
   /* 6. Cleanups, if any */
 
@@ -349,7 +349,7 @@ int server(int argc, char *argv[])
   sdata = gras_userdata_new(s_server_data_t);
   sdata->done = 0;
 
-  INFO1("Launch server (port=%d)", port);
+  XBT_INFO("Launch server (port=%d)", port);
 
   /* 3. Create my master socket */
   mysock = gras_socket_server(port);
@@ -360,7 +360,7 @@ int server(int argc, char *argv[])
   gras_cb_register("raise exception", &server_cb_raise_ex);
   gras_cb_register("kill", &server_cb_kill);
 
-  INFO1("Listening on port %d", gras_socket_my_port(mysock));
+  XBT_INFO("Listening on port %d", gras_socket_my_port(mysock));
 
   /* 5. Wait for the ping incomming messages */
 
@@ -396,7 +396,7 @@ int server(int argc, char *argv[])
   /* 8. Free the allocated resources, and shut GRAS down */
   free(sdata);
   gras_socket_close(mysock);
-  INFO0("Done.");
+  XBT_INFO("Done.");
   gras_exit();
 
   return 0;
index 07ff188..001abd7 100644 (file)
@@ -42,7 +42,7 @@ int worker(int argc, char *argv[]) {
     if (!moretodo)
       break; // Do not break from within the CATCH, exceptions don't like it.
 
-    INFO2("Got [%d;%d] to do",chunk->min,chunk->max);
+    XBT_INFO("Got [%d;%d] to do",chunk->min,chunk->max);
     GRAS_BENCH_ALWAYS_BEGIN();
     int i;
     for (i=chunk->min;i<chunk->max;i++) {
@@ -57,7 +57,7 @@ int worker(int argc, char *argv[]) {
     GRAS_BENCH_ALWAYS_END();
     xbt_queue_push(done,&chunk);
   }
-  INFO0("No more work for me; bailing out");
+  XBT_INFO("No more work for me; bailing out");
 
   return 0;
 }
@@ -81,7 +81,7 @@ int server(int argc, char *argv[])
   done = xbt_queue_new(-1,sizeof(work_chunk_t));
 
 
-  INFO0("Prepare some work");
+  XBT_INFO("Prepare some work");
   for (i=0;i<maxint/perchunk;i++) {
     chunk = xbt_new0(s_work_chunk_t,1);
     chunk->min = i*perchunk;
@@ -90,7 +90,7 @@ int server(int argc, char *argv[])
     xbt_queue_push(todo,&chunk);
   }
 
-  INFO0("Spawn the kids");
+  XBT_INFO("Spawn the kids");
   for (i = 0; i < child_amount; i++) {
     char *name = bprintf("child%d",i);
     worker_args = xbt_new0(char *, 2);
@@ -100,7 +100,7 @@ int server(int argc, char *argv[])
     free(name);
   }
 
-  INFO0("Fetch their answers");
+  XBT_INFO("Fetch their answers");
   for (i=0;i<maxint/perchunk;i++) {
     work_chunk_t chunk;
     xbt_strbuff_t buff = xbt_strbuff_new();
@@ -117,7 +117,7 @@ int server(int argc, char *argv[])
         xbt_strbuff_append(buff,",");
       xbt_strbuff_append(buff,number);
     }
-    INFO3("Primes in [%d,%d]: %s",chunk->min,chunk->max,buff->data);
+    XBT_INFO("Primes in [%d,%d]: %s",chunk->min,chunk->max,buff->data);
     xbt_strbuff_free(buff);
   }
   gras_os_sleep(.1);/* Let the childs detect that there is nothing more to do */
index d4debb2..dc5a693 100644 (file)
@@ -27,7 +27,7 @@ int *id;                        /* to pass a pointer to the threads without race
 
 static void pickup(int id, int lunch)
 {
-  INFO2("Thread %d gets hungry (lunch #%d)", id, lunch);
+  XBT_INFO("Thread %d gets hungry (lunch #%d)", id, lunch);
   xbt_mutex_acquire(mutex);
   while (state[(id + (philosopher_amount - 1)) % philosopher_amount] ==
          EATING || state[(id + 1) % philosopher_amount] == EATING) {
@@ -42,12 +42,12 @@ static void pickup(int id, int lunch)
               id);
 
   xbt_mutex_release(mutex);
-  INFO1("Thread %d eats", id);
+  XBT_INFO("Thread %d eats", id);
 }
 
 static void putdown(int id)
 {
-  INFO1("Thread %d is full", id);
+  XBT_INFO("Thread %d is full", id);
   xbt_mutex_acquire(mutex);
   state[id] = THINKING;
   xbt_cond_signal(forks
@@ -55,7 +55,7 @@ static void putdown(int id)
   xbt_cond_signal(forks[(id + 1) % philosopher_amount]);
 
   xbt_mutex_release(mutex);
-  INFO1("Thread %d thinks", id);
+  XBT_INFO("Thread %d thinks", id);
 }
 
 /*
@@ -86,11 +86,11 @@ static void philo_thread(void *arg)
   xbt_mutex_release(mut_end);
 
   /* Enter an endless loop to test the killing facilities */
-  INFO1
+  XBT_INFO
       ("Thread %d tries to enter the dead-end; hopefully, the master will cancel it",
        id);
   xbt_mutex_acquire(dead_end);
-  INFO1("Oops, thread %d reached the dead-end. Cancelation failed", id);
+  XBT_INFO("Oops, thread %d reached the dead-end. Cancelation failed", id);
 }
 
 int philosopher(int argc, char *argv[]);
@@ -124,7 +124,7 @@ int philosopher(int argc, char *argv[])
   dead_end = xbt_mutex_init();
   xbt_mutex_acquire(dead_end);
 
-  INFO2("Spawn the %d threads (%d lunches scheduled)", philosopher_amount,
+  XBT_INFO("Spawn the %d threads (%d lunches scheduled)", philosopher_amount,
         lunch_amount);
   /* spawn threads */
   for (i = 0; i < philosopher_amount; i++) {
@@ -141,7 +141,7 @@ int philosopher(int argc, char *argv[])
     xbt_cond_wait(cond_end, mut_end);
   xbt_mutex_release(mut_end);
 
-  INFO0("Cancel all childs");
+  XBT_INFO("Cancel all childs");
   /* nuke them threads */
   for (i = 0; i < philosopher_amount; i++) {
     xbt_thread_cancel(philosophers[i]);
index 18d52a1..22be3d2 100644 (file)
@@ -26,7 +26,7 @@ static void repetitive_action(void)
 
   /* Stop if nothing to do yet */
   if (globals->still_to_do <= 0) {
-    INFO0("Repetitive_action has nothing to do yet");
+    XBT_INFO("Repetitive_action has nothing to do yet");
     return;
   }
 
@@ -35,7 +35,7 @@ static void repetitive_action(void)
     gras_timer_cancel_repeat(REPEAT_INTERVAL, repetitive_action);
   }
 
-  INFO1
+  XBT_INFO
       ("repetitive_action decrementing globals->still_to_do. New value: %d",
        globals->still_to_do - 1);
 
@@ -46,7 +46,7 @@ static void delayed_action(void)
 {
   my_globals *globals = (my_globals *) gras_userdata_get();
 
-  INFO1("delayed_action setting globals->still_to_do to %d", LOOP_COUNT);
+  XBT_INFO("delayed_action setting globals->still_to_do to %d", LOOP_COUNT);
 
   globals->still_to_do = LOOP_COUNT;
 }                               /* end_of_delayed_action */
@@ -59,20 +59,20 @@ int client(int argc, char *argv[])
   globals = gras_userdata_new(my_globals);
   globals->still_to_do = -1;
 
-  INFO1("Programming the repetitive_action with a frequency of %f sec",
+  XBT_INFO("Programming the repetitive_action with a frequency of %f sec",
         REPEAT_INTERVAL);
   gras_timer_repeat(REPEAT_INTERVAL, repetitive_action);
 
-  INFO1("Programming the delayed_action for after %f sec", DELAY_INTERVAL);
+  XBT_INFO("Programming the delayed_action for after %f sec", DELAY_INTERVAL);
   gras_timer_delay(REPEAT_INTERVAL, delayed_action);
 
-  INFO0("Have a rest");
+  XBT_INFO("Have a rest");
   gras_os_sleep(DELAY_INTERVAL / 2.0);
 
-  INFO0("Canceling the delayed_action.");
+  XBT_INFO("Canceling the delayed_action.");
   gras_timer_cancel_delay(REPEAT_INTERVAL, delayed_action);
 
-  INFO1("Re-programming the delayed_action for after %f sec",
+  XBT_INFO("Re-programming the delayed_action for after %f sec",
         DELAY_INTERVAL);
   gras_timer_delay(REPEAT_INTERVAL, delayed_action);
 
@@ -80,7 +80,7 @@ int client(int argc, char *argv[])
          globals->still_to_do >
          0 /* after delayed_action, and not enough repetitive_action */ ) {
 
-    DEBUG1("Prepare to handle messages for 5 sec (still_to_do=%d)",
+    XBT_DEBUG("Prepare to handle messages for 5 sec (still_to_do=%d)",
            globals->still_to_do);
     gras_msg_handle(5.0);
   }
index 0b42753..35dabdf 100644 (file)
@@ -81,14 +81,14 @@ static void action_send(const char *const *action)
   TRACE_smpi_send(rank, rank, dst_traced);
 #endif
 
-  DEBUG2("Entering Send: %s (size: %lg)", name, size);
+  XBT_DEBUG("Entering Send: %s (size: %lg)", name, size);
    if (size<65536) {
      action_Isend(action);
    } else {
      MSG_task_send(MSG_task_create(name, 0, size, NULL), to);
    }
    
-   VERB2("%s %f", name, MSG_get_clock() - clock);
+   XBT_VERB("%s %f", name, MSG_get_clock() - clock);
 
   if (XBT_LOG_ISENABLED(actions, xbt_log_priority_verbose))
     free(name);
@@ -113,8 +113,8 @@ static void action_Isend(const char *const *action)
       MSG_task_isend( MSG_task_create(to,0,parse_double(size),NULL), to);
   xbt_dynar_push(globals->isends,&comm);
 
-  DEBUG1("Isend on %s", MSG_process_get_name(MSG_process_self()));
-  VERB2("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
+  XBT_DEBUG("Isend on %s", MSG_process_get_name(MSG_process_self()));
+  XBT_VERB("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
 
   asynchronous_cleanup();
 }
@@ -139,10 +139,10 @@ static void action_recv(const char *const *action)
   TRACE_smpi_ptp_in(rank, src_traced, rank, "recv");
 #endif
 
-  DEBUG1("Receiving: %s", name);
+  XBT_DEBUG("Receiving: %s", name);
   MSG_task_receive(&task, mailbox_name);
   //  MSG_task_receive(&task, MSG_process_get_name(MSG_process_self()));
-  VERB2("%s %f", name, MSG_get_clock() - clock);
+  XBT_VERB("%s %f", name, MSG_get_clock() - clock);
   MSG_task_destroy(task);
 
   if (XBT_LOG_ISENABLED(actions, xbt_log_priority_verbose))
@@ -161,7 +161,7 @@ static void action_Irecv(const char *const *action)
   double clock = MSG_get_clock();
   process_globals_t globals = (process_globals_t) MSG_process_get_data(MSG_process_self());
 
-  DEBUG1("Irecv on %s", MSG_process_get_name(MSG_process_self()));
+  XBT_DEBUG("Irecv on %s", MSG_process_get_name(MSG_process_self()));
 #ifdef HAVE_TRACING
   int rank = get_rank(MSG_process_get_name(MSG_process_self()));
   int src_traced = get_rank(action[2]);
@@ -181,7 +181,7 @@ static void action_Irecv(const char *const *action)
           mailbox);
   xbt_dynar_push(globals->irecvs,&c);
 
-  VERB2("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
+  XBT_VERB("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
 
 #ifdef HAVE_TRACING
   TRACE_smpi_ptp_out(rank, src_traced, rank, "Irecv");
@@ -211,14 +211,14 @@ static void action_wait(const char *const *action)
   TRACE_smpi_ptp_in(rank, src_traced, rank, "wait");
 #endif
 
-  DEBUG1("Entering %s", name);
+  XBT_DEBUG("Entering %s", name);
   comm = xbt_dynar_pop_as(globals->irecvs,msg_comm_t);
   MSG_comm_wait(comm,-1);
   task = xbt_dynar_pop_as(globals->tasks,m_task_t);
   MSG_comm_destroy(comm);
   MSG_task_destroy(task);
 
-  VERB2("%s %f", name, MSG_get_clock() - clock);
+  XBT_VERB("%s %f", name, MSG_get_clock() - clock);
   if (XBT_LOG_ISENABLED(actions, xbt_log_priority_verbose))
     free(name);
 #ifdef HAVE_TRACING
@@ -244,7 +244,7 @@ static void action_barrier(const char *const *action)
     cond = SIMIX_req_cond_init();
     processes_arrived_sofar=0;
   }
-  DEBUG2("Entering barrier: %s (%d already there)", name,processes_arrived_sofar);
+  XBT_DEBUG("Entering barrier: %s (%d already there)", name,processes_arrived_sofar);
 
   SIMIX_req_mutex_lock(mutex);
   if (++processes_arrived_sofar == communicator_size) {
@@ -255,7 +255,7 @@ static void action_barrier(const char *const *action)
     SIMIX_req_mutex_unlock(mutex);
   }
 
-  DEBUG1("Exiting barrier: %s", name);
+  XBT_DEBUG("Exiting barrier: %s", name);
 
   processes_arrived_sofar--;
   if (!processes_arrived_sofar) {
@@ -290,7 +290,7 @@ static void action_reduce(const char *const *action)
        reduce_identifier = bprintf("reduce_%d", counters->reduce_counter++);
 
        if (!strcmp(process_name, "p0")) {
-               DEBUG2("%s: %s is the Root", reduce_identifier, process_name);
+               XBT_DEBUG("%s: %s is the Root", reduce_identifier, process_name);
 
                msg_comm_t *comms = xbt_new0(msg_comm_t,communicator_size-1);
            m_task_t *tasks = xbt_new0(m_task_t,communicator_size-1);
@@ -306,20 +306,20 @@ static void action_reduce(const char *const *action)
            free(tasks);
 
            comp_task = MSG_task_create("reduce_comp", comp_size, 0, NULL);
-           DEBUG1("%s: computing 'reduce_comp'", reduce_identifier);
+           XBT_DEBUG("%s: computing 'reduce_comp'", reduce_identifier);
            MSG_task_execute(comp_task);
            MSG_task_destroy(comp_task);
-           DEBUG1("%s: computed", reduce_identifier);
+           XBT_DEBUG("%s: computed", reduce_identifier);
 
        } else {
-               DEBUG2("%s: %s sends", reduce_identifier, process_name);
+               XBT_DEBUG("%s: %s sends", reduce_identifier, process_name);
                sprintf(mailbox, "%s_%s_p0", reduce_identifier, process_name);
-           DEBUG1("put on %s", mailbox);
+           XBT_DEBUG("put on %s", mailbox);
            MSG_task_send(MSG_task_create(reduce_identifier, 0, comm_size, NULL),
                          mailbox);
        }
 
-       VERB2("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
+       XBT_VERB("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
        free(reduce_identifier);
 }
 
@@ -343,7 +343,7 @@ static void action_bcast(const char *const *action)
        bcast_identifier = bprintf("bcast_%d", counters->bcast_counter++);
 
        if (!strcmp(process_name, "p0")) {
-               DEBUG2("%s: %s is the Root", bcast_identifier, process_name);
+               XBT_DEBUG("%s: %s is the Root", bcast_identifier, process_name);
 
            msg_comm_t *comms = xbt_new0(msg_comm_t,communicator_size-1);
 
@@ -358,17 +358,17 @@ static void action_bcast(const char *const *action)
               MSG_comm_destroy(comms[i-1]);
            free(comms);
 
-           DEBUG2("%s: all messages sent by %s have been received",
+           XBT_DEBUG("%s: all messages sent by %s have been received",
                   bcast_identifier, process_name);
 
        } else {
            sprintf(mailbox, "%s_p0_%s", bcast_identifier, process_name);
            MSG_task_receive(&task, mailbox);
            MSG_task_destroy(task);
-           DEBUG2("%s: %s has received", bcast_identifier, process_name);
+           XBT_DEBUG("%s: %s has received", bcast_identifier, process_name);
        }
 
-       VERB2("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
+       XBT_VERB("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
        free(bcast_identifier);
 }
 
@@ -382,9 +382,9 @@ static void action_sleep(const char *const *action)
   if (XBT_LOG_ISENABLED(actions, xbt_log_priority_verbose))
     name = xbt_str_join_array(action, " ");
 
-  DEBUG1("Entering %s", name);
+  XBT_DEBUG("Entering %s", name);
   MSG_process_sleep(parse_double(duration));
-  VERB2("%s %f ", name, MSG_get_clock() - clock);
+  XBT_VERB("%s %f ", name, MSG_get_clock() - clock);
 
   if (XBT_LOG_ISENABLED(actions, xbt_log_priority_verbose))
     free(name);
@@ -410,7 +410,7 @@ static void action_allReduce(const char *const *action) {
   allreduce_identifier = bprintf("allReduce_%d", counters->allReduce_counter++);
 
   if (!strcmp(process_name, "p0")) {
-    DEBUG2("%s: %s is the Root", allreduce_identifier, process_name);
+    XBT_DEBUG("%s: %s is the Root", allreduce_identifier, process_name);
 
     msg_comm_t *comms = xbt_new0(msg_comm_t,communicator_size-1);
     m_task_t *tasks = xbt_new0(m_task_t,communicator_size-1);
@@ -426,10 +426,10 @@ static void action_allReduce(const char *const *action) {
     free(tasks);
 
     comp_task = MSG_task_create("allReduce_comp", comp_size, 0, NULL);
-    DEBUG1("%s: computing 'reduce_comp'", allreduce_identifier);
+    XBT_DEBUG("%s: computing 'reduce_comp'", allreduce_identifier);
     MSG_task_execute(comp_task);
     MSG_task_destroy(comp_task);
-    DEBUG1("%s: computed", allreduce_identifier);
+    XBT_DEBUG("%s: computed", allreduce_identifier);
 
     for (i = 1; i < communicator_size; i++) {
       sprintf(mailbox, "%s_p0_p%d", allreduce_identifier, i);
@@ -442,23 +442,23 @@ static void action_allReduce(const char *const *action) {
        MSG_comm_destroy(comms[i-1]);
     free(comms);
 
-    DEBUG2("%s: all messages sent by %s have been received",
+    XBT_DEBUG("%s: all messages sent by %s have been received",
            allreduce_identifier, process_name);
 
   } else {
-    DEBUG2("%s: %s sends", allreduce_identifier, process_name);
+    XBT_DEBUG("%s: %s sends", allreduce_identifier, process_name);
     sprintf(mailbox, "%s_%s_p0", allreduce_identifier, process_name);
-    DEBUG1("put on %s", mailbox);
+    XBT_DEBUG("put on %s", mailbox);
     MSG_task_send(MSG_task_create(allreduce_identifier, 0, comm_size, NULL),
                   mailbox);
 
     sprintf(mailbox, "%s_p0_%s", allreduce_identifier, process_name);
     MSG_task_receive(&task, mailbox);
     MSG_task_destroy(task);
-    DEBUG2("%s: %s has received", allreduce_identifier, process_name);
+    XBT_DEBUG("%s: %s has received", allreduce_identifier, process_name);
   }
 
-  VERB2("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
+  XBT_VERB("%s %f", xbt_str_join_array(action, " "), MSG_get_clock() - clock);
   free(allreduce_identifier);
 }
 
@@ -471,7 +471,7 @@ static void action_comm_size(const char *const *action)
   if (XBT_LOG_ISENABLED(actions, xbt_log_priority_verbose))
     name = xbt_str_join_array(action, " ");
   communicator_size = parse_double(size);
-  VERB2("%s %f", name, MSG_get_clock() - clock);
+  XBT_VERB("%s %f", name, MSG_get_clock() - clock);
   if (XBT_LOG_ISENABLED(actions, xbt_log_priority_verbose))
     free(name);
 }
@@ -485,10 +485,10 @@ static void action_compute(const char *const *action)
 
   if (XBT_LOG_ISENABLED(actions, xbt_log_priority_verbose))
     name = xbt_str_join_array(action, " ");
-  DEBUG1("Entering %s", name);
+  XBT_DEBUG("Entering %s", name);
   MSG_task_execute(task);
   MSG_task_destroy(task);
-  VERB2("%s %f", name, MSG_get_clock() - clock);
+  XBT_VERB("%s %f", name, MSG_get_clock() - clock);
   if (XBT_LOG_ISENABLED(actions, xbt_log_priority_verbose))
     free(name);
 }
@@ -498,7 +498,7 @@ static void action_init(const char *const *action)
 #ifdef HAVE_TRACING
   TRACE_smpi_init(get_rank(MSG_process_get_name(MSG_process_self())));
 #endif
-  DEBUG0("Initialize the counters");
+  XBT_DEBUG("Initialize the counters");
   process_globals_t globals = (process_globals_t) calloc(1, sizeof(s_process_globals_t));
   globals->isends = xbt_dynar_new(sizeof(msg_comm_t),NULL);
   globals->irecvs = xbt_dynar_new(sizeof(msg_comm_t),NULL);
@@ -568,7 +568,7 @@ int main(int argc, char *argv[])
   /* Actually do the simulation using MSG_action_trace_run */
   res = MSG_action_trace_run(argv[3]);  // it's ok to pass a NULL argument here
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   MSG_clean();
 
   if (res == MSG_OK)
index 4258bfb..807d775 100644 (file)
@@ -73,32 +73,32 @@ int master(int argc, char *argv[])
     }
   }
 
-  INFO2("Got %d aliases and %d tasks to process", alias_count,
+  XBT_INFO("Got %d aliases and %d tasks to process", alias_count,
         number_of_tasks);
 
   for (i = 0; i < alias_count; i++)
-    DEBUG1("%s", aliases[i]);
+    XBT_DEBUG("%s", aliases[i]);
 
   for (i = 0; i < number_of_tasks; i++) {
-    INFO2("Sending \"%s\" to \"%s\"", todo[i]->name,
+    XBT_INFO("Sending \"%s\" to \"%s\"", todo[i]->name,
           aliases[i % alias_count]);
 
     if (!strcmp
         (MSG_host_get_name(MSG_host_self()), aliases[i % alias_count])) {
-      INFO0("Hey ! It's me ! :)");
+      XBT_INFO("Hey ! It's me ! :)");
     }
 
     MSG_task_send(todo[i], aliases[i % alias_count]);
-    INFO0("Sent");
+    XBT_INFO("Sent");
   }
 
-  INFO0
+  XBT_INFO
       ("All tasks have been dispatched. Let's tell everybody the computation is over.");
 
   for (i = 0; i < alias_count; i++)
     MSG_task_send(MSG_task_create("finalize", 0, 0, FINALIZE), aliases[i]);
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
 
   for (i = 0; i < alias_count; i++)
     free(aliases[i]);
@@ -118,21 +118,21 @@ int slave(int argc, char *argv[])
     res = MSG_task_receive(&(task), MSG_host_get_name(MSG_host_self()));
     xbt_assert0(res == MSG_OK, "MSG_task_receive failed");
 
-    INFO1("Received \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Received \"%s\"", MSG_task_get_name(task));
 
     if (!strcmp(MSG_task_get_name(task), "finalize")) {
       MSG_task_destroy(task);
       break;
     }
 
-    INFO1("Processing \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Processing \"%s\"", MSG_task_get_name(task));
     MSG_task_execute(task);
-    INFO1("\"%s\" done", MSG_task_get_name(task));
+    XBT_INFO("\"%s\" done", MSG_task_get_name(task));
     MSG_task_destroy(task);
     task = NULL;
   }
 
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_slave */
 
@@ -160,10 +160,10 @@ int forwarder(int argc, char *argv[])
     a = MSG_task_receive(&(task), MSG_host_get_name(MSG_host_self()));
 
     if (a == MSG_OK) {
-      INFO1("Received \"%s\"", MSG_task_get_name(task));
+      XBT_INFO("Received \"%s\"", MSG_task_get_name(task));
 
       if (MSG_task_get_data(task) == FINALIZE) {
-        INFO0
+        XBT_INFO
             ("All tasks have been dispatched. Let's tell everybody the computation is over.");
 
         for (i = 0; i < alias_count; i++)
@@ -174,12 +174,12 @@ int forwarder(int argc, char *argv[])
         break;
       }
 
-      INFO2("Sending \"%s\" to \"%s\"", MSG_task_get_name(task),
+      XBT_INFO("Sending \"%s\" to \"%s\"", MSG_task_get_name(task),
             aliases[i % alias_count]);
       MSG_task_send(task, aliases[i % alias_count]);
       i++;
     } else {
-      INFO0("Hey ?! What's up ? ");
+      XBT_INFO("Hey ?! What's up ? ");
       xbt_assert0(0, "Unexpected behavior");
     }
   }
@@ -187,7 +187,7 @@ int forwarder(int argc, char *argv[])
   for (i = 0; i < alias_count; i++)
     free(aliases[i]);
 
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 
 }                               /* end_of_forwarder */
@@ -214,7 +214,7 @@ MSG_error_t test_all(const char *platform_file,
 
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index 773fb4b..51cf97c 100644 (file)
@@ -124,7 +124,7 @@ static void chord_initialize(void)
     pow = pow << 1;
   }
   nb_keys = pow;
-  DEBUG1("Sets nb_keys to %d", nb_keys);
+  XBT_DEBUG("Sets nb_keys to %d", nb_keys);
 }
 
 /**
@@ -202,12 +202,12 @@ static void print_finger_table(node_t node)
 {
   if (XBT_LOG_ISENABLED(msg_chord, xbt_log_priority_verbose)) {
     int i;
-    VERB0("My finger table:");
-    VERB0("Start | Succ ");
+    XBT_VERB("My finger table:");
+    XBT_VERB("Start | Succ ");
     for (i = 0; i < nb_bits; i++) {
-      VERB2(" %3d  | %3d ", (node->id + powers2[i]) % nb_keys, node->fingers[i].id);
+      XBT_VERB(" %3d  | %3d ", (node->id + powers2[i]) % nb_keys, node->fingers[i].id);
     }
-    VERB1("Predecessor: %d", node->pred_id);
+    XBT_VERB("Predecessor: %d", node->pred_id);
   }
 }
 
@@ -223,7 +223,7 @@ static void set_finger(node_t node, int finger_index, int id)
     node->fingers[finger_index].id = id;
     get_mailbox(id, node->fingers[finger_index].mailbox);
     node->last_change_date = MSG_get_clock();
-    DEBUG2("My new finger #%d is %d", finger_index, id);
+    XBT_DEBUG("My new finger #%d is %d", finger_index, id);
   }
 }
 
@@ -242,7 +242,7 @@ static void set_predecessor(node_t node, int predecessor_id)
     }
     node->last_change_date = MSG_get_clock();
 
-    DEBUG1("My new predecessor is %d", predecessor_id);
+    XBT_DEBUG("My new predecessor is %d", predecessor_id);
   }
 }
 
@@ -299,10 +299,10 @@ int node(int argc, char *argv[])
 
     /*
     // sleep before starting
-    DEBUG1("Let's sleep during %f", sleep_time);
+    XBT_DEBUG("Let's sleep during %f", sleep_time);
     MSG_process_sleep(sleep_time);
     */
-    DEBUG0("Hey! Let's join the system.");
+    XBT_DEBUG("Hey! Let's join the system.");
 
     join_success = join(&node, known_id);
   }
@@ -348,7 +348,7 @@ int node(int argc, char *argv[])
         MSG_error_t status = MSG_comm_get_status(node.comm_receive);
 
         if (status != MSG_OK) {
-          DEBUG0("Failed to receive a task. Nevermind.");
+          XBT_DEBUG("Failed to receive a task. Nevermind.");
           node.comm_receive = NULL;
         }
         else {
@@ -365,7 +365,7 @@ int node(int argc, char *argv[])
         comm_send = xbt_dynar_get_as(node.comms, index, msg_comm_t);
         MSG_error_t status = MSG_comm_get_status(comm_send);
         xbt_dynar_remove_at(node.comms, index, &comm_send);
-        DEBUG3("Communication %p is finished with status %d, dynar size is now %lu",
+        XBT_DEBUG("Communication %p is finished with status %d, dynar size is now %lu",
             comm_send, status, xbt_dynar_length(node.comms));
        m_task_t task = MSG_comm_get_task(comm_send);
         MSG_comm_destroy(comm_send);
@@ -394,7 +394,7 @@ int node(int argc, char *argv[])
 
   // stop the simulation
   xbt_free(node.fingers);
-  INFO1("Messages created: %lu", smx_total_comms);
+  XBT_INFO("Messages created: %lu", smx_total_comms);
   return 0;
 }
 
@@ -406,7 +406,7 @@ int node(int argc, char *argv[])
  */
 static void handle_task(node_t node, m_task_t task) {
 
-  DEBUG1("Handling task %p", task);
+  XBT_DEBUG("Handling task %p", task);
   char mailbox[MAILBOX_NAME_SIZE];
   task_data_t task_data = (task_data_t) MSG_task_get_data(task);
   e_task_type_t type = task_data->type;
@@ -414,13 +414,13 @@ static void handle_task(node_t node, m_task_t task) {
   switch (type) {
 
     case TASK_FIND_SUCCESSOR:
-      DEBUG2("Receiving a 'Find Successor' request from %s for id %d",
+      XBT_DEBUG("Receiving a 'Find Successor' request from %s for id %d",
           task_data->issuer_host_name, task_data->request_id);
       // is my successor the successor?
       if (is_in_interval(task_data->request_id, node->id + 1, node->fingers[0].id)) {
         task_data->type = TASK_FIND_SUCCESSOR_ANSWER;
         task_data->answer_id = node->fingers[0].id;
-        DEBUG4("Sending back a 'Find Successor Answer' to %s (mailbox %s): the successor of %d is %d",
+        XBT_DEBUG("Sending back a 'Find Successor Answer' to %s (mailbox %s): the successor of %d is %d",
             task_data->issuer_host_name,
            task_data->answer_to,
             task_data->request_id, task_data->answer_id);
@@ -429,7 +429,7 @@ static void handle_task(node_t node, m_task_t task) {
       else {
         // otherwise, forward the request to the closest preceding finger in my table
         int closest = closest_preceding_node(node, task_data->request_id);
-        DEBUG2("Forwarding the 'Find Successor' request for id %d to my closest preceding finger %d",
+        XBT_DEBUG("Forwarding the 'Find Successor' request for id %d to my closest preceding finger %d",
             task_data->request_id, closest);
         get_mailbox(closest, mailbox);
         MSG_task_dsend(task, mailbox, task_free);
@@ -437,10 +437,10 @@ static void handle_task(node_t node, m_task_t task) {
       break;
 
     case TASK_GET_PREDECESSOR:
-      DEBUG1("Receiving a 'Get Predecessor' request from %s", task_data->issuer_host_name);
+      XBT_DEBUG("Receiving a 'Get Predecessor' request from %s", task_data->issuer_host_name);
       task_data->type = TASK_GET_PREDECESSOR_ANSWER;
       task_data->answer_id = node->pred_id;
-      DEBUG3("Sending back a 'Get Predecessor Answer' to %s via mailbox '%s': my predecessor is %d",
+      XBT_DEBUG("Sending back a 'Get Predecessor Answer' to %s via mailbox '%s': my predecessor is %d",
           task_data->issuer_host_name,
           task_data->answer_to, task_data->answer_id);
       MSG_task_dsend(task, task_data->answer_to, task_free);
@@ -448,14 +448,14 @@ static void handle_task(node_t node, m_task_t task) {
 
     case TASK_NOTIFY:
       // someone is telling me that he may be my new predecessor
-      DEBUG1("Receiving a 'Notify' request from %s", task_data->issuer_host_name);
+      XBT_DEBUG("Receiving a 'Notify' request from %s", task_data->issuer_host_name);
       notify(node, task_data->request_id);
       task_free(task);
       break;
 
     case TASK_PREDECESSOR_LEAVING:
       // my predecessor is about to quit
-      DEBUG1("Receiving a 'Predecessor Leaving' message from %s", task_data->issuer_host_name);
+      XBT_DEBUG("Receiving a 'Predecessor Leaving' message from %s", task_data->issuer_host_name);
       // modify my predecessor
       set_predecessor(node, task_data->request_id);
       task_free(task);
@@ -467,7 +467,7 @@ static void handle_task(node_t node, m_task_t task) {
 
     case TASK_SUCCESSOR_LEAVING:
       // my successor is about to quit
-      DEBUG1("Receiving a 'Successor Leaving' message from %s", task_data->issuer_host_name);
+      XBT_DEBUG("Receiving a 'Successor Leaving' message from %s", task_data->issuer_host_name);
       // modify my successor FIXME : this should be implicit ?
       set_finger(node, 0, task_data->request_id);
       task_free(task);
@@ -478,7 +478,7 @@ static void handle_task(node_t node, m_task_t task) {
 
     case TASK_FIND_SUCCESSOR_ANSWER:
     case TASK_GET_PREDECESSOR_ANSWER:
-      DEBUG2("Ignoring unexpected task of type %d (%p)", type, task);
+      XBT_DEBUG("Ignoring unexpected task of type %d (%p)", type, task);
       task_free(task);
       break;
   }
@@ -490,7 +490,7 @@ static void handle_task(node_t node, m_task_t task) {
  */
 static void create(node_t node)
 {
-  DEBUG0("Create a new Chord ring...");
+  XBT_DEBUG("Create a new Chord ring...");
   set_predecessor(node, -1); // -1 means that I have no predecessor
   print_finger_table(node);
 }
@@ -504,7 +504,7 @@ static void create(node_t node)
  */
 static int join(node_t node, int known_id)
 {
-  INFO2("Joining the ring with id %d, knowing node %d", node->id, known_id);
+  XBT_INFO("Joining the ring with id %d, knowing node %d", node->id, known_id);
   set_predecessor(node, -1); // no predecessor (yet)
 
   int i;
@@ -514,7 +514,7 @@ static int join(node_t node, int known_id)
 
   int successor_id = remote_find_successor(node, known_id, node->id);
   if (successor_id == -1) {
-    INFO0("Cannot join the ring.");
+    XBT_INFO("Cannot join the ring.");
   }
   else {
     set_finger(node, 0, successor_id);
@@ -530,7 +530,7 @@ static int join(node_t node, int known_id)
  */
 static void leave(node_t node)
 {
-  DEBUG0("Well Guys! I Think it's time for me to quit ;)");
+  XBT_DEBUG("Well Guys! I Think it's time for me to quit ;)");
   quit_notify(node, 1);  // notify to my successor ( >>> 1 );
   quit_notify(node, -1); // notify my predecessor  ( >>> -1);
   // TODO ...
@@ -556,7 +556,7 @@ static void quit_notify(node_t node, int to)
   const char* to_mailbox = NULL;
   if (to == 1) {    // notify my successor
     to_mailbox = node->fingers[0].mailbox;
-    INFO2("Telling my Successor %d about my departure via mailbox %s",
+    XBT_INFO("Telling my Successor %d about my departure via mailbox %s",
          node->fingers[0].id, to_mailbox);
     req_data->type = TASK_PREDECESSOR_LEAVING;
   }
@@ -567,7 +567,7 @@ static void quit_notify(node_t node, int to)
     }
 
     to_mailbox = node->pred_mailbox;
-    INFO2("Telling my Predecessor %d about my departure via mailbox %s",
+    XBT_INFO("Telling my Predecessor %d about my departure via mailbox %s",
          node->pred_id, to_mailbox);
     req_data->type = TASK_SUCCESSOR_LEAVING;
   }
@@ -617,18 +617,18 @@ static int remote_find_successor(node_t node, int ask_to, int id)
 
   // send a "Find Successor" request to ask_to_id
   m_task_t task_sent = MSG_task_create(NULL, COMP_SIZE, COMM_SIZE, req_data);
-  DEBUG3("Sending a 'Find Successor' request (task %p) to %d for id %d", task_sent, ask_to, id);
+  XBT_DEBUG("Sending a 'Find Successor' request (task %p) to %d for id %d", task_sent, ask_to, id);
   MSG_error_t res = MSG_task_send_with_timeout(task_sent, mailbox, timeout);
 
   if (res != MSG_OK) {
-    DEBUG3("Failed to send the 'Find Successor' request (task %p) to %d for id %d",
+    XBT_DEBUG("Failed to send the 'Find Successor' request (task %p) to %d for id %d",
         task_sent, ask_to, id);
     task_free(task_sent);
   }
   else {
 
     // receive the answer
-    DEBUG3("Sent a 'Find Successor' request (task %p) to %d for key %d, waiting for the answer",
+    XBT_DEBUG("Sent a 'Find Successor' request (task %p) to %d for key %d, waiting for the answer",
         task_sent, ask_to, id);
 
     do {
@@ -640,7 +640,7 @@ static int remote_find_successor(node_t node, int ask_to, int id)
       res = MSG_comm_wait(node->comm_receive, timeout);
 
       if (res != MSG_OK) {
-        DEBUG2("Failed to receive the answer to my 'Find Successor' request (task %p): %d",
+        XBT_DEBUG("Failed to receive the answer to my 'Find Successor' request (task %p): %d",
             task_sent, res);
         stop = 1;
        MSG_comm_destroy(node->comm_receive);
@@ -648,7 +648,7 @@ static int remote_find_successor(node_t node, int ask_to, int id)
       }
       else {
         m_task_t task_received = MSG_comm_get_task(node->comm_receive);
-        DEBUG1("Received a task (%p)", task_received);
+        XBT_DEBUG("Received a task (%p)", task_received);
         task_data_t ans_data = MSG_task_get_data(task_received);
 
        if (MC_IS_ENABLED) {
@@ -663,7 +663,7 @@ static int remote_find_successor(node_t node, int ask_to, int id)
         }
         else {
           // this is our answer
-          DEBUG4("Received the answer to my 'Find Successor' request for id %d (task %p): the successor of key %d is %d",
+          XBT_DEBUG("Received the answer to my 'Find Successor' request for id %d (task %p): the successor of key %d is %d",
               ans_data->request_id, task_received, id, ans_data->answer_id);
           successor = ans_data->answer_id;
           stop = 1;
@@ -697,19 +697,19 @@ static int remote_get_predecessor(node_t node, int ask_to)
   req_data->issuer_host_name = MSG_host_get_name(MSG_host_self());
 
   // send a "Get Predecessor" request to ask_to_id
-  DEBUG1("Sending a 'Get Predecessor' request to %d", ask_to);
+  XBT_DEBUG("Sending a 'Get Predecessor' request to %d", ask_to);
   m_task_t task_sent = MSG_task_create(NULL, COMP_SIZE, COMM_SIZE, req_data);
   MSG_error_t res = MSG_task_send_with_timeout(task_sent, mailbox, timeout);
 
   if (res != MSG_OK) {
-    DEBUG2("Failed to send the 'Get Predecessor' request (task %p) to %d",
+    XBT_DEBUG("Failed to send the 'Get Predecessor' request (task %p) to %d",
         task_sent, ask_to);
     task_free(task_sent);
   }
   else {
 
     // receive the answer
-    DEBUG3("Sent 'Get Predecessor' request (task %p) to %d, waiting for the answer on my mailbox '%s'",
+    XBT_DEBUG("Sent 'Get Predecessor' request (task %p) to %d, waiting for the answer on my mailbox '%s'",
         task_sent, ask_to, req_data->answer_to);
 
     do {
@@ -721,7 +721,7 @@ static int remote_get_predecessor(node_t node, int ask_to)
       res = MSG_comm_wait(node->comm_receive, timeout);
 
       if (res != MSG_OK) {
-        DEBUG2("Failed to receive the answer to my 'Get Predecessor' request (task %p): %d",
+        XBT_DEBUG("Failed to receive the answer to my 'Get Predecessor' request (task %p): %d",
             task_sent, res);
         stop = 1;
        MSG_comm_destroy(node->comm_receive);
@@ -741,7 +741,7 @@ static int remote_get_predecessor(node_t node, int ask_to)
           handle_task(node, task_received);
         }
         else {
-          DEBUG3("Received the answer to my 'Get Predecessor' request (task %p): the predecessor of node %d is %d",
+          XBT_DEBUG("Received the answer to my 'Get Predecessor' request (task %p): the predecessor of node %d is %d",
               task_received, ask_to, ans_data->answer_id);
           predecessor_id = ans_data->answer_id;
           stop = 1;
@@ -781,7 +781,7 @@ int closest_preceding_node(node_t node, int id)
  */
 static void stabilize(node_t node)
 {
-  DEBUG0("Stabilizing node");
+  XBT_DEBUG("Stabilizing node");
 
   // get the predecessor of my immediate successor
   int candidate_id;
@@ -817,7 +817,7 @@ static void notify(node_t node, int predecessor_candidate_id) {
     print_finger_table(node);
   }
   else {
-    DEBUG1("I don't have to change my predecessor to %d", predecessor_candidate_id);
+    XBT_DEBUG("I don't have to change my predecessor to %d", predecessor_candidate_id);
   }
 }
 
@@ -836,7 +836,7 @@ static void remote_notify(node_t node, int notify_id, int predecessor_candidate_
 
   // send a "Notify" request to notify_id
   m_task_t task = MSG_task_create(NULL, COMP_SIZE, COMM_SIZE, req_data);
-  DEBUG2("Sending a 'Notify' request (task %p) to %d", task, notify_id);
+  XBT_DEBUG("Sending a 'Notify' request (task %p) to %d", task, notify_id);
   char mailbox[MAILBOX_NAME_SIZE];
   get_mailbox(notify_id, mailbox);
   MSG_task_dsend(task, mailbox, task_free);
@@ -849,7 +849,7 @@ static void remote_notify(node_t node, int notify_id, int predecessor_candidate_
  */
 static void fix_fingers(node_t node) {
 
-  DEBUG0("Fixing fingers");
+  XBT_DEBUG("Fixing fingers");
   int i = node->next_finger_to_fix;
   int id = find_successor(node, node->id + powers2[i]);
   if (id != -1) {
@@ -869,7 +869,7 @@ static void fix_fingers(node_t node) {
  */
 static void check_predecessor(node_t node)
 {
-  DEBUG0("Checking whether my predecessor is alive");
+  XBT_DEBUG("Checking whether my predecessor is alive");
   // TODO
 }
 
@@ -880,7 +880,7 @@ static void check_predecessor(node_t node)
 static void random_lookup(node_t node)
 {
   int id = 1337; // TODO pick a pseudorandom id
-  DEBUG1("Making a lookup request for id %d", id);
+  XBT_DEBUG("Making a lookup request for id %d", id);
   find_successor(node, id);
 }
 
@@ -905,14 +905,14 @@ int main(int argc, char *argv[])
     int length = strlen("-nb_bits=");
     if (!strncmp(options[0], "-nb_bits=", length) && strlen(options[0]) > length) {
       nb_bits = atoi(options[0] + length);
-      DEBUG1("Set nb_bits to %d", nb_bits);
+      XBT_DEBUG("Set nb_bits to %d", nb_bits);
     }
     else {
 
       length = strlen("-timeout=");
       if (!strncmp(options[0], "-timeout=", length) && strlen(options[0]) > length) {
        timeout = atoi(options[0] + length);
-       DEBUG1("Set timeout to %d", timeout);
+       XBT_DEBUG("Set timeout to %d", timeout);
       }
       else {
        xbt_assert1(0, "Invalid chord option '%s'", options[0]);
@@ -935,8 +935,8 @@ int main(int argc, char *argv[])
   xbt_os_timer_start(timer);
   MSG_error_t res = MSG_main();
   xbt_os_timer_stop(timer);
-  CRITICAL1("Simulation time %lf", xbt_os_timer_elapsed(timer));
-  INFO1("Simulated time: %g", MSG_get_clock());
+  XBT_CRITICAL("Simulation time %lf", xbt_os_timer_elapsed(timer));
+  XBT_INFO("Simulated time: %g", MSG_get_clock());
 
   MSG_clean();
 
index 6fbb1e3..bd00faf 100644 (file)
@@ -47,7 +47,7 @@ int master(int argc, char *argv[])
   int id = -1;
 
   if (argc != 4) {
-    INFO1("Strange number of arguments expected 3 got %d", argc - 1);
+    XBT_INFO("Strange number of arguments expected 3 got %d", argc - 1);
   }
 
   /* data size */
@@ -100,7 +100,7 @@ int slave(int argc, char *argv[])
   char id_alias[10];
 
   if (argc != 2) {
-    INFO1("Strange number of arguments expected 1 got %d", argc - 1);
+    XBT_INFO("Strange number of arguments expected 1 got %d", argc - 1);
   }
 
   id = atoi(argv[1]);
@@ -110,7 +110,7 @@ int slave(int argc, char *argv[])
   a = MSG_task_receive(&(task), id_alias);
 
   if (a != MSG_OK) {
-    INFO0("Hey?! What's up?");
+    XBT_INFO("Hey?! What's up?");
     xbt_assert0(0, "Unexpected behavior.");
   }
 
@@ -126,10 +126,10 @@ int slave(int argc, char *argv[])
 #ifdef HAVE_LATENCY_BOUND_TRACKING
         limited_latency = MSG_task_is_latency_bounded(gl_task_array[id]);
         if (limited_latency) {
-          INFO1("WARNING FLOW[%d] is limited by latency!!", id);
+          XBT_INFO("WARNING FLOW[%d] is limited by latency!!", id);
         }
 #endif
-        INFO5
+        XBT_INFO
             ("===> Estimated Bw of FLOW[%d] : %f ;  message from %s to %s  with remaining : %f",
              id, gl_data_size[id] / elapsed_time, masternames[id],
              slavenames[id], 0.0);
@@ -140,10 +140,10 @@ int slave(int argc, char *argv[])
         limited_latency = MSG_task_is_latency_bounded(gl_task_array[id]);
 
         if (limited_latency) {
-          INFO1("WARNING FLOW[%d] is limited by latency!!", id);
+          XBT_INFO("WARNING FLOW[%d] is limited by latency!!", id);
         }
 #endif
-        INFO5
+        XBT_INFO
             ("===> Estimated Bw of FLOW[%d] : %f ;  message from %s to %s  with remaining : %f",
              id, (gl_data_size[id] - remaining) / elapsed_time,
              masternames[id], slavenames[id], remaining);
index 1d70c27..7b6ef56 100644 (file)
@@ -30,7 +30,7 @@ int sender(int argc, char *argv[])
   double sleep_start_time = atof(argv[5]);
   double sleep_test_time = atof(argv[6]);
 
-  INFO2("sleep_start_time : %f , sleep_test_time : %f", sleep_start_time,
+  XBT_INFO("sleep_start_time : %f , sleep_test_time : %f", sleep_start_time,
         sleep_test_time);
 
   msg_comm_t comm = NULL;
@@ -48,7 +48,7 @@ int sender(int argc, char *argv[])
         MSG_task_create(sprintf_buffer, task_comp_size, task_comm_size,
                         NULL);
     comm = MSG_task_isend(task, mailbox);
-    INFO2("Send to receiver-%ld Task_%d", i % receivers_count, i);
+    XBT_INFO("Send to receiver-%ld Task_%d", i % receivers_count, i);
 
     if (sleep_test_time == 0) {
       MSG_comm_wait(comm, -1);
@@ -66,7 +66,7 @@ int sender(int argc, char *argv[])
     sprintf(mailbox, "receiver-%ld", i % receivers_count);
     task = MSG_task_create("finalize", 0, 0, 0);
     comm = MSG_task_isend(task, mailbox);
-    INFO1("Send to receiver-%ld finalize", i % receivers_count);
+    XBT_INFO("Send to receiver-%ld finalize", i % receivers_count);
     if (sleep_test_time == 0) {
       MSG_comm_wait(comm, -1);
     } else {
@@ -78,7 +78,7 @@ int sender(int argc, char *argv[])
 
   }
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   return 0;
 }                               /* end_of_sender */
 
@@ -92,7 +92,7 @@ int receiver(int argc, char *argv[])
   msg_comm_t res_irecv;
   double sleep_start_time = atof(argv[2]);
   double sleep_test_time = atof(argv[3]);
-  INFO2("sleep_start_time : %f , sleep_test_time : %f", sleep_start_time,
+  XBT_INFO("sleep_start_time : %f , sleep_test_time : %f", sleep_start_time,
         sleep_test_time);
 
   xbt_assert1(sscanf(argv[1], "%d", &id),
@@ -103,7 +103,7 @@ int receiver(int argc, char *argv[])
   sprintf(mailbox, "receiver-%d", id);
   while (1) {
     res_irecv = MSG_task_irecv(&(task), mailbox);
-    INFO0("Wait to receive a task");
+    XBT_INFO("Wait to receive a task");
 
     if (sleep_test_time == 0) {
       res = MSG_comm_wait(res_irecv, -1);
@@ -115,19 +115,19 @@ int receiver(int argc, char *argv[])
       MSG_comm_destroy(res_irecv);
     }
 
-    INFO1("Received \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Received \"%s\"", MSG_task_get_name(task));
     if (!strcmp(MSG_task_get_name(task), "finalize")) {
       MSG_task_destroy(task);
       break;
     }
 
-    INFO1("Processing \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Processing \"%s\"", MSG_task_get_name(task));
     MSG_task_execute(task);
-    INFO1("\"%s\" done", MSG_task_get_name(task));
+    XBT_INFO("\"%s\" done", MSG_task_get_name(task));
     MSG_task_destroy(task);
     task = NULL;
   }
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_receiver */
 
@@ -149,7 +149,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index 2db1409..0c28719 100644 (file)
@@ -40,20 +40,20 @@ int sender(int argc, char *argv[])
         MSG_task_create(sprintf_buffer, task_comp_size, task_comm_size,
                         NULL);
     comm[i] = MSG_task_isend(task, mailbox);
-    INFO2("Send to receiver-%ld Task_%d", i % receivers_count, i);
+    XBT_INFO("Send to receiver-%ld Task_%d", i % receivers_count, i);
   }
   for (i = 0; i < receivers_count; i++) {
     char mailbox[80];
     sprintf(mailbox, "receiver-%ld", i % receivers_count);
     task = MSG_task_create("finalize", 0, 0, 0);
     comm[i + number_of_tasks] = MSG_task_isend(task, mailbox);
-    INFO1("Send to receiver-%ld finalize", i % receivers_count);
+    XBT_INFO("Send to receiver-%ld finalize", i % receivers_count);
 
   }
   /* Here we are waiting for the completion of all communications */
   MSG_comm_waitall(comm, (number_of_tasks + receivers_count), -1);
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   xbt_free(comm);
   return 0;
 }                               /* end_of_sender */
@@ -73,22 +73,22 @@ int receiver(int argc, char *argv[])
   sprintf(mailbox, "receiver-%d", id);
   while (1) {
     res_irecv = MSG_task_irecv(&(task), mailbox);
-    INFO0("Wait to receive a task");
+    XBT_INFO("Wait to receive a task");
     res = MSG_comm_wait(res_irecv, -1);
     xbt_assert0(res == MSG_OK, "MSG_task_get failed");
-    INFO1("Received \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Received \"%s\"", MSG_task_get_name(task));
     if (!strcmp(MSG_task_get_name(task), "finalize")) {
       MSG_task_destroy(task);
       break;
     }
 
-    INFO1("Processing \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Processing \"%s\"", MSG_task_get_name(task));
     MSG_task_execute(task);
-    INFO1("\"%s\" done", MSG_task_get_name(task));
+    XBT_INFO("\"%s\" done", MSG_task_get_name(task));
     MSG_task_destroy(task);
     task = NULL;
   }
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_receiver */
 
@@ -110,7 +110,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index 6fcef1e..ffde174 100644 (file)
@@ -49,7 +49,7 @@ int sender(int argc, char *argv[])
                         task_comm_size / coef, NULL);
     comm = MSG_task_isend(task, mailbox);
     xbt_dynar_push_as(d, msg_comm_t, comm);
-    INFO3("Send to receiver-%ld %s comm_size %f", i % receivers_count,
+    XBT_INFO("Send to receiver-%ld %s comm_size %f", i % receivers_count,
           sprintf_buffer, task_comm_size / coef);
   }
   /* Here we are waiting for the completion of all communications */
@@ -74,7 +74,7 @@ int sender(int argc, char *argv[])
     MSG_task_destroy(task);
   }
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   return 0;
 }                               /* end_of_sender */
 
@@ -95,7 +95,7 @@ int receiver(int argc, char *argv[])
   MSG_process_sleep(10);
   msg_comm_t res_irecv;
   for (i = 0; i < tasks; i++) {
-    INFO1("Wait to receive task %d", i);
+    XBT_INFO("Wait to receive task %d", i);
     task[i] = NULL;
     res_irecv = MSG_task_irecv(&task[i], mailbox);
     xbt_dynar_push_as(comms, msg_comm_t, res_irecv);
@@ -108,9 +108,9 @@ int receiver(int argc, char *argv[])
     xbt_dynar_remove_at(comms, MSG_comm_waitany(comms), &res_irecv);
     task_com = MSG_comm_get_task(res_irecv);
     MSG_comm_destroy(res_irecv);
-    INFO1("Processing \"%s\"", MSG_task_get_name(task_com));
+    XBT_INFO("Processing \"%s\"", MSG_task_get_name(task_com));
     MSG_task_execute(task_com);
-    INFO1("\"%s\" done", MSG_task_get_name(task_com));
+    XBT_INFO("\"%s\" done", MSG_task_get_name(task_com));
     err = MSG_task_destroy(task_com);
     xbt_assert0(err == MSG_OK, "MSG_task_destroy failed");
   }
@@ -122,7 +122,7 @@ int receiver(int argc, char *argv[])
   res_irecv = MSG_task_isend(MSG_task_create(NULL, 0, 0, NULL), mailbox);
   MSG_comm_wait(res_irecv, -1);
   MSG_comm_destroy(res_irecv);
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_receiver */
 
@@ -144,7 +144,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index af49c30..bd81da8 100644 (file)
@@ -22,16 +22,16 @@ static int surf_parse_bypass_platform(void)
   /* allocating memory for the buffer, I think 2kB should be enough */
   surfxml_bufferstack = xbt_new0(char, surfxml_bufferstack_size);
 
-  DEBUG0("<platform>");
+  XBT_DEBUG("<platform>");
   SURFXML_BUFFER_SET(platform_version, "3");
   SURFXML_START_TAG(platform);
 
-  DEBUG0("<AS>");
+  XBT_DEBUG("<AS>");
   SURFXML_BUFFER_SET(AS_id, "AS0");
   SURFXML_BUFFER_SET(AS_routing, "Full");
   SURFXML_START_TAG(AS);
 
-  DEBUG0("<host id=\"host A\" power=\"100000000.00\"/>");
+  XBT_DEBUG("<host id=\"host A\" power=\"100000000.00\"/>");
   SURFXML_BUFFER_SET(host_id, "host A");
   SURFXML_BUFFER_SET(host_power, "100000000.00");
   SURFXML_BUFFER_SET(host_availability, "1.0");
@@ -42,7 +42,7 @@ static int surf_parse_bypass_platform(void)
   SURFXML_START_TAG(host);
   SURFXML_END_TAG(host);
 
-  DEBUG0("<host id=\"host B\" power=\"100000000.00\"/>");
+  XBT_DEBUG("<host id=\"host B\" power=\"100000000.00\"/>");
   SURFXML_BUFFER_SET(host_id, "host B");
   SURFXML_BUFFER_SET(host_power, "100000000.00");
   SURFXML_BUFFER_SET(host_availability, "1.0");
@@ -53,7 +53,7 @@ static int surf_parse_bypass_platform(void)
   SURFXML_START_TAG(host);
   SURFXML_END_TAG(host);
 
-  DEBUG0("<link id=\"LinkA\" bandwidth=\"10000000.0\" latency=\"0.2\"/>");
+  XBT_DEBUG("<link id=\"LinkA\" bandwidth=\"10000000.0\" latency=\"0.2\"/>");
   SURFXML_BUFFER_SET(link_id, "LinkA");
   SURFXML_BUFFER_SET(link_bandwidth, "10000000.0");
   SURFXML_BUFFER_SET(link_bandwidth_file, "");
@@ -65,22 +65,22 @@ static int surf_parse_bypass_platform(void)
   SURFXML_START_TAG(link);
   SURFXML_END_TAG(link);
 
-  DEBUG0("<route src=\"host A\" dst=\"host B\">");
+  XBT_DEBUG("<route src=\"host A\" dst=\"host B\">");
   SURFXML_BUFFER_SET(route_src, "host A");
   SURFXML_BUFFER_SET(route_dst, "host B");
   A_surfxml_route_symmetrical = A_surfxml_route_symmetrical_YES;
   SURFXML_START_TAG(route);
-  DEBUG0("     <link:ctn id=\"LinkA\"/>");
+  XBT_DEBUG("  <link:ctn id=\"LinkA\"/>");
   SURFXML_BUFFER_SET(link_ctn_id, "LinkA");
   A_surfxml_link_ctn_direction = A_surfxml_link_ctn_direction_NONE;
   SURFXML_START_TAG(link_ctn);
   SURFXML_END_TAG(link_ctn);
-  DEBUG0("</route>");
+  XBT_DEBUG("</route>");
   SURFXML_END_TAG(route);
 
-  DEBUG0("</AS>");
+  XBT_DEBUG("</AS>");
   SURFXML_END_TAG(AS);
-  DEBUG0("</platfrom>");
+  XBT_DEBUG("</platfrom>");
   SURFXML_END_TAG(platform);
 
   free(surfxml_bufferstack);
@@ -195,38 +195,38 @@ int master(int argc, char *argv[])
     for (i = 4; i < argc; i++) {
       slaves[i - 4] = MSG_get_host_by_name(argv[i]);
       if (slaves[i - 4] == NULL) {
-        INFO1("Unknown host %s. Stopping Now! ", argv[i]);
+        XBT_INFO("Unknown host %s. Stopping Now! ", argv[i]);
         abort();
       }
     }
   }
 
-  INFO1("Got %d slave(s) :", slaves_count);
+  XBT_INFO("Got %d slave(s) :", slaves_count);
   for (i = 0; i < slaves_count; i++)
-    INFO1("\t %s", slaves[i]->name);
+    XBT_INFO("\t %s", slaves[i]->name);
 
-  INFO1("Got %d task to process :", number_of_tasks);
+  XBT_INFO("Got %d task to process :", number_of_tasks);
 
   for (i = 0; i < number_of_tasks; i++)
-    INFO1("\t\"%s\"", todo[i]->name);
+    XBT_INFO("\t\"%s\"", todo[i]->name);
 
   for (i = 0; i < number_of_tasks; i++) {
-    INFO2("Sending \"%s\" to \"%s\"",
+    XBT_INFO("Sending \"%s\" to \"%s\"",
           todo[i]->name, slaves[i % slaves_count]->name);
     if (MSG_host_self() == slaves[i % slaves_count]) {
-      INFO0("Hey ! It's me ! :)");
+      XBT_INFO("Hey ! It's me ! :)");
     }
     MSG_task_put(todo[i], slaves[i % slaves_count], PORT_22);
-    INFO0("Send completed");
+    XBT_INFO("Send completed");
   }
 
-  INFO0
+  XBT_INFO
       ("All tasks have been dispatched. Let's tell everybody the computation is over.");
   for (i = 0; i < slaves_count; i++)
     MSG_task_put(MSG_task_create("finalize", 0, 0, FINALIZE),
                  slaves[i], PORT_22);
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   free(slaves);
   free(todo);
   return 0;
@@ -235,27 +235,27 @@ int master(int argc, char *argv[])
 /** Receiver function  */
 int slave(int argc, char *argv[])
 {
-  INFO0("I'm a slave");
+  XBT_INFO("I'm a slave");
   while (1) {
     m_task_t task = NULL;
     int a;
     a = MSG_task_get(&(task), PORT_22);
     if (a == MSG_OK) {
-      INFO1("Received \"%s\" ", MSG_task_get_name(task));
+      XBT_INFO("Received \"%s\" ", MSG_task_get_name(task));
       if (MSG_task_get_data(task) == FINALIZE) {
         MSG_task_destroy(task);
         break;
       }
-      INFO1("Processing \"%s\" ", MSG_task_get_name(task));
+      XBT_INFO("Processing \"%s\" ", MSG_task_get_name(task));
       MSG_task_execute(task);
-      INFO1("\"%s\" done ", MSG_task_get_name(task));
+      XBT_INFO("\"%s\" done ", MSG_task_get_name(task));
       MSG_task_destroy(task);
     } else {
-      INFO0("Hey ?! What's up ? ");
+      XBT_INFO("Hey ?! What's up ? ");
       xbt_assert0(0, "Unexpected behavior");
     }
   }
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_slave */
 
@@ -277,7 +277,7 @@ MSG_error_t test_all(void)
 
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index d985c9e..15a2ecd 100644 (file)
@@ -67,38 +67,38 @@ int master(int argc, char *argv[])
     for (i = 4; i < argc; i++) {
       slaves[i - 4] = MSG_get_host_by_name(argv[i]);
       if (slaves[i - 4] == NULL) {
-        INFO1("Unknown host %s. Stopping Now! ", argv[i]);
+        XBT_INFO("Unknown host %s. Stopping Now! ", argv[i]);
         abort();
       }
     }
   }
 
-  INFO1("Got %d slave(s) :", slaves_count);
+  XBT_INFO("Got %d slave(s) :", slaves_count);
   for (i = 0; i < slaves_count; i++)
-    INFO1("\t %s", slaves[i]->name);
+    XBT_INFO("\t %s", slaves[i]->name);
 
-  INFO1("Got %d task to process :", number_of_tasks);
+  XBT_INFO("Got %d task to process :", number_of_tasks);
 
   for (i = 0; i < number_of_tasks; i++)
-    INFO1("\t\"%s\"", todo[i]->name);
+    XBT_INFO("\t\"%s\"", todo[i]->name);
 
   for (i = 0; i < number_of_tasks; i++) {
-    INFO2("Sending \"%s\" to \"%s\"",
+    XBT_INFO("Sending \"%s\" to \"%s\"",
           todo[i]->name, slaves[i % slaves_count]->name);
     if (MSG_host_self() == slaves[i % slaves_count]) {
-      INFO0("Hey ! It's me ! :)");
+      XBT_INFO("Hey ! It's me ! :)");
     }
     MSG_task_put(todo[i], slaves[i % slaves_count], PORT_22);
-    INFO0("Send completed");
+    XBT_INFO("Send completed");
   }
 
-  INFO0
+  XBT_INFO
       ("All tasks have been dispatched. Let's tell everybody the computation is over.");
   for (i = 0; i < slaves_count; i++)
     MSG_task_put(MSG_task_create("finalize", 0, 0, FINALIZE),
                  slaves[i], PORT_22);
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   free(slaves);
   free(todo);
   return 0;
@@ -107,27 +107,27 @@ int master(int argc, char *argv[])
 /** Receiver function  */
 int slave(int argc, char *argv[])
 {
-  INFO0("I'm a slave");
+  XBT_INFO("I'm a slave");
   while (1) {
     m_task_t task = NULL;
     int a;
     a = MSG_task_get(&(task), PORT_22);
     if (a == MSG_OK) {
-      INFO1("Received \"%s\" ", MSG_task_get_name(task));
+      XBT_INFO("Received \"%s\" ", MSG_task_get_name(task));
       if (MSG_task_get_data(task) == FINALIZE) {
         MSG_task_destroy(task);
         break;
       }
-      INFO1("Processing \"%s\" ", MSG_task_get_name(task));
+      XBT_INFO("Processing \"%s\" ", MSG_task_get_name(task));
       MSG_task_execute(task);
-      INFO1("\"%s\" done ", MSG_task_get_name(task));
+      XBT_INFO("\"%s\" done ", MSG_task_get_name(task));
       MSG_task_destroy(task);
     } else {
-      INFO0("Hey ?! What's up ? ");
+      XBT_INFO("Hey ?! What's up ? ");
       xbt_assert0(0, "Unexpected behavior");
     }
   }
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_slave */
 
@@ -147,43 +147,43 @@ static int bypass_deployment(void)
        /* <platform> */
        SURFXML_BUFFER_SET(platform_version, "3");
        SURFXML_START_TAG(platform);
-       DEBUG0("<platform version=\"3\">");
+       XBT_DEBUG("<platform version=\"3\">");
 
-         DEBUG0("      <process host=\"c-0.me\" function=\"master\">");
+         XBT_DEBUG("   <process host=\"c-0.me\" function=\"master\">");
          SURFXML_BUFFER_SET(process_host, "c-0.me");
          SURFXML_BUFFER_SET(process_function, "master");
          SURFXML_BUFFER_SET(process_start_time, "-1.0");
          SURFXML_BUFFER_SET(process_kill_time, "-1.0");
          SURFXML_START_TAG(process);
 
-         DEBUG1("              <argument value=\"%s\"/>",bprintf("%d",nb_host-1));
+         XBT_DEBUG("           <argument value=\"%s\"/>",bprintf("%d",nb_host-1));
          SURFXML_BUFFER_SET(argument_value, bprintf("%d",nb_host-1));
          SURFXML_START_TAG(argument);
          SURFXML_END_TAG(argument);
 
-         DEBUG0("              <argument value=\"5000000\"/>");
+         XBT_DEBUG("           <argument value=\"5000000\"/>");
          SURFXML_BUFFER_SET(argument_value, "5000000");
          SURFXML_START_TAG(argument);
          SURFXML_END_TAG(argument);
 
-         DEBUG0("              <argument value=\"100000\"/>");
+         XBT_DEBUG("           <argument value=\"100000\"/>");
          SURFXML_BUFFER_SET(argument_value, "100000");
          SURFXML_START_TAG(argument);
          SURFXML_END_TAG(argument);
 
        for(i=1 ; i<nb_host ; i++)
        {
-         DEBUG1("              <argument value=\"%s.me\"/>",bprintf("c-%d",i));
+         XBT_DEBUG("           <argument value=\"%s.me\"/>",bprintf("c-%d",i));
          SURFXML_BUFFER_SET(argument_value, bprintf("c-%d.me",i));
          SURFXML_START_TAG(argument);
          SURFXML_END_TAG(argument);
        }
-       DEBUG0("        </process>");
+       XBT_DEBUG("     </process>");
        SURFXML_END_TAG(process);
 
        for(i=1 ; i<nb_host ; i++)
        {
-         DEBUG1("      <process host=\"%s.me\" function=\"slave\"/>",bprintf("c-%d",i));
+         XBT_DEBUG("   <process host=\"%s.me\" function=\"slave\"/>",bprintf("c-%d",i));
          SURFXML_BUFFER_SET(process_host, bprintf("c-%d.me",i));
          SURFXML_BUFFER_SET(process_function, "slave");
          SURFXML_BUFFER_SET(process_start_time, "-1.0");
@@ -192,7 +192,7 @@ static int bypass_deployment(void)
          SURFXML_END_TAG(process);
        }
 
-       DEBUG0("</platform>");
+       XBT_DEBUG("</platform>");
        SURFXML_END_TAG(platform);
 
        free(surfxml_bufferstack);
@@ -212,7 +212,7 @@ MSG_error_t test_all(const char *platform_file)
 
        res = MSG_main();
 
-       INFO1("Simulation time %g", MSG_get_clock());
+       XBT_INFO("Simulation time %g", MSG_get_clock());
        return res;
 }                               /* end_of_test_all */
 
index 978bf70..fd78488 100644 (file)
@@ -32,7 +32,7 @@ int master(int argc, char *argv[])
   long slaves_count = atol(argv[4]);
   int i;
 
-  INFO2("Got %ld slaves and %ld tasks to process", slaves_count,
+  XBT_INFO("Got %ld slaves and %ld tasks to process", slaves_count,
         number_of_tasks);
   for (i = 0; i < number_of_tasks; i++) {
     char mailbox[256];
@@ -45,12 +45,12 @@ int master(int argc, char *argv[])
         MSG_task_create(sprintf_buffer, task_comp_size, task_comm_size,
                         NULL);
     if (number_of_tasks < 10000 || i % 10000 == 0)
-      INFO3("Sending \"%s\" (of %ld) to mailbox \"%s\"", task->name,
+      XBT_INFO("Sending \"%s\" (of %ld) to mailbox \"%s\"", task->name,
             number_of_tasks, mailbox);
     MSG_task_send(task, mailbox);
   }
 
-  INFO0
+  XBT_INFO
       ("All tasks have been dispatched. Let's tell everybody the computation is over.");
   for (i = 0; i < slaves_count; i++) {
     char mailbox[80];
@@ -60,7 +60,7 @@ int master(int argc, char *argv[])
     MSG_task_send(finalize, mailbox);
   }
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   return 0;
 }                               /* end_of_master */
 
@@ -81,19 +81,19 @@ int slave(int argc, char *argv[])
     res = MSG_task_receive(&(task), mailbox);
     xbt_assert0(res == MSG_OK, "MSG_task_get failed");
 
-    INFO1("Received \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Received \"%s\"", MSG_task_get_name(task));
     if (!strcmp(MSG_task_get_name(task), "finalize")) {
       MSG_task_destroy(task);
       break;
     }
 
-    INFO1("Processing \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Processing \"%s\"", MSG_task_get_name(task));
     MSG_task_execute(task);
-    INFO1("\"%s\" done", MSG_task_get_name(task));
+    XBT_INFO("\"%s\" done", MSG_task_get_name(task));
     MSG_task_destroy(task);
     task = NULL;
   }
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_slave */
 
@@ -110,7 +110,7 @@ MSG_error_t test_all(const char *file)  //(void)
 
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index a9ce28a..901d08c 100644 (file)
@@ -53,17 +53,17 @@ int master(int argc, char *argv[])
     for (i = 4; i < argc; i++) {
       slaves[i - 4] = MSG_get_host_by_name(argv[i]);
       if (slaves[i - 4] == NULL) {
-        INFO1("Unknown host %s. Stopping Now! ", argv[i]);
+        XBT_INFO("Unknown host %s. Stopping Now! ", argv[i]);
         abort();
       }
     }
   }
 
-  INFO1("Got %d slave(s) :", slaves_count);
+  XBT_INFO("Got %d slave(s) :", slaves_count);
   for (i = 0; i < slaves_count; i++)
-    INFO1("%s", slaves[i]->name);
+    XBT_INFO("%s", slaves[i]->name);
 
-  INFO1("Got %d task to process :", number_of_tasks);
+  XBT_INFO("Got %d task to process :", number_of_tasks);
 
   for (i = 0; i < number_of_tasks; i++) {
     m_task_t task = MSG_task_create("Task", task_comp_size, task_comm_size,
@@ -74,33 +74,33 @@ int master(int argc, char *argv[])
     a = MSG_task_put_with_timeout(task, slaves[i % slaves_count], PORT_22,
                                   10.0);
     if (a == MSG_OK) {
-      INFO0("Send completed");
+      XBT_INFO("Send completed");
     } else if (a == MSG_HOST_FAILURE) {
-      INFO0
+      XBT_INFO
           ("Gloups. The cpu on which I'm running just turned off!. See you!");
       free(task->data);
       MSG_task_destroy(task);
       free(slaves);
       return 0;
     } else if (a == MSG_TRANSFER_FAILURE) {
-      INFO1
+      XBT_INFO
           ("Mmh. Something went wrong with '%s'. Nevermind. Let's keep going!",
            slaves[i % slaves_count]->name);
       free(task->data);
       MSG_task_destroy(task);
     } else if (a == MSG_TIMEOUT) {
-      INFO1
+      XBT_INFO
           ("Mmh. Got timeouted while speaking to '%s'. Nevermind. Let's keep going!",
            slaves[i % slaves_count]->name);
       free(task->data);
       MSG_task_destroy(task);
     } else {
-      INFO0("Hey ?! What's up ? ");
+      XBT_INFO("Hey ?! What's up ? ");
       xbt_assert0(0, "Unexpected behavior");
     }
   }
 
-  INFO0
+  XBT_INFO
       ("All tasks have been dispatched. Let's tell everybody the computation is over.");
   for (i = 0; i < slaves_count; i++) {
     m_task_t task = MSG_task_create("finalize", 0, 0, FINALIZE);
@@ -108,28 +108,28 @@ int master(int argc, char *argv[])
     if (a == MSG_OK)
       continue;
     if (a == MSG_HOST_FAILURE) {
-      INFO0
+      XBT_INFO
           ("Gloups. The cpu on which I'm running just turned off!. See you!");
       MSG_task_destroy(task);
       free(slaves);
       return 0;
     } else if (a == MSG_TRANSFER_FAILURE) {
-      INFO1("Mmh. Can't reach '%s'! Nevermind. Let's keep going!",
+      XBT_INFO("Mmh. Can't reach '%s'! Nevermind. Let's keep going!",
             slaves[i]->name);
       MSG_task_destroy(task);
     } else if (a == MSG_TIMEOUT) {
-      INFO1
+      XBT_INFO
           ("Mmh. Got timeouted while speaking to '%s'. Nevermind. Let's keep going!",
            slaves[i % slaves_count]->name);
       MSG_task_destroy(task);
     } else {
-      INFO0("Hey ?! What's up ? ");
+      XBT_INFO("Hey ?! What's up ? ");
       xbt_assert2(0, "Unexpected behavior with '%s': %d", slaves[i]->name,
                   a);
     }
   }
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   free(slaves);
   return 0;
 }                               /* end_of_master */
@@ -146,40 +146,40 @@ int slave(int argc, char *argv[])
     a = MSG_task_get(&(task), PORT_22);
     time2 = MSG_get_clock();
     if (a == MSG_OK) {
-      INFO1("Received \"%s\"", MSG_task_get_name(task));
+      XBT_INFO("Received \"%s\"", MSG_task_get_name(task));
       if (MSG_task_get_data(task) == FINALIZE) {
         MSG_task_destroy(task);
         break;
       }
       if (time1 < *((double *) task->data))
         time1 = *((double *) task->data);
-      INFO1("Communication time : \"%f\"", time2 - time1);
-      INFO1("Processing \"%s\"", MSG_task_get_name(task));
+      XBT_INFO("Communication time : \"%f\"", time2 - time1);
+      XBT_INFO("Processing \"%s\"", MSG_task_get_name(task));
       a = MSG_task_execute(task);
       if (a == MSG_OK) {
-        INFO1("\"%s\" done", MSG_task_get_name(task));
+        XBT_INFO("\"%s\" done", MSG_task_get_name(task));
         free(task->data);
         MSG_task_destroy(task);
       } else if (a == MSG_HOST_FAILURE) {
-        INFO0
+        XBT_INFO
             ("Gloups. The cpu on which I'm running just turned off!. See you!");
         return 0;
       } else {
-        INFO0("Hey ?! What's up ? ");
+        XBT_INFO("Hey ?! What's up ? ");
         xbt_assert0(0, "Unexpected behavior");
       }
     } else if (a == MSG_HOST_FAILURE) {
-      INFO0
+      XBT_INFO
           ("Gloups. The cpu on which I'm running just turned off!. See you!");
       return 0;
     } else if (a == MSG_TRANSFER_FAILURE) {
-      INFO0("Mmh. Something went wrong. Nevermind. Let's keep going!");
+      XBT_INFO("Mmh. Something went wrong. Nevermind. Let's keep going!");
     } else {
-      INFO0("Hey ?! What's up ? ");
+      XBT_INFO("Hey ?! What's up ? ");
       xbt_assert0(0, "Unexpected behavior");
     }
   }
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_slave */
 
@@ -201,7 +201,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index 3e6a07e..efcb433 100644 (file)
@@ -70,30 +70,30 @@ int master(int argc, char *argv[])
     }
   }
 
-  INFO2("Got %d slaves and %d tasks to process", slaves_count,
+  XBT_INFO("Got %d slaves and %d tasks to process", slaves_count,
         number_of_tasks);
   for (i = 0; i < slaves_count; i++)
-    DEBUG1("%s", slaves[i]->name);
+    XBT_DEBUG("%s", slaves[i]->name);
 
   for (i = 0; i < number_of_tasks; i++) {
-    INFO2("Sending \"%s\" to \"%s\"",
+    XBT_INFO("Sending \"%s\" to \"%s\"",
           todo[i]->name, slaves[i % slaves_count]->name);
     if (MSG_host_self() == slaves[i % slaves_count]) {
-      INFO0("Hey ! It's me ! :)");
+      XBT_INFO("Hey ! It's me ! :)");
     }
 
     MSG_task_put(todo[i], slaves[i % slaves_count], PORT_22);
-    INFO0("Sent");
+    XBT_INFO("Sent");
   }
 
-  INFO0
+  XBT_INFO
       ("All tasks have been dispatched. Let's tell everybody the computation is over.");
   for (i = 0; i < slaves_count; i++) {
     m_task_t finalize = MSG_task_create("finalize", 0, 0, FINALIZE);
     MSG_task_put(finalize, slaves[i], PORT_22);
   }
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   free(slaves);
   free(todo);
   return 0;
@@ -108,19 +108,19 @@ int slave(int argc, char *argv[])
     res = MSG_task_get(&(task), PORT_22);
     xbt_assert0(res == MSG_OK, "MSG_task_get failed");
 
-    INFO1("Received \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Received \"%s\"", MSG_task_get_name(task));
     if (!strcmp(MSG_task_get_name(task), "finalize")) {
       MSG_task_destroy(task);
       break;
     }
 
-    INFO1("Processing \"%s\"", MSG_task_get_name(task));
+    XBT_INFO("Processing \"%s\"", MSG_task_get_name(task));
     MSG_task_execute(task);
-    INFO1("\"%s\" done", MSG_task_get_name(task));
+    XBT_INFO("\"%s\" done", MSG_task_get_name(task));
     MSG_task_destroy(task);
     task = NULL;
   }
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_slave */
 
@@ -138,7 +138,7 @@ int forwarder(int argc, char *argv[])
     for (i = 1; i < argc; i++) {
       slaves[i - 1] = MSG_get_host_by_name(argv[i]);
       if (slaves[i - 1] == NULL) {
-        INFO1("Unknown host %s. Stopping Now! ", argv[i]);
+        XBT_INFO("Unknown host %s. Stopping Now! ", argv[i]);
         abort();
       }
     }
@@ -150,9 +150,9 @@ int forwarder(int argc, char *argv[])
     int a;
     a = MSG_task_get(&(task), PORT_22);
     if (a == MSG_OK) {
-      INFO1("Received \"%s\"", MSG_task_get_name(task));
+      XBT_INFO("Received \"%s\"", MSG_task_get_name(task));
       if (MSG_task_get_data(task) == FINALIZE) {
-        INFO0
+        XBT_INFO
             ("All tasks have been dispatched. Let's tell everybody the computation is over.");
         for (i = 0; i < slaves_count; i++)
           MSG_task_put(MSG_task_create("finalize", 0, 0, FINALIZE),
@@ -160,18 +160,18 @@ int forwarder(int argc, char *argv[])
         MSG_task_destroy(task);
         break;
       }
-      INFO2("Sending \"%s\" to \"%s\"",
+      XBT_INFO("Sending \"%s\" to \"%s\"",
             MSG_task_get_name(task), slaves[i % slaves_count]->name);
       MSG_task_put(task, slaves[i % slaves_count], PORT_22);
       i++;
     } else {
-      INFO0("Hey ?! What's up ? ");
+      XBT_INFO("Hey ?! What's up ? ");
       xbt_assert0(0, "Unexpected behavior");
     }
   }
   xbt_free(slaves);
 
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_forwarder */
 
@@ -194,7 +194,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index fdf0e48..e4e6759 100644 (file)
@@ -30,7 +30,7 @@ int master(int argc, char *argv[])
 
   int i;
 
-  INFO2("Got %ld slaves and %ld tasks to process", slaves_count,
+  XBT_INFO("Got %ld slaves and %ld tasks to process", slaves_count,
         number_of_tasks);
 
   for (i = 0; i < number_of_tasks; i++) {
@@ -44,13 +44,13 @@ int master(int argc, char *argv[])
         MSG_task_create(sprintf_buffer, task_comp_size, task_comm_size,
                         NULL);
     if (number_of_tasks < 10000 || i % 10000 == 0)
-      INFO3("Sending \"%s\" (of %ld) to mailbox \"%s\"", task->name,
+      XBT_INFO("Sending \"%s\" (of %ld) to mailbox \"%s\"", task->name,
             number_of_tasks, mailbox);
 
     MSG_task_send(task, mailbox);
   }
 
-  INFO0
+  XBT_INFO
       ("All tasks have been dispatched. Let's tell everybody the computation is over.");
   for (i = 0; i < slaves_count; i++) {
     char mailbox[80];
@@ -60,7 +60,7 @@ int master(int argc, char *argv[])
     MSG_task_send(finalize, mailbox);
   }
 
-//  INFO0("Goodbye now!");
+//  XBT_INFO("Goodbye now!");
   return 0;
 }                               /* end_of_master */
 
@@ -81,18 +81,18 @@ int slave(int argc, char *argv[])
     res = MSG_task_receive(&(task), mailbox);
     xbt_assert0(res == MSG_OK, "MSG_task_get failed");
 
-//  INFO1("Received \"%s\"", MSG_task_get_name(task));
+//  XBT_INFO("Received \"%s\"", MSG_task_get_name(task));
     if (!strcmp(MSG_task_get_name(task), "finalize")) {
       MSG_task_destroy(task);
       break;
     }
-//    INFO1("Processing \"%s\"", MSG_task_get_name(task));
+//    XBT_INFO("Processing \"%s\"", MSG_task_get_name(task));
     MSG_task_execute(task);
-//    INFO1("\"%s\" done", MSG_task_get_name(task));
+//    XBT_INFO("\"%s\" done", MSG_task_get_name(task));
     MSG_task_destroy(task);
     task = NULL;
   }
-  INFO0("I'm done. See you!");
+  XBT_INFO("I'm done. See you!");
   return 0;
 }                               /* end_of_slave */
 
@@ -114,7 +114,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index 38f9051..16425d7 100644 (file)
@@ -26,7 +26,7 @@ int server(int argc, char *argv[])
   }
   MC_assert(atoi(MSG_task_get_name(task)) == 3);
 
-  INFO0("OK");
+  XBT_INFO("OK");
   return 0;
 }
 
@@ -39,7 +39,7 @@ int client(int argc, char *argv[])
 
   MSG_task_send(task, "mymailbox");
 
-  INFO0("Sent!");
+  XBT_INFO("Sent!");
   return 0;
 }
 
index 22f3d54..85af8dc 100644 (file)
@@ -21,27 +21,27 @@ int server(int argc, char *argv[])
   val1 = (long) MSG_task_get_data(task1);
   MSG_task_destroy(task1);
   task1 = NULL;
-  INFO1("Received %lu", val1);
+  XBT_INFO("Received %lu", val1);
 
   MSG_task_receive(&task2, "mymailbox");
   val2 = (long) MSG_task_get_data(task2);
   MSG_task_destroy(task2);
   task2 = NULL;
-  INFO1("Received %lu", val2);
+  XBT_INFO("Received %lu", val2);
 
   MC_assert(min(val1, val2) == 1);
 
   MSG_task_receive(&task1, "mymailbox");
   val1 = (long) MSG_task_get_data(task1);
   MSG_task_destroy(task1);
-  INFO1("Received %lu", val1);
+  XBT_INFO("Received %lu", val1);
 
   MSG_task_receive(&task2, "mymailbox");
   val2 = (long) MSG_task_get_data(task2);
   MSG_task_destroy(task2);
-  INFO1("Received %lu", val2);
+  XBT_INFO("Received %lu", val2);
 
-  INFO0("OK");
+  XBT_INFO("OK");
   return 0;
 }
 
@@ -52,10 +52,10 @@ int client(int argc, char *argv[])
   m_task_t task2 =
       MSG_task_create("task", 0, 10000, (void *) atol(argv[1]));
 
-  INFO1("Send %d!", atoi(argv[1]));
+  XBT_INFO("Send %d!", atoi(argv[1]));
   MSG_task_send(task1, "mymailbox");
 
-  INFO1("Send %d!", atoi(argv[1]));
+  XBT_INFO("Send %d!", atoi(argv[1]));
   MSG_task_send(task2, "mymailbox");
 
   return 0;
index 5853337..8e33b31 100644 (file)
@@ -27,11 +27,11 @@ int server(int argc, char *argv[])
   MSG_comm_wait(comm2, -1);
 
   val1 = (long) MSG_task_get_data(task1);
-  INFO1("Received %lu", val1);
+  XBT_INFO("Received %lu", val1);
 
   MC_assert(val1 == 2);
 
-  INFO0("OK");
+  XBT_INFO("OK");
   return 0;
 }
 
@@ -44,7 +44,7 @@ int client(int argc, char *argv[])
 
   mbox = bprintf("mymailbox%s", argv[1]);
 
-  INFO1("Send %d!", atoi(argv[1]));
+  XBT_INFO("Send %d!", atoi(argv[1]));
   comm = MSG_task_isend(task1, mbox);
   MSG_comm_wait(comm, -1);
 
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;
 }
 
index b5039c7..c7e474d 100644 (file)
@@ -9,8 +9,8 @@ int server(int argc, char *argv[])
 {
   int val;
   val = MC_random(3, 6);
-  INFO1("val=%d", val);
-  INFO0("OK");
+  XBT_INFO("val=%d", val);
+  XBT_INFO("OK");
   return 0;
 }
 
index 0d83c80..5abb763 100644 (file)
@@ -16,19 +16,19 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test,
 static int emigrant(int argc, char *argv[])
 {
   m_task_t task;
-  INFO0
+  XBT_INFO
       ("I'll look for a new job on another machine where the grass is greener.");
   MSG_process_change_host(MSG_get_host_by_name("Boivin"));
-  INFO0("Yeah, found something to do");
+  XBT_INFO("Yeah, found something to do");
   task = MSG_task_create("job", 98095000, 0, NULL);
   MSG_task_execute(task);
   MSG_task_destroy(task);
   MSG_process_sleep(2);
-  INFO0("Moving back home after work");
+  XBT_INFO("Moving back home after work");
   MSG_process_change_host(MSG_get_host_by_name("Jacquelin"));
   MSG_process_change_host(MSG_get_host_by_name("Boivin"));
   MSG_process_sleep(4);
-  INFO0("Uh, nothing to do here. Stopping now");
+  XBT_INFO("Uh, nothing to do here. Stopping now");
   return 0;
 }                               /* end_of_emigrant */
 
@@ -37,7 +37,7 @@ static int emigrant(int argc, char *argv[])
  */
 static int policeman(int argc, char *argv[])
 {
-  INFO0
+  XBT_INFO
       ("No function in the API to move the emigrant back, so do nothing.");
   return 0;
 }                               /* end_of_policeman */
@@ -51,8 +51,8 @@ int main(int argc, char *argv[])
   /* Argument checking */
   MSG_global_init(&argc, argv);
   if (argc < 3) {
-    CRITICAL1("Usage: %s platform_file deployment_file\n", argv[0]);
-    CRITICAL1("example: %s msg_platform.xml msg_deployment_suspend.xml\n",
+    XBT_CRITICAL("Usage: %s platform_file deployment_file\n", argv[0]);
+    XBT_CRITICAL("example: %s msg_platform.xml msg_deployment_suspend.xml\n",
               argv[0]);
     exit(1);
   }
@@ -66,7 +66,7 @@ int main(int argc, char *argv[])
 
   /* Run the simulation */
   res = MSG_main();
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   if (res == MSG_OK)
     res = MSG_clean();
 
index 39fef0c..a4cddf5 100644 (file)
@@ -22,7 +22,7 @@ int node(int argc, char** argv)
     for(j=0; j < WORK; j++);
 
     MSG_task_execute(task);
-    INFO0("Task successfully executed");
+    XBT_INFO("Task successfully executed");
     MSG_task_destroy(task);
   }
 
@@ -46,7 +46,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index bef800a..5cae6f5 100644 (file)
@@ -28,7 +28,7 @@ int master(int argc, char** argv)
     for(j=0; j < WORK; j++);
 
     MSG_task_send(task, mailbox);
-    INFO1("Task sent to %s", mailbox);
+    XBT_INFO("Task sent to %s", mailbox);
   }
 
   return 0;
@@ -45,7 +45,7 @@ int slave(int argc, char **argv)
 
   for(i=0; i < MAX_ITER; i++){
     MSG_task_receive(&task, mailbox);
-    INFO1("Task received to %s", mailbox);
+    XBT_INFO("Task received to %s", mailbox);
     MSG_task_destroy(task);
     task=NULL;
   }
@@ -71,7 +71,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
index 3a3825c..ced1cf2 100644 (file)
@@ -53,7 +53,7 @@ int test(int argc, char *argv[])
 /*   free(communication_amount); */
 /*   free(computation_amount); */
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   free(slaves);
   return 0;
 }
@@ -73,7 +73,7 @@ MSG_error_t test_all(const char *platform_file)
   res = MSG_main();
   xbt_free(hosts);
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }
 
index 95b9c9f..53ac24b 100644 (file)
@@ -41,7 +41,7 @@ int execute(int argc, char *argv[])
 
 
   host_list_size = argc - 3;
-  DEBUG1("host_list_size=%d", host_list_size);
+  XBT_DEBUG("host_list_size=%d", host_list_size);
   m_host_list = calloc(host_list_size, sizeof(m_host_t));
   for (i = 1; i <= host_list_size; i++) {
     m_host_list[i - 1] = MSG_get_host_by_name(argv[i]);
@@ -76,7 +76,7 @@ int execute(int argc, char *argv[])
   xbt_free(m_host_list);
   execution_time = MSG_get_clock() - execution_time;
 
-  INFO1("execution_time=%g ", execution_time);
+  XBT_INFO("execution_time=%g ", execution_time);
 
   return 0;
 }
@@ -96,7 +96,7 @@ int redistribute(int argc, char *argv[])
 
 
   host_list_size = argc - 2;
-  DEBUG1("host_list_size=%d", host_list_size);
+  XBT_DEBUG("host_list_size=%d", host_list_size);
   m_host_list = calloc(host_list_size, sizeof(m_host_t));
   for (i = 1; i <= host_list_size; i++) {
     m_host_list[i - 1] = MSG_get_host_by_name(argv[i]);
@@ -128,7 +128,7 @@ int redistribute(int argc, char *argv[])
   xbt_free(m_host_list);
   redistribution_time = MSG_get_clock() - redistribution_time;
 
-  INFO1("redistribution_time=%g ", redistribution_time);
+  XBT_INFO("redistribution_time=%g ", redistribution_time);
 
   return 0;
 }
@@ -153,7 +153,7 @@ MSG_error_t test_all(const char *platform_file,
 
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }
 
index 7075eb9..e5b6c62 100644 (file)
@@ -25,7 +25,7 @@ static int test(int argc, char *argv[])
   res = sscanf(argv[2], "%lg", &priority);
   xbt_assert1(res, "Invalid argument %s\n", argv[2]);
 
-  INFO2("Hello! Running a task of size %g with priority %g",
+  XBT_INFO("Hello! Running a task of size %g with priority %g",
         computation_amount, priority);
   task = MSG_task_create("Task", computation_amount, 0.0, NULL);
   MSG_task_set_priority(task, priority);
@@ -33,7 +33,7 @@ static int test(int argc, char *argv[])
   MSG_task_execute(task);
   MSG_task_destroy(task);
 
-  INFO0("Goodbye now!");
+  XBT_INFO("Goodbye now!");
   return 0;
 }
 
@@ -52,7 +52,7 @@ static MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }
 
index 5501a25..fcf9519 100644 (file)
@@ -32,24 +32,24 @@ int alice(int argc, char *argv[])
   const char *value;
   char exist[] = "SG_TEST_Hdd";
 
-  INFO0("== Print the properties of the host");
+  XBT_INFO("== Print the properties of the host");
   xbt_dict_foreach(props, cursor, key, data)
-      INFO2("  Host property: '%s' -> '%s'", key, data);
+      XBT_INFO("  Host property: '%s' -> '%s'", key, data);
 
-  INFO0("== Try to get a host property that does not exist");
+  XBT_INFO("== Try to get a host property that does not exist");
   value = MSG_host_get_property_value(host1, noexist);
   xbt_assert0(!value, "The key exists (it's not supposed to)");
 
-  INFO0("== Try to get a host property that does exist");
+  XBT_INFO("== Try to get a host property that does exist");
   value = MSG_host_get_property_value(host1, exist);
   xbt_assert1(value, "\tProperty %s is undefined (where it should)",
               exist);
   xbt_assert2(!strcmp(value, "180"),
               "\tValue of property %s is defined to %s (where it should be 180)",
               exist, value);
-  INFO2("   Property: %s old value: %s", exist, value);
+  XBT_INFO("   Property: %s old value: %s", exist, value);
 
-  INFO0("== Trying to modify a host property");
+  XBT_INFO("== Trying to modify a host property");
   xbt_dict_set(props, exist, xbt_strdup("250"), xbt_free_f);
 
   /* Test if we have changed the value */
@@ -58,7 +58,7 @@ int alice(int argc, char *argv[])
   xbt_assert2(!strcmp(value, "250"),
               "Value of property %s is defined to %s (where it should be 250)",
               exist, value);
-  INFO2("   Property: %s old value: %s", exist, value);
+  XBT_INFO("   Property: %s old value: %s", exist, value);
 
   return 0;
 }
@@ -72,11 +72,11 @@ int bob(int argc, char *argv[])
   const char *noexist = "UnknownProcessProp";
   const char *value;
 
-  INFO0("== Print the properties of the process");
+  XBT_INFO("== Print the properties of the process");
   xbt_dict_foreach(props, cursor, key, data)
-      INFO2("   Process property: %s -> %s", key, data);
+      XBT_INFO("   Process property: %s -> %s", key, data);
 
-  INFO0("== Try to get a process property that does not exist");
+  XBT_INFO("== Try to get a process property that does not exist");
 
   value = MSG_process_get_property_value(MSG_process_self(), noexist);
   xbt_assert0(!value, "The property is defined (it shouldnt)");
index a16f9cc..97f162d 100644 (file)
@@ -40,16 +40,16 @@ int sender(int argc, char *argv[])
   char sprintf_buffer_la[64];
   char sprintf_buffer_bw[64];
 
-  INFO0("sender");
+  XBT_INFO("sender");
 
   /*host = xbt_new0(m_host_t,1); */
 
-  INFO1("host = %s", argv[1]);
+  XBT_INFO("host = %s", argv[1]);
 
   host = MSG_get_host_by_name(argv[1]);
 
   if (host == NULL) {
-    INFO1("Unknown host %s. Stopping Now! ", argv[1]);
+    XBT_INFO("Unknown host %s. Stopping Now! ", argv[1]);
     abort();
   }
 
@@ -60,7 +60,7 @@ int sender(int argc, char *argv[])
       MSG_task_create(sprintf_buffer_la, 0.0, task_comm_size_lat, NULL);
   task_la->data = xbt_new(double, 1);
   *(double *) task_la->data = time;
-  INFO1("task_la->data = %le", *((double *) task_la->data));
+  XBT_INFO("task_la->data = %le", *((double *) task_la->data));
   MSG_task_put(task_la, host, PORT_22);
 
   /* Bandwidth */
@@ -70,7 +70,7 @@ int sender(int argc, char *argv[])
       MSG_task_create(sprintf_buffer_bw, 0.0, task_comm_size_bw, NULL);
   task_bw->data = xbt_new(double, 1);
   *(double *) task_bw->data = time;
-  INFO1("task_bw->data = %le", *((double *) task_bw->data));
+  XBT_INFO("task_bw->data = %le", *((double *) task_bw->data));
   MSG_task_put(task_bw, host, PORT_22);
 
   return 0;
@@ -85,7 +85,7 @@ int receiver(int argc, char *argv[])
   int a;
   double communication_time = 0;
 
-  INFO0("receiver");
+  XBT_INFO("receiver");
 
   time = MSG_get_clock();
 
@@ -96,11 +96,11 @@ int receiver(int argc, char *argv[])
     sender_time = *((double *) (task_la->data));
     time = sender_time;
     communication_time = time1 - time;
-    INFO1("Task received : %s", task_la->name);
+    XBT_INFO("Task received : %s", task_la->name);
     xbt_free(task_la->data);
     MSG_task_destroy(task_la);
-    INFO1("Communic. time %le", communication_time);
-    INFO1("--- la %f ----", communication_time);
+    XBT_INFO("Communic. time %le", communication_time);
+    XBT_INFO("--- la %f ----", communication_time);
   } else {
     xbt_assert0(0, "Unexpected behavior");
   }
@@ -113,11 +113,11 @@ int receiver(int argc, char *argv[])
     sender_time = *((double *) (task_bw->data));
     time = sender_time;
     communication_time = time1 - time;
-    INFO1("Task received : %s", task_bw->name);
+    XBT_INFO("Task received : %s", task_bw->name);
     xbt_free(task_bw->data);
     MSG_task_destroy(task_bw);
-    INFO1("Communic. time %le", communication_time);
-    INFO1("--- bw %f ----", task_comm_size_bw / communication_time);
+    XBT_INFO("Communic. time %le", communication_time);
+    XBT_INFO("--- bw %f ----", task_comm_size_bw / communication_time);
   } else {
     xbt_assert0(0, "Unexpected behavior");
   }
@@ -136,7 +136,7 @@ MSG_error_t test_all(const char *platform_file,
 
 
 
-  INFO0("test_all");
+  XBT_INFO("test_all");
 
   /*  Simulation setting */
   MSG_set_channel_number(MAX_CHANNEL);
@@ -168,9 +168,9 @@ int main(int argc, char *argv[])
 
 
   if (argc != 3) {
-    CRITICAL1("Usage: %s platform_file deployment_file <model>\n",
+    XBT_CRITICAL("Usage: %s platform_file deployment_file <model>\n",
               argv[0]);
-    CRITICAL1
+    XBT_CRITICAL
         ("example: %s msg_platform.xml msg_deployment.xml KCCFLN05_Vegas\n",
          argv[0]);
     exit(1);
@@ -187,7 +187,7 @@ int main(int argc, char *argv[])
 
   res = test_all(argv[1], argv[2]);
 
-  INFO1("Total simulation time: %le", MSG_get_clock());
+  XBT_INFO("Total simulation time: %le", MSG_get_clock());
 
   MSG_clean();
 
index c8e045a..2dc8304 100644 (file)
@@ -21,10 +21,10 @@ typedef enum {
 /** Lazy guy function. This process suspends itself asap.  */
 static int lazy_guy(int argc, char *argv[])
 {
-  INFO0("Nobody's watching me ? Let's go to sleep.");
+  XBT_INFO("Nobody's watching me ? Let's go to sleep.");
   MSG_process_suspend(MSG_process_self());
-  INFO0("Uuuh ? Did somebody call me ?");
-  INFO0("Mmmh, goodbye now.");
+  XBT_INFO("Uuuh ? Did somebody call me ?");
+  XBT_INFO("Mmmh, goodbye now.");
   return 0;
 }                               /* end_of_lazy_guy */
 
@@ -34,13 +34,13 @@ static int dream_master(int argc, char *argv[])
 {
   m_process_t lazy = NULL;
 
-  INFO0("Let's create a lazy guy.");
+  XBT_INFO("Let's create a lazy guy.");
   lazy = MSG_process_create("Lazy", lazy_guy, NULL, MSG_host_self());
-  INFO0("Let's wait a little bit...");
+  XBT_INFO("Let's wait a little bit...");
   MSG_process_sleep(10.0);
-  INFO0("Let's wake the lazy guy up! >:) BOOOOOUUUHHH!!!!");
+  XBT_INFO("Let's wake the lazy guy up! >:) BOOOOOUUUHHH!!!!");
   MSG_process_resume(lazy);
-  INFO0("OK, goodbye now.");
+  XBT_INFO("OK, goodbye now.");
   return 0;
 }                               /* end_of_dram_master */
 
@@ -60,7 +60,7 @@ static MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }                               /* end_of_test_all */
 
@@ -72,8 +72,8 @@ int main(int argc, char *argv[])
 
   MSG_global_init(&argc, argv);
   if (argc < 3) {
-    CRITICAL1("Usage: %s platform_file deployment_file\n", argv[0]);
-    CRITICAL1("example: %s msg_platform.xml msg_deployment_suspend.xml\n",
+    XBT_CRITICAL("Usage: %s platform_file deployment_file\n", argv[0]);
+    XBT_CRITICAL("example: %s msg_platform.xml msg_deployment_suspend.xml\n",
               argv[0]);
     exit(1);
   }
index a57d856..305945b 100644 (file)
@@ -39,11 +39,11 @@ int master(int argc, char *argv[])
                                                        task_comm_size,
                                                        NULL);
     MSG_task_send(task_s,mailbox);
-    INFO1("Send Data to \"%s\"", mailbox);
+    XBT_INFO("Send Data to \"%s\"", mailbox);
 
        sprintf(mailbox, "host%d", num);
        MSG_task_receive(&(task_r), mailbox);
-       INFO1("Received \"%s\"", MSG_task_get_name(task_r));
+       XBT_INFO("Received \"%s\"", MSG_task_get_name(task_r));
        return 0;
 }
 
@@ -59,7 +59,7 @@ int slave(int argc, char *argv[])
 
        sprintf(mailbox, "host%d", num);
        MSG_task_receive(&(task_r), mailbox);
-       INFO1("Received \"%s\"", MSG_task_get_name(task_r));
+       XBT_INFO("Received \"%s\"", MSG_task_get_name(task_r));
        sprintf(mailbox, "host%d", num+1);
        if(num == totalHosts-1)
                sprintf(mailbox, "host%d", 0);
@@ -69,7 +69,7 @@ int slave(int argc, char *argv[])
                                                        task_comm_size,
                                                        NULL);
        MSG_task_send(task_s, mailbox);
-       INFO1("Send Data to \"%s\"", mailbox);
+       XBT_INFO("Send Data to \"%s\"", mailbox);
 
        return 0;
 }
@@ -92,7 +92,7 @@ static int surf_parse_bypass_application(void)
 
        SURFXML_START_TAG(platform);
 
-       DEBUG1("process : %s en master",MSG_host_get_name(hosts[0]));
+       XBT_DEBUG("process : %s en master",MSG_host_get_name(hosts[0]));
        /*   <process host="host A" function="master"> */
        SURFXML_BUFFER_SET(process_host, MSG_host_get_name(hosts[0]));
        SURFXML_BUFFER_SET(process_function, "master");
@@ -108,7 +108,7 @@ static int surf_parse_bypass_application(void)
 
        for(i=1;i<totalHosts;i++)
        {
-       DEBUG1("process : %s en slave",MSG_host_get_name(hosts[i]));
+       XBT_DEBUG("process : %s en slave",MSG_host_get_name(hosts[i]));
        /*   <process host="host A" function="slave"> */
        SURFXML_BUFFER_SET(process_host,MSG_host_get_name(hosts[i]) );
        SURFXML_BUFFER_SET(process_function, "slave");
@@ -148,7 +148,7 @@ int main(int argc, char **argv)
 
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
 
   MSG_clean();
 
index 426e182..9556b41 100644 (file)
@@ -31,9 +31,9 @@ int test_trace(int argc, char *argv[])
   task_comp_size = atof(argv[1]);
   task_prio = atof(argv[2]);
 
-  INFO0("Testing the trace integration cpu model: CpuTI");
-  INFO1("Task size: %lf", task_comp_size);
-  INFO1("Task prio: %lf", task_prio);
+  XBT_INFO("Testing the trace integration cpu model: CpuTI");
+  XBT_INFO("Task size: %lf", task_comp_size);
+  XBT_INFO("Task prio: %lf", task_prio);
 
   /* Create and execute a single task. */
   task = MSG_task_create("proc 0", task_comp_size, 0, NULL);
@@ -41,7 +41,7 @@ int test_trace(int argc, char *argv[])
   MSG_task_execute(task);
   MSG_task_destroy(task);
 
-  INFO0("Test finished");
+  XBT_INFO("Test finished");
 
 
   return 0;
index b10abcc..400de0a 100644 (file)
@@ -97,7 +97,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }
 
index 3c35c82..d0355c9 100644 (file)
@@ -117,7 +117,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }
 
index d3e139c..1878229 100644 (file)
@@ -25,7 +25,7 @@ static int emigrant(int argc, char *argv[])
     MSG_task_receive(&(task), "master_mailbox");
     destination = (char*)MSG_task_get_data (task);
     if (!destination) break; //there is no destination, die
-    INFO1("Migrating to %s", destination);
+    XBT_INFO("Migrating to %s", destination);
     MSG_process_change_host(MSG_get_host_by_name(destination));
     MSG_process_sleep(2); // I am tired, have to sleep for 2 seconds
     xbt_free (destination);
@@ -74,8 +74,8 @@ int main(int argc, char *argv[])
   /* Argument checking */
   MSG_global_init(&argc, argv);
   if (argc < 3) {
-    CRITICAL1("Usage: %s platform_file deployment_file\n", argv[0]);
-    CRITICAL1("example: %s msg_platform.xml msg_deployment_suspend.xml\n",
+    XBT_CRITICAL("Usage: %s platform_file deployment_file\n", argv[0]);
+    XBT_CRITICAL("example: %s msg_platform.xml msg_deployment_suspend.xml\n",
               argv[0]);
     exit(1);
   }
@@ -92,7 +92,7 @@ int main(int argc, char *argv[])
 
   /* Run the simulation */
   res = MSG_main();
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   if (res == MSG_OK)
     res = MSG_clean();
 
index 4d01940..13a3c74 100644 (file)
@@ -27,7 +27,7 @@ int master(int argc, char *argv[])
   double task_comp_size = atof(argv[2]);
   double task_comm_size = atof(argv[3]);
   long slaves_count = atol(argv[4]);
-  INFO4("master %ld %f %f %ld", number_of_tasks, task_comp_size,
+  XBT_INFO("master %ld %f %f %ld", number_of_tasks, task_comp_size,
         task_comm_size, slaves_count);
 
   int i;
@@ -63,7 +63,7 @@ int slave(int argc, char *argv[])
   while (1) {
     res = MSG_task_receive(&(task), "master_mailbox");
     if (res != MSG_OK) {
-      INFO0("error");
+      XBT_INFO("error");
       break;
     }
 
@@ -73,9 +73,9 @@ int slave(int argc, char *argv[])
       break;
     }
 
-    INFO1("Executing task %f", MSG_task_get_compute_duration(task));
+    XBT_INFO("Executing task %f", MSG_task_get_compute_duration(task));
     MSG_task_execute(task);
-    INFO0("End of execution");
+    XBT_INFO("End of execution");
     MSG_task_destroy(task);
     task = NULL;
   }
@@ -104,7 +104,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }
 
index 805225e..c19720a 100644 (file)
@@ -103,7 +103,7 @@ MSG_error_t test_all(const char *platform_file,
   }
   res = MSG_main();
 
-  INFO1("Simulation time %g", MSG_get_clock());
+  XBT_INFO("Simulation time %g", MSG_get_clock());
   return res;
 }
 
index 8ae9424..a258853 100644 (file)
@@ -36,8 +36,8 @@ int main(int argc, char **argv)
 
   /* Check our arguments */
   if (argc < 3) {
-    INFO1("Usage: %s platform_file dax_file [trace_file]", argv[0]);
-    INFO1
+    XBT_INFO("Usage: %s platform_file dax_file [trace_file]", argv[0]);
+    XBT_INFO
         ("example: %s ../sd_platform.xml Montage_50.xml Montage_50.mytrace",
          argv[0]);
     exit(1);
@@ -61,7 +61,7 @@ int main(int argc, char **argv)
   dax = SD_daxload(argv[2]);
 
   /* Display all the tasks */
-  INFO0
+  XBT_INFO
       ("------------------- Display all tasks of the loaded DAG ---------------------------");
   xbt_dynar_foreach(dax, cursor, task) {
     SD_task_dump(task);
@@ -76,7 +76,7 @@ int main(int argc, char **argv)
   fclose(dotout);
 
   /* Schedule them all on the first workstation */
-  INFO0("------------------- Schedule tasks ---------------------------");
+  XBT_INFO("------------------- Schedule tasks ---------------------------");
   const SD_workstation_t *ws_list = SD_workstation_get_list();
   int totalHosts = SD_workstation_get_number();
   qsort((void *) ws_list, totalHosts, sizeof(SD_workstation_t),
@@ -92,13 +92,13 @@ int main(int argc, char **argv)
     }
   }
 
-  INFO0
+  XBT_INFO
       ("------------------- Run the schedule ---------------------------");
   changed = SD_simulate(-1);
   xbt_dynar_free_container(&changed);
-  INFO0
+  XBT_INFO
       ("------------------- Produce the trace file---------------------------");
-  INFO1("Producing the trace of the run into %s", tracefilename);
+  XBT_INFO("Producing the trace of the run into %s", tracefilename);
   FILE *out = fopen(tracefilename, "w");
   xbt_assert1(out, "Cannot write to %s", tracefilename);
   free(tracefilename);
index 3edb40d..dfc57ab 100644 (file)
@@ -27,8 +27,8 @@ int main(int argc, char **argv)
 
   /* Check our arguments */
   if (argc < 3) {
-    INFO1("Usage: %s platform_file dot_file [trace_file]", argv[0]);
-    INFO1("example: %s ../2clusters.xml dag.dot dag.mytrace", argv[0]);
+    XBT_INFO("Usage: %s platform_file dot_file [trace_file]", argv[0]);
+    XBT_INFO("example: %s ../2clusters.xml dag.dot dag.mytrace", argv[0]);
     exit(1);
   }
   char *tracefilename;
@@ -49,12 +49,12 @@ int main(int argc, char **argv)
   /* load the DOT file */
   dot = SD_dotload(argv[2]);
   if(dot == NULL){
-    INFO0("No dot load may be you have a cycle in your graph");
+    XBT_INFO("No dot load may be you have a cycle in your graph");
     return -1;
   }
 
   /* Display all the tasks */
-  INFO0
+  XBT_INFO
       ("------------------- Display all tasks of the loaded DAG ---------------------------");
   xbt_dynar_foreach(dot, cursor, task) {
     SD_task_dump(task);
@@ -69,7 +69,7 @@ int main(int argc, char **argv)
   fclose(dotout);
 
   /* Schedule them all on the first workstation */
-  INFO0("------------------- Schedule tasks ---------------------------");
+  XBT_INFO("------------------- Schedule tasks ---------------------------");
   const SD_workstation_t *ws_list = SD_workstation_get_list();
 
   int count = SD_workstation_get_number();
@@ -82,13 +82,13 @@ int main(int argc, char **argv)
     }
   }
 
-  INFO0
+  XBT_INFO
       ("------------------- Run the schedule ---------------------------");
   changed = SD_simulate(-1);
   xbt_dynar_free_container(&changed);
-  INFO0
+  XBT_INFO
       ("------------------- Produce the trace file---------------------------");
-  INFO1("Producing the trace of the run into %s", tracefilename);
+  XBT_INFO("Producing the trace of the run into %s", tracefilename);
   FILE *out = fopen(tracefilename, "w");
   xbt_assert1(out, "Cannot write to %s", tracefilename);
   free(tracefilename);
index b4f4fbd..b9baad1 100644 (file)
@@ -27,7 +27,7 @@ int main(int argc, char **argv)
 
   /* Check our arguments */
   if (argc < 2) {
-    INFO1("Usage: %s dot_file", argv[0]);
+    XBT_INFO("Usage: %s dot_file", argv[0]);
     exit(1);
   }
 
@@ -35,17 +35,17 @@ int main(int argc, char **argv)
   dot = SD_dotload(argv[1]);
 
   /* Display all the tasks */
-  INFO0
+  XBT_INFO
       ("------------------- Display all tasks of the loaded DAG ---------------------------");
   xbt_dynar_foreach(dot, cursor, task) {
       SD_task_dump(task);
     }
 
-  INFO0
+  XBT_INFO
       ("--------------------- Transform the dynar into an array ---------------------------");
   cursor=0;
   dot_as_array = (SD_task_t*) xbt_dynar_to_array(dot);
-  INFO0
+  XBT_INFO
       ("----------------------------- dump tasks again ------------------------------------");
   while ((task=dot_as_array[cursor++])){
     SD_task_dump(task);
index ad2a6cb..a67ec8a 100644 (file)
@@ -27,8 +27,8 @@ int main(int argc, char **argv)
 
   /* Check our arguments */
   if (argc < 3) {
-    INFO1("Usage: %s platform_file dot_file [trace_file]", argv[0]);
-    INFO1("example: %s ../2clusters.xml dag.dot dag.mytrace", argv[0]);
+    XBT_INFO("Usage: %s platform_file dot_file [trace_file]", argv[0]);
+    XBT_INFO("example: %s ../2clusters.xml dag.dot dag.mytrace", argv[0]);
     exit(1);
   }
   char *tracefilename;
@@ -49,12 +49,12 @@ int main(int argc, char **argv)
   /* load the DOT file  and schedule tasks */
   dot = SD_dotload_with_sched(argv[2]);
   if(dot == NULL){
-    INFO0("The dot file with the provided scheduling is wrong, more information with the option : --log=sd_dotparse.thres:verbose");
+    XBT_INFO("The dot file with the provided scheduling is wrong, more information with the option : --log=sd_dotparse.thres:verbose");
     return -1;
   }
 
   /* Display all the tasks */
-  INFO0
+  XBT_INFO
       ("------------------- Display all tasks of the loaded DAG ---------------------------");
   xbt_dynar_foreach(dot, cursor, task) {
     SD_task_dump(task);
@@ -68,13 +68,13 @@ int main(int argc, char **argv)
   fprintf(dotout, "}\n");
   fclose(dotout);
 
-  INFO0
+  XBT_INFO
       ("------------------- Run the schedule ---------------------------");
   changed = SD_simulate(-1);
   xbt_dynar_free_container(&changed);
-  INFO0
+  XBT_INFO
       ("------------------- Produce the trace file---------------------------");
-  INFO1("Producing the trace of the run into %s", tracefilename);
+  XBT_INFO("Producing the trace of the run into %s", tracefilename);
   FILE *out = fopen(tracefilename, "w");
   xbt_assert1(out, "Cannot write to %s", tracefilename);
   free(tracefilename);
index 0067eaa..369da0f 100644 (file)
@@ -37,8 +37,8 @@ int main(int argc, char **argv)
   /*  xbt_log_control_set("sd.thres=debug"); */
 
   if (argc < 2) {
-    INFO1("Usage: %s platform_file", argv[0]);
-    INFO1("example: %s sd_platform.xml", argv[0]);
+    XBT_INFO("Usage: %s platform_file", argv[0]);
+    XBT_INFO("example: %s sd_platform.xml", argv[0]);
     exit(1);
   }
 
@@ -61,11 +61,11 @@ int main(int argc, char **argv)
       w2 = workstations[j];
       name1 = SD_workstation_get_name(w1);
       name2 = SD_workstation_get_name(w2);
-      INFO2("Route between %s and %s:", name1, name2);
+      XBT_INFO("Route between %s and %s:", name1, name2);
       route = SD_route_get_list(w1, w2);
       route_size = SD_route_get_size(w1, w2);
       for (k = 0; k < route_size; k++) {
-        INFO3("\tLink %s: latency = %f, bandwidth = %f",
+        XBT_INFO("\tLink %s: latency = %f, bandwidth = %f",
               SD_link_get_name(route[k]),
               SD_link_get_current_latency(route[k]),
               SD_link_get_current_bandwidth(route[k]));
index 089e89c..28ee597 100644 (file)
@@ -31,8 +31,8 @@ int main(int argc, char **argv)
   /* initialisation of SD */
   SD_init(&argc, argv);
   if (argc < 2) {
-    INFO1("Usage: %s platform_file", argv[0]);
-    INFO1("example: %s sd_platform.xml", argv[0]);
+    XBT_INFO("Usage: %s platform_file", argv[0]);
+    XBT_INFO("example: %s sd_platform.xml", argv[0]);
     exit(1);
   }
   SD_create_environment(argv[1]);
@@ -48,7 +48,7 @@ int main(int argc, char **argv)
 
   /* The host properties can be retrived from all interfaces */
 
-  INFO1("Property list for workstation %s", name1);
+  XBT_INFO("Property list for workstation %s", name1);
   /* Get the property list of the workstation 1 */
   props = SD_workstation_get_properties(w1);
 
@@ -58,45 +58,45 @@ int main(int argc, char **argv)
 
   /* Print the properties of the workstation 1 */
   xbt_dict_foreach(props, cursor, key, data) {
-    INFO2("\tProperty: %s has value: %s", key, data);
+    XBT_INFO("\tProperty: %s has value: %s", key, data);
   }
 
   /* Try to get a property that does not exist */
 
   value = SD_workstation_get_property_value(w1, noexist);
   if (value == NULL)
-    INFO1("\tProperty: %s is undefined", noexist);
+    XBT_INFO("\tProperty: %s is undefined", noexist);
   else
-    INFO2("\tProperty: %s has value: %s", noexist, value);
+    XBT_INFO("\tProperty: %s has value: %s", noexist, value);
 
 
-  INFO1("Property list for workstation %s", name2);
+  XBT_INFO("Property list for workstation %s", name2);
   /* Get the property list of the workstation 2 */
   props = SD_workstation_get_properties(w2);
   cursor = NULL;
 
   /* Print the properties of the workstation 2 */
   xbt_dict_foreach(props, cursor, key, data) {
-    INFO2("\tProperty: %s on host: %s", key, data);
+    XBT_INFO("\tProperty: %s on host: %s", key, data);
   }
 
   /* Modify an existing property test. First check it exists */
-  INFO0("Modify an existing property");
+  XBT_INFO("Modify an existing property");
 
   value = SD_workstation_get_property_value(w2, exist);
   if (value == NULL)
-    INFO1("\tProperty: %s is undefined", exist);
+    XBT_INFO("\tProperty: %s is undefined", exist);
   else {
-    INFO2("\tProperty: %s old value: %s", exist, value);
+    XBT_INFO("\tProperty: %s old value: %s", exist, value);
     xbt_dict_set(props, exist, strdup("250"), free);
   }
 
   /* Test if we have changed the value */
   value = SD_workstation_get_property_value(w2, exist);
   if (value == NULL)
-    INFO1("\tProperty: %s is undefined", exist);
+    XBT_INFO("\tProperty: %s is undefined", exist);
   else
-    INFO2("\tProperty: %s new value: %s", exist, value);
+    XBT_INFO("\tProperty: %s new value: %s", exist, value);
 
   SD_exit();
   return 0;
index a779dee..898120f 100644 (file)
@@ -65,7 +65,7 @@ static xbt_dynar_t get_ready_tasks(xbt_dynar_t dax)
       xbt_dynar_push(ready_tasks, &task);
     }
   }
-  DEBUG1("There are %lu ready tasks", xbt_dynar_length(ready_tasks));
+  XBT_DEBUG("There are %lu ready tasks", xbt_dynar_length(ready_tasks));
 
   return ready_tasks;
 }
@@ -95,7 +95,7 @@ static double finish_on_at(SD_task_t task, SD_workstation_t workstation)
         grand_parents = SD_task_get_parents(parent);
 
         if (xbt_dynar_length(grand_parents) > 1) {
-          ERROR1("Warning: transfer %s has 2 parents",
+          XBT_ERROR("Warning: transfer %s has 2 parents",
                  SD_task_get_name(parent));
         }
         xbt_dynar_get_cpy(grand_parents, 0, &grand_parent);
@@ -154,7 +154,7 @@ static SD_workstation_t SD_task_get_best_workstation(SD_task_t task)
 
   for (i = 1; i < nworkstations; i++) {
     EFT = finish_on_at(task, workstations[i]);
-    DEBUG3("%s finishes on %s at %f",
+    XBT_DEBUG("%s finishes on %s at %f",
            SD_task_get_name(task),
            SD_workstation_get_name(workstations[i]), EFT);
 
@@ -251,8 +251,8 @@ int main(int argc, char **argv)
 
   /* Check our arguments */
   if (argc < 3) {
-    INFO1("Usage: %s platform_file dax_file [jedule_file]", argv[0]);
-    INFO1
+    XBT_INFO("Usage: %s platform_file dax_file [jedule_file]", argv[0]);
+    XBT_INFO
         ("example: %s simulacrum_7_hosts.xml Montage_25.xml Montage_25.jed",
          argv[0]);
     exit(1);
@@ -307,7 +307,7 @@ int main(int argc, char **argv)
      * its best workstation.
      */
     xbt_dynar_foreach(ready_tasks, cursor, task) {
-      DEBUG1("%s is ready", SD_task_get_name(task));
+      XBT_DEBUG("%s is ready", SD_task_get_name(task));
       workstation = SD_task_get_best_workstation(task);
       finish_time = finish_on_at(task, workstation);
       if (min_finish_time == -1. || finish_time < min_finish_time) {
@@ -318,7 +318,7 @@ int main(int argc, char **argv)
       }
     }
 
-    INFO2("Schedule %s on %s", SD_task_get_name(selected_task),
+    XBT_INFO("Schedule %s on %s", SD_task_get_name(selected_task),
           SD_workstation_get_name(selected_workstation));
 
     SD_task_schedulel(selected_task, 1, selected_workstation);
@@ -330,14 +330,14 @@ int main(int argc, char **argv)
     xbt_dynar_free_container(&changed);
   }
 
-  INFO1("Simulation Time: %f", SD_get_clock());
+  XBT_INFO("Simulation Time: %f", SD_get_clock());
 
 
 
 
-  INFO0
+  XBT_INFO
       ("------------------- Produce the trace file---------------------------");
-  INFO1("Producing the trace of the run into %s", tracefilename);
+  XBT_INFO("Producing the trace of the run into %s", tracefilename);
   out = fopen(tracefilename, "w");
   xbt_assert1(out, "Cannot write to %s", tracefilename);
   free(tracefilename);
index 82ac121..786ce22 100644 (file)
@@ -33,8 +33,8 @@ int main(int argc, char **argv)
   /*  xbt_log_control_set("sd.thres=debug"); */
 
   if (argc < 2) {
-    INFO1("Usage: %s platform_file", argv[0]);
-    INFO1("example: %s sd_platform.xml", argv[0]);
+    XBT_INFO("Usage: %s platform_file", argv[0]);
+    XBT_INFO("example: %s sd_platform.xml", argv[0]);
     exit(1);
   }
 
@@ -49,7 +49,7 @@ int main(int argc, char **argv)
   for (i = 0; i < 2; i++) {
     SD_workstation_set_access_mode(workstations[i],
                                    SD_WORKSTATION_SEQUENTIAL_ACCESS);
-    INFO2("Access mode of %s is %s",
+    XBT_INFO("Access mode of %s is %s",
           SD_workstation_get_name(workstations[i]),
           (SD_workstation_get_access_mode(workstations[i]) ==
            SD_WORKSTATION_SEQUENTIAL_ACCESS) ? "sequential" : "shared");
@@ -92,40 +92,40 @@ int main(int argc, char **argv)
       if (task)
         kind = SD_task_get_kind(task);
       else {
-        INFO1("There is no task running on %s",
+        XBT_INFO("There is no task running on %s",
               SD_workstation_get_name(workstations[i]));
         continue;
       }
 
       switch (kind) {
       case SD_TASK_COMP_SEQ:
-        INFO2("%s is currently running on %s (SD_TASK_COMP_SEQ)",
+        XBT_INFO("%s is currently running on %s (SD_TASK_COMP_SEQ)",
               SD_task_get_name(task),
               SD_workstation_get_name(workstations[i]));
         break;
       case SD_TASK_COMM_E2E:
-        INFO2("%s is currently running on %s (SD_TASK_COMM_E2E)",
+        XBT_INFO("%s is currently running on %s (SD_TASK_COMM_E2E)",
               SD_task_get_name(task),
               SD_workstation_get_name(workstations[i]));
         break;
       case SD_TASK_NOT_TYPED:
-        INFO1("Task running on %s has no type",
+        XBT_INFO("Task running on %s has no type",
               SD_workstation_get_name(workstations[i]));
         break;
       default:
-        ERROR0("Shouldn't be here");
+        XBT_ERROR("Shouldn't be here");
       }
     }
     xbt_dynar_free_container(&changed_tasks);
   }
 
-  DEBUG0("Destroying tasks...");
+  XBT_DEBUG("Destroying tasks...");
 
   SD_task_destroy(taskA);
   SD_task_destroy(taskB);
   SD_task_destroy(taskC);
 
-  DEBUG0("Tasks destroyed. Exiting SimDag...");
+  XBT_DEBUG("Tasks destroyed. Exiting SimDag...");
 
   SD_exit();
   return 0;
index 886f80b..3d8acc7 100644 (file)
@@ -43,8 +43,8 @@ int main(int argc, char **argv)
   /*  xbt_log_control_set("sd.thres=debug"); */
 
   if (argc < 2) {
-    INFO1("Usage: %s platform_file", argv[0]);
-    INFO1("example: %s sd_platform.xml", argv[0]);
+    XBT_INFO("Usage: %s platform_file", argv[0]);
+    XBT_INFO("example: %s sd_platform.xml", argv[0]);
     exit(1);
   }
 
@@ -63,29 +63,29 @@ int main(int argc, char **argv)
   computation_amount2 = 1000000;
   communication_amount12 = 2000000;
   communication_amount21 = 3000000;
-  INFO3("Computation time for %f flops on %s: %f", computation_amount1,
+  XBT_INFO("Computation time for %f flops on %s: %f", computation_amount1,
         name1, SD_workstation_get_computation_time(w1,
                                                    computation_amount1));
-  INFO3("Computation time for %f flops on %s: %f", computation_amount2,
+  XBT_INFO("Computation time for %f flops on %s: %f", computation_amount2,
         name2, SD_workstation_get_computation_time(w2,
                                                    computation_amount2));
 
-  INFO2("Route between %s and %s:", name1, name2);
+  XBT_INFO("Route between %s and %s:", name1, name2);
   route = SD_route_get_list(w1, w2);
   route_size = SD_route_get_size(w1, w2);
   for (i = 0; i < route_size; i++) {
-    INFO3("   Link %s: latency = %f, bandwidth = %f",
+    XBT_INFO("   Link %s: latency = %f, bandwidth = %f",
           SD_link_get_name(route[i]),
           SD_link_get_current_latency(route[i]),
           SD_link_get_current_bandwidth(route[i]));
   }
-  INFO2("Route latency = %f, route bandwidth = %f",
+  XBT_INFO("Route latency = %f, route bandwidth = %f",
         SD_route_get_current_latency(w1, w2),
         SD_route_get_current_bandwidth(w1, w2));
-  INFO4("Communication time for %f bytes between %s and %s: %f",
+  XBT_INFO("Communication time for %f bytes between %s and %s: %f",
         communication_amount12, name1, name2,
         SD_route_get_communication_time(w1, w2, communication_amount12));
-  INFO4("Communication time for %f bytes between %s and %s: %f",
+  XBT_INFO("Communication time for %f bytes between %s and %s: %f",
         communication_amount21, name2, name1,
         SD_route_get_communication_time(w2, w1, communication_amount21));
 
@@ -164,7 +164,7 @@ int main(int argc, char **argv)
 
   /* estimated time */
   task = taskD;
-  INFO2("Estimated time for '%s': %f", SD_task_get_name(task),
+  XBT_INFO("Estimated time for '%s': %f", SD_task_get_name(task),
         SD_task_get_execution_time(task, workstation_number,
                                    workstation_list, computation_amount,
                                    communication_amount));
@@ -182,7 +182,7 @@ int main(int argc, char **argv)
 
   changed_tasks = SD_simulate(-1.0);
   xbt_dynar_foreach(changed_tasks, ctr, task) {
-    INFO3("Task '%s' start time: %f, finish time: %f",
+    XBT_INFO("Task '%s' start time: %f, finish time: %f",
           SD_task_get_name(task),
           SD_task_get_start_time(task), SD_task_get_finish_time(task));
   }
@@ -195,14 +195,14 @@ int main(int argc, char **argv)
 
   xbt_dynar_free_container(&changed_tasks);
 
-  DEBUG0("Destroying tasks...");
+  XBT_DEBUG("Destroying tasks...");
 
   SD_task_destroy(taskA);
   SD_task_destroy(taskB);
   SD_task_destroy(taskC);
   SD_task_destroy(taskD);
 
-  DEBUG0("Tasks destroyed. Exiting SimDag...");
+  XBT_DEBUG("Tasks destroyed. Exiting SimDag...");
 
   SD_exit();
   return 0;
index cc86f17..e04bcfd 100644 (file)
@@ -199,7 +199,7 @@ int main(int argc, char **argv)
   /* let's launch the simulation! */
   changed_tasks = SD_simulate(-1.0);
 
-  INFO1("Simulation time: %f", SD_get_clock());
+  XBT_INFO("Simulation time: %f", SD_get_clock());
 
   xbt_dynar_free_container(&changed_tasks);
 
index ad8d4b4..f1ac477 100644 (file)
@@ -43,8 +43,8 @@ int main(int argc, char **argv)
   /*  xbt_log_control_set("sd.thres=debug"); */
 
   if (argc < 2) {
-    INFO1("Usage: %s script_file", argv[0]);
-    INFO1("example: %s sd_platform_script.lua", argv[0]);
+    XBT_INFO("Usage: %s script_file", argv[0]);
+    XBT_INFO("example: %s sd_platform_script.lua", argv[0]);
     exit(1);
   }
 
@@ -63,29 +63,29 @@ int main(int argc, char **argv)
   computation_amount2 = 1000000;
   communication_amount12 = 2000000;
   communication_amount21 = 3000000;
-  INFO3("Computation time for %f flops on %s: %f", computation_amount1,
+  XBT_INFO("Computation time for %f flops on %s: %f", computation_amount1,
         name1, SD_workstation_get_computation_time(w1,
                                                    computation_amount1));
-  INFO3("Computation time for %f flops on %s: %f", computation_amount2,
+  XBT_INFO("Computation time for %f flops on %s: %f", computation_amount2,
         name2, SD_workstation_get_computation_time(w2,
                                                    computation_amount2));
 
-  INFO2("Route between %s and %s:", name1, name2);
+  XBT_INFO("Route between %s and %s:", name1, name2);
   route = SD_route_get_list(w1, w2);
   route_size = SD_route_get_size(w1, w2);
   for (i = 0; i < route_size; i++) {
-    INFO3("   Link %s: latency = %f, bandwidth = %f",
+    XBT_INFO("   Link %s: latency = %f, bandwidth = %f",
           SD_link_get_name(route[i]),
           SD_link_get_current_latency(route[i]),
           SD_link_get_current_bandwidth(route[i]));
   }
-  INFO2("Route latency = %f, route bandwidth = %f",
+  XBT_INFO("Route latency = %f, route bandwidth = %f",
         SD_route_get_current_latency(w1, w2),
         SD_route_get_current_bandwidth(w1, w2));
-  INFO4("Communication time for %f bytes between %s and %s: %f",
+  XBT_INFO("Communication time for %f bytes between %s and %s: %f",
         communication_amount12, name1, name2,
         SD_route_get_communication_time(w1, w2, communication_amount12));
-  INFO4("Communication time for %f bytes between %s and %s: %f",
+  XBT_INFO("Communication time for %f bytes between %s and %s: %f",
         communication_amount21, name2, name1,
         SD_route_get_communication_time(w2, w1, communication_amount21));
 
@@ -164,7 +164,7 @@ int main(int argc, char **argv)
 
   /* estimated time */
   task = taskD;
-  INFO2("Estimated time for '%s': %f", SD_task_get_name(task),
+  XBT_INFO("Estimated time for '%s': %f", SD_task_get_name(task),
         SD_task_get_execution_time(task, workstation_number,
                                    workstation_list, computation_amount,
                                    communication_amount));
@@ -182,7 +182,7 @@ int main(int argc, char **argv)
 
   changed_tasks = SD_simulate(-1.0);
   xbt_dynar_foreach(changed_tasks, ctr, task) {
-    INFO3("Task '%s' start time: %f, finish time: %f",
+    XBT_INFO("Task '%s' start time: %f, finish time: %f",
           SD_task_get_name(task),
           SD_task_get_start_time(task), SD_task_get_finish_time(task));
   }
@@ -195,14 +195,14 @@ int main(int argc, char **argv)
 
   xbt_dynar_free_container(&changed_tasks);
 
-  DEBUG0("Destroying tasks...");
+  XBT_DEBUG("Destroying tasks...");
 
   SD_task_destroy(taskA);
   SD_task_destroy(taskB);
   SD_task_destroy(taskC);
   SD_task_destroy(taskD);
 
-  DEBUG0("Tasks destroyed. Exiting SimDag...");
+  XBT_DEBUG("Tasks destroyed. Exiting SimDag...");
 
   SD_exit();
   return 0;
index d5e2e57..b05e5fb 100644 (file)
@@ -33,8 +33,8 @@ int main(int argc, char **argv)
   /*  xbt_log_control_set("sd.thres=debug"); */
 
   if (argc < 2) {
-    INFO1("Usage: %s platform_file", argv[0]);
-    INFO1("example: %s sd_platform.xml", argv[0]);
+    XBT_INFO("Usage: %s platform_file", argv[0]);
+    XBT_INFO("example: %s sd_platform.xml", argv[0]);
     exit(1);
   }
 
@@ -49,7 +49,7 @@ int main(int argc, char **argv)
   for (i = 0; i < 2; i++) {
     SD_workstation_set_access_mode(workstations[i],
                                    SD_WORKSTATION_SEQUENTIAL_ACCESS);
-    INFO2("Access mode of %s is %s",
+    XBT_INFO("Access mode of %s is %s",
           SD_workstation_get_name(workstations[i]),
           (SD_workstation_get_access_mode(workstations[i]) ==
            SD_WORKSTATION_SEQUENTIAL_ACCESS) ? "sequential" : "shared");
@@ -98,40 +98,40 @@ int main(int argc, char **argv)
       if (task)
         kind = SD_task_get_kind(task);
       else {
-        INFO1("There is no task running on %s",
+        XBT_INFO("There is no task running on %s",
               SD_workstation_get_name(workstations[i]));
         continue;
       }
 
       switch (kind) {
       case SD_TASK_COMP_SEQ:
-        INFO2("%s is currently running on %s (SD_TASK_COMP_SEQ)",
+        XBT_INFO("%s is currently running on %s (SD_TASK_COMP_SEQ)",
               SD_task_get_name(task),
               SD_workstation_get_name(workstations[i]));
         break;
       case SD_TASK_COMM_E2E:
-        INFO2("%s is currently running on %s (SD_TASK_COMM_E2E)",
+        XBT_INFO("%s is currently running on %s (SD_TASK_COMM_E2E)",
               SD_task_get_name(task),
               SD_workstation_get_name(workstations[i]));
         break;
       case SD_TASK_NOT_TYPED:
-        INFO1("Task running on %s has no type",
+        XBT_INFO("Task running on %s has no type",
               SD_workstation_get_name(workstations[i]));
         break;
       default:
-        ERROR0("Shouldn't be here");
+        XBT_ERROR("Shouldn't be here");
       }
     }
     xbt_dynar_free_container(&changed_tasks);
   }
 
-  DEBUG0("Destroying tasks...");
+  XBT_DEBUG("Destroying tasks...");
 
   SD_task_destroy(taskA);
   SD_task_destroy(taskB);
   SD_task_destroy(taskC);
 
-  DEBUG0("Tasks destroyed. Exiting SimDag...");
+  XBT_DEBUG("Tasks destroyed. Exiting SimDag...");
 
   SD_exit();
   return 0;
index 1d944f7..c840eb6 100644 (file)
@@ -64,7 +64,7 @@ int main(int argc, char *argv[])
 
   xbt_os_sem_destroy(sem);
 
-  INFO1("sem_basic terminated with exit code %d (success)", EXIT_SUCCESS);
+  XBT_INFO("sem_basic terminated with exit code %d (success)", EXIT_SUCCESS);
 
   return EXIT_SUCCESS;
 
@@ -76,9 +76,9 @@ void *thread_routine(void *param)
   int exit_code = 0;
 
   xbt_os_sem_acquire(sem);
-  INFO1("Hello i'm the thread %d", thread_index);
+  XBT_INFO("Hello i'm the thread %d", thread_index);
   value++;
-  INFO1("The new value of the global variable is %d, bye", value);
+  XBT_INFO("The new value of the global variable is %d, bye", value);
   xbt_os_sem_release(sem);
 
   xbt_os_thread_exit(&exit_code);
index 7ae8b7d..eb018c7 100644 (file)
@@ -95,7 +95,7 @@ int main(int argc, char *argv[])
   xbt_init(&argc, argv);
 
   if (argc != 2) {
-    INFO1("Usage: %s job count", argv[0]);
+    XBT_INFO("Usage: %s job count", argv[0]);
     exit(EXIT_FAILURE);
   }
 
@@ -106,7 +106,7 @@ int main(int argc, char *argv[])
   sched = sched_new(size);
 
   if (!sched) {
-    INFO1("sched_new() failed : errno %d", errno);
+    XBT_INFO("sched_new() failed : errno %d", errno);
     exit(EXIT_FAILURE);
   }
 
@@ -126,28 +126,28 @@ int main(int argc, char *argv[])
   /* initialize the scheduler */
   if (sched_init(sched) < 0) {
     sched_free(&sched);
-    INFO1("sched_init() failed : errno %d\n", errno);
+    XBT_INFO("sched_init() failed : errno %d\n", errno);
     exit(EXIT_FAILURE);
   }
 
   /* schedule the jobs */
   if (sched_schedule(sched) < 0) {
     sched_free(&sched);
-    INFO1("sched_init() failed : errno %d", errno);
+    XBT_INFO("sched_init() failed : errno %d", errno);
     exit(EXIT_FAILURE);
   }
 
   /* cleanup */
   if (sched_clean(sched) < 0) {
     sched_free(&sched);
-    INFO1("sched_init() failed : errno %d", errno);
+    XBT_INFO("sched_init() failed : errno %d", errno);
     exit(EXIT_FAILURE);
   }
 
   /* destroy the scheduler */
   sched_free(&sched);
 
-  INFO1("sem_sched terminated with exit code %d (success)", EXIT_SUCCESS);
+  XBT_INFO("sem_sched terminated with exit code %d (success)", EXIT_SUCCESS);
 
   return EXIT_SUCCESS;
 
@@ -159,24 +159,24 @@ void *ctx_function(void *param)
   int exit_code = 1;
   ctx_t ctx = (ctx_t) param;
 
-  INFO1("Hello i'm the owner of the context %d, i'm waiting for starting",
+  XBT_INFO("Hello i'm the owner of the context %d, i'm waiting for starting",
         ctx->index);
 
   unschedule(ctx);
 
   if (ctx->failure) {
-    INFO1("0ups the scheduler initialization failed bye {%d}.",
+    XBT_INFO("0ups the scheduler initialization failed bye {%d}.",
           ctx->index);
     xbt_os_thread_exit(&exit_code);
   }
 
-  INFO1("I'm the owner of the context %d : I'm started", ctx->index);
-  INFO0("Wait a minute, I do my job");
+  XBT_INFO("I'm the owner of the context %d : I'm started", ctx->index);
+  XBT_INFO("Wait a minute, I do my job");
 
   /* do its job */
   exit_code = job_execute(ctx->job);
 
-  INFO1("Have finished my job, bye {%d}\n", ctx->index);
+  XBT_INFO("Have finished my job, bye {%d}\n", ctx->index);
 
   xbt_os_sem_release(ctx->end);
 
@@ -348,13 +348,13 @@ int job(int argc, char **argv)
 {
   int i = 0;
 
-  INFO0
+  XBT_INFO
       ("I'm the job : I'm going to print all the args of my commande line");
 
-  INFO1("-- Arguments (%d):", argc);
+  XBT_INFO("-- Arguments (%d):", argc);
 
   for (i = 0; i < argc; i++)
-    INFO2("  ---- [%i] %s", i, argv[i]);
+    XBT_INFO("  ---- [%i] %s", i, argv[i]);
 
   return 0;
 }
index b98f704..210efb7 100644 (file)
@@ -230,7 +230,7 @@ _xbt_dynar_cursor_first(const xbt_dynar_t dynar,
   if (dynar->mutex)             /* ie _dynar_lock(dynar) but not public */
     xbt_mutex_acquire(dynar->mutex);
 
-  //DEBUG1("Set cursor on %p to the first position", (void *) dynar);
+  //XBT_DEBUG("Set cursor on %p to the first position", (void *) dynar);
   *cursor = 0;
 }
 
@@ -240,12 +240,12 @@ _xbt_dynar_cursor_get(const xbt_dynar_t dynar,
 {
 
   if (idx >= dynar->used) {
-    //DEBUG1("Cursor on %p already on last elem", (void *) dynar);
+    //XBT_DEBUG("Cursor on %p already on last elem", (void *) dynar);
     if (dynar->mutex)           /* unlock */
       xbt_mutex_release(dynar->mutex);
     return FALSE;
   }
-  //  DEBUG2("Cash out cursor on %p at %u", (void *) dynar, *idx);
+  //  XBT_DEBUG("Cash out cursor on %p at %u", (void *) dynar, *idx);
 
   memcpy(dst, ((char *) dynar->data) + idx * dynar->elmsize,
          dynar->elmsize);
index 2930369..69055cb 100644 (file)
@@ -528,7 +528,6 @@ extern xbt_log_layout_t xbt_log_default_layout;
  */
 #define XBT_HERE             XBT_LOG(xbt_log_priority_trace, "-- was here")
 
-#define XBT_LOG_OLD_STYLE
 #ifdef XBT_LOG_OLD_STYLE
 
 /* Kept for backward compatibility. */
index af79f60..fbf9f99 100644 (file)
@@ -167,7 +167,7 @@ void amok_bw_test(gras_socket_t peer,
   request->msg_amount = msg_amount;
   request->peer.name = NULL;
   request->peer.port = gras_socket_my_port(measMasterIn);
-  DEBUG6
+  XBT_DEBUG
       ("Handshaking with %s:%d to connect it back on my %d (bufsize=%ld, msg_size=%ld, msg_amount=%ld)",
        gras_socket_peer_name(peer), gras_socket_peer_port(peer),
        request->peer.port, request->buf_size, request->msg_size,
@@ -191,7 +191,7 @@ void amok_bw_test(gras_socket_t peer,
         ("Error encountered while opening the measurement socket to %s:%d for BW test: %s",
          gras_socket_peer_name(peer), request_ack->peer.port);
   }
-  DEBUG2
+  XBT_DEBUG
       ("Got ACK; conduct the experiment (msg_size = %ld, msg_amount=%ld)",
        request->msg_size, request->msg_amount);
 
@@ -227,7 +227,7 @@ void amok_bw_test(gras_socket_t peer,
         request->msg_size = 64 * 1024 * 1024;
       }
 
-      VERB5
+      XBT_VERB
           ("The experiment was too short (%f sec<%f sec). Redo it with msg_size=%lu (nb_messages=%lu) (got %fMb/s)",
            meas_duration, min_duration, request->msg_size,
            request->msg_amount,
@@ -242,7 +242,7 @@ void amok_bw_test(gras_socket_t peer,
     TRY {
       gras_socket_meas_send(measOut, 120, request->msg_size,
                             request->msg_amount);
-      DEBUG0("Data sent. Wait ACK");
+      XBT_DEBUG("Data sent. Wait ACK");
       gras_socket_meas_recv(measIn, 120, 1, 1);
     } CATCH(e) {
       gras_socket_close(measOut);
@@ -256,14 +256,14 @@ void amok_bw_test(gras_socket_t peer,
           ((double) request->msg_size) * ((double) request->msg_amount) /
           (*sec);
     }
-    DEBUG1("Experiment done ; it took %f sec", *sec);
+    XBT_DEBUG("Experiment done ; it took %f sec", *sec);
     if (*sec <= 0) {
-      CRITICAL1("Nonpositive value (%f) found for BW test time.", *sec);
+      XBT_CRITICAL("Nonpositive value (%f) found for BW test time.", *sec);
     }
 
   } while (*sec < min_duration);
 
-  DEBUG2
+  XBT_DEBUG
       ("This measurement was long enough (%f sec; found %f b/s). Stop peer",
        *sec, *bw);
   gras_msg_send(peer, "BW stop", NULL);
@@ -297,7 +297,7 @@ int amok_bw_cb_bw_handshake(gras_msg_cb_ctx_t ctx, void *payload)
   gras_msg_cb_ctx_t ctx_reask;
   static xbt_dynar_t msgtwaited = NULL;
 
-  DEBUG5
+  XBT_DEBUG
       ("Handshaked to connect to %s:%d (sizes: buf=%lu msg=%lu msg_amount=%lu)",
        gras_socket_peer_name(expeditor), request->peer.port,
        request->buf_size, request->msg_size, request->msg_amount);
@@ -350,7 +350,7 @@ int amok_bw_cb_bw_handshake(gras_msg_cb_ctx_t ctx, void *payload)
 
   TRY {
     measIn = gras_socket_meas_accept(measMasterIn);
-    DEBUG4
+    XBT_DEBUG
         ("BW handshake answered. buf_size=%lu msg_size=%lu msg_amount=%lu port=%d",
          answer->buf_size, answer->msg_size, answer->msg_amount,
          answer->peer.port);
@@ -392,7 +392,7 @@ int amok_bw_cb_bw_handshake(gras_msg_cb_ctx_t ctx, void *payload)
       tooshort = 1;
       free(request);
       request = (bw_request_t) payload;
-      VERB0("Return the reasking RPC");
+      XBT_VERB("Return the reasking RPC");
       gras_msg_rpcreturn(60, ctx_reask, NULL);
     }
     gras_msg_cb_ctx_free(ctx_reask);
@@ -404,7 +404,7 @@ int amok_bw_cb_bw_handshake(gras_msg_cb_ctx_t ctx, void *payload)
   gras_socket_close(measOut);
   free(answer);
   free(request);
-  VERB0("BW experiment done.");
+  XBT_VERB("BW experiment done.");
   return 0;
 }
 
@@ -460,7 +460,7 @@ void amok_bw_request(const char *from_name, unsigned int from_port,
 
 
 
-  DEBUG4("Ask for a BW test between %s:%d and %s:%d", from_name, from_port,
+  XBT_DEBUG("Ask for a BW test between %s:%d and %s:%d", from_name, from_port,
          to_name, to_port);
   gras_msg_rpccall(sock, 20 * 60, "BW request", &request, &result);
 
@@ -469,7 +469,7 @@ void amok_bw_request(const char *from_name, unsigned int from_port,
   if (bw)
     *bw = result->bw;
 
-  VERB6("BW test (%s:%d -> %s:%d) took %f sec (%f kb/s)",
+  XBT_VERB("BW test (%s:%d -> %s:%d) took %f sec (%f kb/s)",
         from_name, from_port, to_name, to_port,
         result->sec, ((double) result->bw) / 1024.0);
 
@@ -487,7 +487,7 @@ int amok_bw_cb_bw_request(gras_msg_cb_ctx_t ctx, void *payload)
   gras_socket_t peer, asker;
 
   asker = gras_msg_cb_ctx_from(ctx);
-  VERB6("Asked by %s:%d to conduct a bw XP with %s:%d (request: %ld %ld)",
+  XBT_VERB("Asked by %s:%d to conduct a bw XP with %s:%d (request: %ld %ld)",
         gras_socket_peer_name(asker), gras_socket_peer_port(asker),
         request->peer.name, request->peer.port,
         request->msg_size, request->msg_amount);
index c2b74ec..d20e142 100644 (file)
@@ -79,7 +79,7 @@ void amok_bw_saturate_start(const char *from_name, unsigned int from_port,
   gras_socket_t sock;
   sat_request_t request = xbt_new(s_sat_request_t, 1);
 
-  VERB4("Start from_name %s:%d -> to_name %s:%d",
+  XBT_VERB("Start from_name %s:%d -> to_name %s:%d",
         from_name, from_port, to_name, to_port);
   sock = gras_socket_client(from_name, from_port);
 
@@ -101,7 +101,7 @@ static int amok_bw_cb_sat_start(gras_msg_cb_ctx_t ctx, void *payload)
   sat_request_t request = *(sat_request_t *) payload;
   gras_socket_t expeditor = gras_msg_cb_ctx_from(ctx);
 
-  VERB4("Asked by %s:%d to start a saturation to %s:%d",
+  XBT_VERB("Asked by %s:%d to start a saturation to %s:%d",
         gras_socket_peer_name(expeditor), gras_socket_peer_port(expeditor),
         request->peer.name, request->peer.port);
 
@@ -151,7 +151,7 @@ void amok_bw_saturate_begin(const char *to_name, unsigned int to_port,
   /* Negociate the saturation with the peer */
   sat_request_t request = xbt_new(s_sat_request_t, 1);
 
-  DEBUG2("Begin to saturate to %s:%d", to_name, to_port);
+  XBT_DEBUG("Begin to saturate to %s:%d", to_name, to_port);
   memset(&msg_got, 0, sizeof(msg_got));
 
   request->msg_size = msg_size;
@@ -170,7 +170,7 @@ void amok_bw_saturate_begin(const char *to_name, unsigned int to_port,
                  1,             /* at least one sec */
                  &sec, &bw);
     msg_size = request->msg_size = (int) bw;
-    DEBUG1("Saturate with packets of %d bytes", request->msg_size);
+    XBT_DEBUG("Saturate with packets of %d bytes", request->msg_size);
   }
 
   /* Launch the saturation */
@@ -186,7 +186,7 @@ void amok_bw_saturate_begin(const char *to_name, unsigned int to_port,
   free(request);
 
   gras_socket_close(peer_cmd);
-  INFO4("Saturation(%s:%d->%s:%d) started", gras_os_myname(),
+  XBT_INFO("Saturation(%s:%d->%s:%d) started", gras_os_myname(),
         gras_os_myport(), to_name, to_port);
 
   /* Start experiment */
@@ -215,7 +215,7 @@ void amok_bw_saturate_begin(const char *to_name, unsigned int to_port,
 
     /* Check whether the experiment has to be terminated by now */
     elapsed = gras_os_time() - start;
-    DEBUG3("elapsed %f duration %f (msg_size=%d)", elapsed, duration,
+    XBT_DEBUG("elapsed %f duration %f (msg_size=%d)", elapsed, duration,
            msg_size);
 
   } while (saturate_further && (duration == 0 || elapsed < duration));
@@ -232,7 +232,7 @@ void amok_bw_saturate_begin(const char *to_name, unsigned int to_port,
     bw_res_t answer = xbt_new(s_bw_res_t, 1);
     s_gras_msg_cb_ctx_t ctx;
 
-    INFO6("Saturation from %s:%d to %s:%d stopped by %s:%d",
+    XBT_INFO("Saturation from %s:%d to %s:%d stopped by %s:%d",
           gras_os_myname(), gras_os_myport(), to_name, to_port,
           gras_socket_peer_name(msg_got.expe),
           gras_socket_peer_port(msg_got.expe));
@@ -247,7 +247,7 @@ void amok_bw_saturate_begin(const char *to_name, unsigned int to_port,
     gras_msg_rpcreturn(60, &ctx, &answer);
     free(answer);
   } else {
-    INFO6
+    XBT_INFO
         ("Saturation from %s:%d to %s:%d elapsed after %f sec (achieving %f kb/s)",
          gras_os_myname(), gras_os_myport(), to_name, to_port, elapsed,
          bw / 1024.0);
@@ -292,7 +292,7 @@ static int amok_bw_cb_sat_begin(gras_msg_cb_ctx_t ctx, void *payload)
 
   TRY {
     meas = gras_socket_meas_accept(measMaster);
-    DEBUG0("saturation handshake answered");
+    XBT_DEBUG("saturation handshake answered");
   }
   CATCH(e) {
     gras_socket_close(measMaster);
@@ -308,7 +308,7 @@ static int amok_bw_cb_sat_begin(gras_msg_cb_ctx_t ctx, void *payload)
       xbt_ex_free(e);
     }
   }
-  INFO4("Saturation comming from %s:%d stopped on %s:%d",
+  XBT_INFO("Saturation comming from %s:%d stopped on %s:%d",
         gras_socket_peer_name(from), gras_socket_peer_port(from),
         gras_os_myname(), gras_os_myport());
 
@@ -334,7 +334,7 @@ void amok_bw_saturate_stop(const char *from_name, unsigned int from_port,
 
   gras_socket_t sock = gras_socket_client(from_name, from_port);
   bw_res_t answer;
-  VERB2("Ask %s:%d to stop the saturation", from_name, from_port);
+  XBT_VERB("Ask %s:%d to stop the saturation", from_name, from_port);
   TRY {
     gras_msg_rpccall(sock, 60, "amok_bw_sat stop", NULL, &answer);
   } CATCH(e) {
index 3cff2c3..a675eb5 100644 (file)
@@ -64,7 +64,7 @@ static int amok_pm_cb_join(gras_msg_cb_ctx_t ctx, void *payload)
 
   rank = xbt_dynar_length(group);
   xbt_dynar_push(group, &dude);
-  VERB3("Contacted by %s:%d. Give it rank #%d", dude->name, dude->port,
+  XBT_VERB("Contacted by %s:%d. Give it rank #%d", dude->name, dude->port,
         rank);
 
   gras_msg_rpcreturn(10, ctx, &rank);
@@ -91,7 +91,7 @@ static int amok_pm_cb_leave(gras_msg_cb_ctx_t ctx, void *payload)
       goto end;
     }
   }
-  WARN3("Asked to remove %s:%d from group '%s', but not found. Ignoring",
+  XBT_WARN("Asked to remove %s:%d from group '%s', but not found. Ignoring",
         dude->name, dude->port, name);
 
 end:
@@ -152,10 +152,10 @@ xbt_dynar_t amok_pm_group_new(const char *group_name)
   xbt_assert0(amok_pm_moddata_id != -1, "Run amok_pm_init first!");
   g = gras_moddata_by_id(amok_pm_moddata_id);
 
-  DEBUG1("retrieved groups=%p", g->groups);
+  XBT_DEBUG("retrieved groups=%p", g->groups);
 
   xbt_dict_set(g->groups, group_name, res, NULL);       /*FIXME: leaking xbt_dynar_free_voidp); */
-  VERB1("Group %s created", group_name);
+  XBT_VERB("Group %s created", group_name);
 
   return res;
 }
@@ -176,11 +176,11 @@ xbt_dynar_t amok_pm_group_get(gras_socket_t master, const char *group_name)
 int amok_pm_group_join(gras_socket_t master, const char *group_name)
 {
   int rank;
-  VERB3("Join group '%s' on %s:%d",
+  XBT_VERB("Join group '%s' on %s:%d",
         group_name, gras_socket_peer_name(master),
         gras_socket_peer_port(master));
   gras_msg_rpccall(master, 30, "amok_pm_join", &group_name, &rank);
-  VERB4("Joined group '%s' on %s:%d. Got rank %d",
+  XBT_VERB("Joined group '%s' on %s:%d. Got rank %d",
         group_name, gras_socket_peer_name(master),
         gras_socket_peer_port(master), rank);
   return rank;
@@ -193,7 +193,7 @@ int amok_pm_group_join(gras_socket_t master, const char *group_name)
 void amok_pm_group_leave(gras_socket_t master, const char *group_name)
 {
   gras_msg_rpccall(master, 30, "amok_pm_leave", &group_name, NULL);
-  VERB3("Leaved group '%s' on %s:%d",
+  XBT_VERB("Leaved group '%s' on %s:%d",
         group_name, gras_socket_peer_name(master),
         gras_socket_peer_port(master));
 }
index 3691e18..abcc05e 100644 (file)
@@ -198,7 +198,7 @@ static int AS_new(lua_State * L)
     mode = lua_tostring(L, -1);
     lua_pop(L, 1);
   } else {
-    ERROR0
+    XBT_ERROR
         ("Bad Arguments to AS.new, Should be a table with named arguments");
     return -1;
   }
@@ -269,7 +269,7 @@ static int Host_new(lua_State * L)
     lua_pop(L, 1);
 
   } else {
-    ERROR0
+    XBT_ERROR
         ("Bad Arguments to create host, Should be a table with named arguments");
     return -1;
   }
@@ -358,7 +358,7 @@ static int Link_new(lua_State * L)      // (id,bandwidth,latency)
     lua_pop(L, 1);
 
   } else {
-    ERROR0
+    XBT_ERROR
         ("Bad Arguments to create link, Should be a table with named arguments");
     return -1;
   }
@@ -433,7 +433,7 @@ static int Route_new(lua_State * L)     // (src_id,dest_id,links_number,link_tab
                {
         link_id = lua_tostring(L, -1);
         xbt_dynar_push(route->links_id, &link_id);
-        DEBUG2("index = %f , Link_id = %s \n", lua_tonumber(L, -2),
+         XBT_DEBUG("index = %f , Link_id = %s \n", lua_tonumber(L, -2),
         lua_tostring(L, -1));
         lua_pop(L, 1);
        }
@@ -475,7 +475,7 @@ static int Host_set_function(lua_State * L)     //(host,function,nb_args,list_ar
      lua_pop(L, 1);
    }
    else {
-          ERROR0("Bad Arguments to create link, Should be a table with named arguments");
+          XBT_ERROR("Bad Arguments to create link, Should be a table with named arguments");
           return -1;
    }
 
@@ -493,7 +493,7 @@ static int Host_set_function(lua_State * L)     //(host,function,nb_args,list_ar
       return 0;
           }
       }
-         ERROR1("Host : %s Not Found !!", host);
+         XBT_ERROR("Host : %s Not Found !!", host);
          return 1;
 
 }
index 1f78abc..c0552d1 100644 (file)
@@ -64,7 +64,7 @@ static void stackDump(const char *msg, lua_State * L)
     }
     p += sprintf(p, "  ");      /* put a separator */
   }
-  INFO2("%s%s", msg, buff);
+  XBT_INFO("%s%s", msg, buff);
 }
 
 /** @brief ensures that a userdata on the stack is a task and returns the pointer inside the userdata */
@@ -173,16 +173,16 @@ static int Task_send(lua_State * L)
   if (res != MSG_OK)
     switch (res) {
     case MSG_TIMEOUT:
-      ERROR0("MSG_task_send failed : Timeout");
+      XBT_ERROR("MSG_task_send failed : Timeout");
       break;
     case MSG_TRANSFER_FAILURE:
-      ERROR0("MSG_task_send failed : Transfer Failure");
+      XBT_ERROR("MSG_task_send failed : Transfer Failure");
       break;
     case MSG_HOST_FAILURE:
-      ERROR0("MSG_task_send failed : Host Failure ");
+      XBT_ERROR("MSG_task_send failed : Host Failure ");
       break;
     default:
-      ERROR0
+      XBT_ERROR
           ("MSG_task_send failed : Unexpected error , please report this bug");
       break;
     }
@@ -202,16 +202,16 @@ static int Task_recv(lua_State * L)
   if (res != MSG_OK)
     switch (res) {
     case MSG_TIMEOUT:
-      ERROR0("MSG_task_receive failed : Timeout");
+      XBT_ERROR("MSG_task_receive failed : Timeout");
       break;
     case MSG_TRANSFER_FAILURE:
-      ERROR0("MSG_task_receive failed : Transfer Failure");
+      XBT_ERROR("MSG_task_receive failed : Transfer Failure");
       break;
     case MSG_HOST_FAILURE:
-      ERROR0("MSG_task_receive failed : Host Failure ");
+      XBT_ERROR("MSG_task_receive failed : Host Failure ");
       break;
     default:
-      ERROR0
+      XBT_ERROR
           ("MSG_task_receive failed : Unexpected error , please report this bug");
       break;
     }
@@ -271,7 +271,7 @@ static m_host_t checkHost(lua_State * L, int index)
 static int Host_get_by_name(lua_State * L)
 {
   const char *name = luaL_checkstring(L, 1);
-  DEBUG0("Getting Host from name...");
+  XBT_DEBUG("Getting Host from name...");
   m_host_t msg_host = MSG_get_host_by_name(name);
   if (!msg_host) {
     luaL_error(L, "null Host : MSG_get_host_by_name failled");
@@ -385,7 +385,7 @@ static int gras_add_process_function(lua_State * L)
         xbt_realloc(process.argv, (process.argc) * sizeof(char *));
     process.argv[(process.argc) - 1] = xbt_strdup(arg);
 
-    DEBUG2("index = %f , arg = %s \n", lua_tonumber(L, -2),
+    XBT_DEBUG("index = %f , arg = %s \n", lua_tonumber(L, -2),
            lua_tostring(L, -1));
     lua_pop(L, 1);
   }
@@ -521,7 +521,7 @@ extern lua_State *simgrid_lua_state;
 
 static int run_lua_code(int argc, char **argv)
 {
-  DEBUG1("Run lua code %s", argv[0]);
+  XBT_DEBUG("Run lua code %s", argv[0]);
   lua_State *L = lua_newthread(simgrid_lua_state);
   int ref = luaL_ref(simgrid_lua_state, LUA_REGISTRYINDEX);     // protect the thread from being garbage collected
   int res = 1;
@@ -548,7 +548,7 @@ static int run_lua_code(int argc, char **argv)
   }
   // cleanups
   luaL_unref(simgrid_lua_state, LUA_REGISTRYINDEX, ref);
-  DEBUG1("Execution of lua code %s is over", (argv ? argv[0] : "(null)"));
+  XBT_DEBUG("Execution of lua code %s is over", (argv ? argv[0] : "(null)"));
   return res;
 }
 
@@ -564,7 +564,7 @@ static int launch_application(lua_State * L)
 static int create_environment(lua_State * L)
 {
   const char *file = luaL_checkstring(L, 1);
-  DEBUG1("Loading environment file %s", file);
+  XBT_DEBUG("Loading environment file %s", file);
   MSG_create_environment(file);
 
 /*
@@ -574,7 +574,7 @@ static int create_environment(lua_State * L)
   const char *name;
 
   xbt_dict_foreach(hosts, c, name, host) {
-    DEBUG1("We have an host %s", SIMIX_host_get_name(host));
+    XBT_DEBUG("We have an host %s", SIMIX_host_get_name(host));
   }
 */
 
@@ -584,14 +584,14 @@ static int create_environment(lua_State * L)
 static int debug(lua_State * L)
 {
   const char *str = luaL_checkstring(L, 1);
-  DEBUG1("%s", str);
+  XBT_DEBUG("%s", str);
   return 0;
 }
 
 static int info(lua_State * L)
 {
   const char *str = luaL_checkstring(L, 1);
-  INFO1("%s", str);
+  XBT_INFO("%s", str);
   return 0;
 }
 
@@ -729,14 +729,14 @@ int luaopen_simgrid(lua_State * L)
                     __FILE__, LUA_MAX_ARGS_COUNT - 1);
         argv[argc - 1] = (char *) luaL_checkstring(L, -1);
         lua_pop(L, 1);
-        DEBUG1("Got command line argument %s from lua", argv[argc - 1]);
+        XBT_DEBUG("Got command line argument %s from lua", argv[argc - 1]);
       }
     }
     argv[argc--] = NULL;
 
     /* Initialize the MSG core */
     MSG_global_init(&argc, argv);
-    DEBUG1("Still %d arguments on command line", argc); // FIXME: update the lua's arg table to reflect the changes from SimGrid
+    XBT_DEBUG("Still %d arguments on command line", argc); // FIXME: update the lua's arg table to reflect the changes from SimGrid
   }
   /* register the core C functions to lua */
   luaL_register(L, "simgrid", simgrid_funcs);
index 5b056e5..2ba6fe7 100644 (file)
@@ -40,7 +40,7 @@ static void rb_process_create_with_args(VALUE fct_name, VALUE arguments,
     rb_raise(rb_eRuntimeError,
              "Internal error: Process name cannot be NULL");
   name = RSTRING_PTR(fct_name);
-  DEBUG1("Create native process %s", name);
+  XBT_DEBUG("Create native process %s", name);
 
   char **argv = xbt_new(char *, 2);
   argv[0] = bprintf("%s@%s", name, RSTRING_PTR(ht_name));
index c2967df..bf24c21 100644 (file)
@@ -74,7 +74,7 @@ void rb_task_send(VALUE class, VALUE task, VALUE mailbox)
   data = MSG_task_get_data(tk);
   data->ruby_task = (void *) task;
   MSG_task_set_data(tk, (void *) data);
-  DEBUG1("Sending task %p", tk);
+  XBT_DEBUG("Sending task %p", tk);
   rv = MSG_task_send(tk, RSTRING_PTR(mailbox));
   if (rv != MSG_OK) {
     if (rv == MSG_TRANSFER_FAILURE)
@@ -98,7 +98,7 @@ VALUE rb_task_receive(VALUE class, VALUE mailbox)
   m_task_t task;
   *ptask = NULL;
   rb_data_t data = NULL;
-  DEBUG2("Receiving a task on mailbox '%s', store it into %p",
+  XBT_DEBUG("Receiving a task on mailbox '%s', store it into %p",
          RSTRING_PTR(mailbox), &task);
   MSG_task_receive(ptask, RSTRING_PTR(mailbox));
   task = *ptask;
@@ -207,7 +207,7 @@ VALUE rb_task_get_data(VALUE class, VALUE task)
   Data_Get_Struct(task, s_m_task_t, tk);
   rb_data_t rb_data = MSG_task_get_data(tk);
   if (!rb_data->user_data)
-    ERROR1("the task %s contain no user data", MSG_task_get_name(tk));
+    XBT_ERROR("the task %s contain no user data", MSG_task_get_name(tk));
 
   return (VALUE) rb_data->user_data;
 }
index 6a4e096..96bc897 100644 (file)
@@ -56,7 +56,7 @@ static void msg_init(VALUE Class, VALUE args)
 //Init Msg_Run From Ruby
 static void msg_run(VALUE class)
 {
-  DEBUG0("Start Running...");
+  XBT_DEBUG("Start Running...");
   m_host_t *hosts;
   int cpt, host_count;
   VALUE rbHost;
@@ -66,10 +66,10 @@ static void msg_run(VALUE class)
     rb_raise(rb_eRuntimeError, "MSG_main() failed");
   }
 
-  DEBUG0
+  XBT_DEBUG
       ("MSG_main finished. Bail out before cleanup since there is a bug in this part.");
   /* Cleanup Ruby hosts */
-  DEBUG0("Clean Ruby World  ");
+  XBT_DEBUG("Clean Ruby World  ");
   hosts = MSG_get_host_table();
   host_count = MSG_get_host_number();
   for (cpt = 0; cpt < host_count; cpt++) {
@@ -93,7 +93,7 @@ static void msg_createEnvironment(VALUE class, VALUE plateformFile)
     rb_raise(rb_eRuntimeError, "Bad Argument's Type");
   const char *platform = RSTRING_PTR(plateformFile);
   MSG_create_environment(platform);
-  DEBUG1("Create Environment (%s)...Done", platform);
+  XBT_DEBUG("Create Environment (%s)...Done", platform);
 }
 
 //deploy Application
@@ -125,20 +125,20 @@ static void msg_deployApplication(VALUE class, VALUE deploymentFile)
 
   rb_application_handler_on_end_document();
 
-  DEBUG1("Deploy Application(%s)...Done", dep_file);
+  XBT_DEBUG("Deploy Application(%s)...Done", dep_file);
 }
 
 // INFO
 static void msg_info(VALUE class, VALUE msg)
 {
   const char *s = RSTRING_PTR(msg);
-  INFO1("%s", s);
+  XBT_INFO("%s", s);
 }
 
 static void msg_debug(VALUE class, VALUE msg)
 {
   const char *s = RSTRING_PTR(msg);
-  DEBUG1("%s", s);
+  XBT_DEBUG("%s", s);
 }
 
 // get Clock
index be4c929..2429eb1 100644 (file)
@@ -54,7 +54,7 @@ static void sd_init(VALUE Class, VALUE args)
   }
   SD_init(&argc, argv);
   free(argv);
-//   INFO0("SD Init...Done");
+//   XBT_INFO("SD Init...Done");
   printf("SD Init...Done\n");
   return;
 
@@ -84,7 +84,7 @@ static void sd_createEnvironment(VALUE class, VALUE plateformFile)
 static void sd_info(VALUE class, VALUE msg)
 {
   const char *s = RSTRING(msg)->ptr;
-//  INFO1("%s",s);
+//  XBT_INFO("%s",s);
   printf("%s\n", s);
 }
 
index 94a5874..0bae0a2 100644 (file)
@@ -83,7 +83,7 @@ gras_cbps_v_push(gras_cbps_t ps,
   char *varname = (char *) xbt_strdup(name);
   xbt_ex_t e;
 
-  DEBUG2("push(%s,%p)", name, (void *) data);
+  XBT_DEBUG("push(%s,%p)", name, (void *) data);
 
   TRY {
     varstack = xbt_dict_get(ps->space, name);
@@ -91,7 +91,7 @@ gras_cbps_v_push(gras_cbps_t ps,
     if (e.category != mismatch_error)
       RETHROW;
 
-    DEBUG1("Create a new variable stack for '%s' into the space", name);
+    XBT_DEBUG("Create a new variable stack for '%s' into the space", name);
     varstack = xbt_dynar_new(sizeof(gras_cbps_elm_t *), NULL);
     xbt_dict_set(ps->space, varname, (void **) varstack, NULL);
     xbt_ex_free(e);
@@ -105,7 +105,7 @@ gras_cbps_v_push(gras_cbps_t ps,
   xbt_dynar_push(varstack, &var);
 
   xbt_dynar_pop(ps->frames, &frame);
-  DEBUG4("Push %s (%p @%p) into frame %p", varname, (void *) varname,
+  XBT_DEBUG("Push %s (%p @%p) into frame %p", varname, (void *) varname,
          (void *) &varname, (void *) frame);
   xbt_dynar_push(frame, &varname);
   xbt_dynar_push(ps->frames, &frame);
@@ -125,7 +125,7 @@ gras_cbps_v_pop(gras_cbps_t ps,
   void *data = NULL;
   xbt_ex_t e;
 
-  DEBUG1("pop(%s)", name);
+  XBT_DEBUG("pop(%s)", name);
   TRY {
     varstack = xbt_dict_get(ps->space, name);
   } CATCH(e) {
@@ -138,7 +138,7 @@ gras_cbps_v_pop(gras_cbps_t ps,
   xbt_dynar_pop(varstack, &var);
 
   if (!xbt_dynar_length(varstack)) {
-    DEBUG1("Last incarnation of %s poped. Kill it", name);
+    XBT_DEBUG("Last incarnation of %s poped. Kill it", name);
     xbt_dict_remove(ps->space, name);
     xbt_dynar_free(&varstack);
   }
@@ -186,7 +186,7 @@ gras_cbps_v_set(gras_cbps_t ps,
   xbt_dynar_t dynar = NULL;
   gras_cbps_elm_t elm = NULL;
 
-  DEBUG1("set(%s)", name);
+  XBT_DEBUG("set(%s)", name);
   dynar = xbt_dict_get_or_null(ps->space, name);
 
   if (dynar == NULL) {
@@ -220,7 +220,7 @@ void *gras_cbps_v_get(gras_cbps_t ps, const char *name,
   xbt_dynar_t dynar = NULL;
   gras_cbps_elm_t elm = NULL;
 
-  DEBUG1("get(%s)", name);
+  XBT_DEBUG("get(%s)", name);
   dynar = xbt_dict_get(ps->space, name);
   xbt_dynar_pop(dynar, &elm);
   xbt_dynar_push(dynar, &elm);
@@ -249,7 +249,7 @@ void gras_cbps_block_begin(gras_cbps_t ps)
 
   xbt_dynar_t dynar = NULL;
 
-  DEBUG0(">>> Block begin");
+  XBT_DEBUG(">>> Block begin");
   dynar = xbt_dynar_new(sizeof(char *), NULL);
   xbt_dynar_push(ps->frames, &dynar);
 }
@@ -271,7 +271,7 @@ void gras_cbps_block_end(gras_cbps_t ps)
     xbt_dynar_t varstack = NULL;
     gras_cbps_elm_t var = NULL;
 
-    DEBUG2("Get ride of %s (%p)", name, (void *) name);
+    XBT_DEBUG("Get ride of %s (%p)", name, (void *) name);
     varstack = xbt_dict_get(ps->space, name);
     xbt_dynar_pop(varstack, &var);
 
@@ -286,14 +286,14 @@ void gras_cbps_block_end(gras_cbps_t ps)
     free(name);
   }
   xbt_dynar_free_container(&frame);     /* we just emptied it */
-  DEBUG0("<<< Block end");
+  XBT_DEBUG("<<< Block end");
 }
 
 
 /** \brief Push a new integer value into the cbps. */
 void gras_cbps_i_push(gras_cbps_t ps, int val)
 {
-  DEBUG1("push %d as a size", val);
+  XBT_DEBUG("push %d as a size", val);
   xbt_dynar_push_as(ps->lints, int, val);
 }
 
@@ -305,7 +305,7 @@ int gras_cbps_i_pop(gras_cbps_t ps)
   xbt_assert0(xbt_dynar_length(ps->lints) > 0,
               "gras_cbps_i_pop: no value to pop");
   ret = xbt_dynar_pop_as(ps->lints, int);
-  DEBUG1("pop %d as a size", ret);
+  XBT_DEBUG("pop %d as a size", ret);
   return ret;
 }
 
@@ -366,7 +366,7 @@ void gras_datadesc_cb_push_int_mult(gras_datadesc_type_t ignored,
 {
   int old = *(int *) data;
   int new = gras_cbps_i_pop(vars);
-  DEBUG2("push %d x %d as a size", old, new);
+  XBT_DEBUG("push %d x %d as a size", old, new);
   gras_cbps_i_push(vars, old * new);
 }
 
@@ -377,7 +377,7 @@ void gras_datadesc_cb_push_uint_mult(gras_datadesc_type_t ignored,
   unsigned int old = *(unsigned int *) data;
   unsigned int new = gras_cbps_i_pop(vars);
 
-  DEBUG2("push %d x %d as a size", old, new);
+  XBT_DEBUG("push %d x %d as a size", old, new);
   gras_cbps_i_push(vars, (int) (old * new));
 }
 
@@ -399,6 +399,6 @@ void gras_datadesc_cb_push_ulint_mult(gras_datadesc_type_t ignored,
   unsigned long int old = *(unsigned long int *) data;
   unsigned long int new = gras_cbps_i_pop(vars);
 
-  DEBUG2("push %ld x %ld as a size", old, new);
+  XBT_DEBUG("push %ld x %ld as a size", old, new);
   gras_cbps_i_push(vars, (int) (old * new));
 }
index 3c965c9..dcccee2 100644 (file)
@@ -37,7 +37,7 @@ void gras_datadesc_init(void)
   if (gras_datadesc_set_local != NULL)
     return;
 
-  VERB0("Initializing DataDesc");
+  XBT_VERB("Initializing DataDesc");
 
   gras_datadesc_set_local = xbt_set_new();
 
@@ -169,10 +169,10 @@ void gras_datadesc_init(void)
  **/
 void gras_datadesc_exit(void)
 {
-  VERB0("Exiting DataDesc");
+  XBT_VERB("Exiting DataDesc");
   xbt_set_free(&gras_datadesc_set_local);
   xbt_dict_free(&gras_dd_constants);
-  DEBUG0("Exited DataDesc");
+  XBT_DEBUG("Exited DataDesc");
 }
 
 /** This is mainly to debug */
index dbc9bec..d24b142 100644 (file)
@@ -110,10 +110,10 @@ gras_dd_convert_elm(gras_datadesc_type_t type, int count,
 
   r_size = type->size[r_arch];
   l_size = type->size[GRAS_THISARCH];
-  DEBUG4("r_size=%lu l_size=%lu,    src=%p dst=%p", r_size, l_size, src,
+  XBT_DEBUG("r_size=%lu l_size=%lu,    src=%p dst=%p", r_size, l_size, src,
          dst);
 
-  DEBUG2("remote=%c local=%c", gras_arches[r_arch].endian ? 'B' : 'l',
+  XBT_DEBUG("remote=%c local=%c", gras_arches[r_arch].endian ? 'B' : 'l',
          gras_arches[GRAS_THISARCH].endian ? 'B' : 'l');
 
   if (r_size != l_size) {
@@ -141,12 +141,12 @@ gras_dd_convert_elm(gras_datadesc_type_t type, int count,
       int lowOrderFirst = !gras_arches[r_arch].endian ||
           gras_arches[r_arch].endian == gras_arches[GRAS_THISARCH].endian;
 
-      DEBUG5("Resize integer %d from %lu @%p to %lu @%p",
+      XBT_DEBUG("Resize integer %d from %lu @%p to %lu @%p",
              cpt, r_size, r_data, l_size, l_data);
       xbt_assert0(r_data != l_data, "Impossible to resize in place");
 
       if (sizeChange < 0) {
-        DEBUG3("Truncate %d bytes (%s,%s)", -sizeChange,
+        XBT_DEBUG("Truncate %d bytes (%s,%s)", -sizeChange,
                lowOrderFirst ? "lowOrderFirst" : "bigOrderFirst",
                scal.encoding ==
                e_gras_dd_scalar_encoding_sint ? "signed" : "unsigned");
@@ -156,7 +156,7 @@ gras_dd_convert_elm(gras_datadesc_type_t type, int count,
                : r_data, l_size);
 
         if (scal.encoding == e_gras_dd_scalar_encoding_sint) {
-          DEBUG0("This is signed");
+          XBT_DEBUG("This is signed");
           /* Make sure the high order bit of r_data and l_data are the same */
           l_sign = gras_arches[GRAS_THISARCH].endian
               ? ((unsigned char *) l_data + l_size - 1)
@@ -164,7 +164,7 @@ gras_dd_convert_elm(gras_datadesc_type_t type, int count,
           r_sign = gras_arches[r_arch].endian
               ? ((unsigned char *) r_data + r_size - 1)
               : (unsigned char *) r_data;
-          DEBUG2("This is signed (r_sign=%c l_sign=%c", *r_sign, *l_sign);
+          XBT_DEBUG("This is signed (r_sign=%c l_sign=%c", *r_sign, *l_sign);
 
           if ((*r_sign > 127) != (*l_sign > 127)) {
             if (*r_sign > 127)
@@ -174,9 +174,9 @@ gras_dd_convert_elm(gras_datadesc_type_t type, int count,
           }
         }
       } else {
-        DEBUG1("Extend %d bytes", sizeChange);
+        XBT_DEBUG("Extend %d bytes", sizeChange);
         if (scal.encoding != e_gras_dd_scalar_encoding_sint) {
-          DEBUG0("This is signed");
+          XBT_DEBUG("This is signed");
           padding = 0;          /* pad unsigned with 0 */
         } else {
           /* extend sign */
@@ -218,7 +218,7 @@ gras_dd_convert_elm(gras_datadesc_type_t type, int count,
     for (cpt = 0, r_data = dst, l_data = dst; cpt < count; cpt++, r_data = (char *) r_data + l_size,    /* resizing already done */
          l_data = (char *) l_data + l_size) {