Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
another MSG example fades away
authorMartin Quinson <martin.quinson@loria.fr>
Tue, 12 Dec 2017 22:11:39 +0000 (23:11 +0100)
committerMartin Quinson <martin.quinson@loria.fr>
Tue, 12 Dec 2017 22:11:39 +0000 (23:11 +0100)
examples/msg/CMakeLists.txt
teshsuite/msg/CMakeLists.txt
teshsuite/msg/cloud-simple/cloud-simple.c [moved from examples/msg/cloud-simple/cloud-simple.c with 77% similarity]
teshsuite/msg/cloud-simple/cloud-simple.tesh [moved from examples/msg/cloud-simple/cloud-simple.tesh with 100% similarity]

index e445ed4..9f577cb 100644 (file)
@@ -1,6 +1,6 @@
 # C examples
 foreach(x app-masterworker app-token-ring 
-          cloud-capping cloud-masterworker cloud-migration cloud-simple
+          cloud-capping cloud-masterworker cloud-migration
           dht-pastry energy-consumption energy-onoff energy-vm platform-failures 
           plugin-hostload
           process-create 
@@ -71,7 +71,7 @@ set(xml_files    ${xml_files}     ${CMAKE_CURRENT_SOURCE_DIR}/app-masterworker/a
                                   ${CMAKE_CURRENT_SOURCE_DIR}/network-ns3/two_clusters_d.xml       PARENT_SCOPE)
 
 foreach(x app-chainsend app-masterworker app-token-ring
-          cloud-capping cloud-masterworker cloud-migration cloud-simple 
+          cloud-capping cloud-masterworker cloud-migration
           dht-pastry dht-kademlia platform-failures
           energy-consumption energy-onoff energy-vm
           plugin-hostload
index cfd3c57..0ecd2c6 100644 (file)
@@ -2,7 +2,7 @@
 foreach(x actions-comm actions-storage
           app-pingpong
           async-wait async-waitall async-waitany
-          cloud-sharing cloud-two-tasks
+          cloud-sharing cloud-two-tasks cloud-simple
          get_sender host_on_off host_on_off_recv host_on_off_processes   
           process-daemon process-kill process-join process-lifetime process-migration process-suspend process-yield
           energy-ptask energy-pstate platform-properties
@@ -78,7 +78,7 @@ foreach(x
     actions-comm actions-storage
     async-wait async-waitall async-waitany
     app-bittorrent app-pingpong
-    cloud-two-tasks
+    cloud-two-tasks cloud-simple
     energy-pstate
     host_on_off host_on_off_processes host_on_off_recv
     get_sender
similarity index 77%
rename from examples/msg/cloud-simple/cloud-simple.c
rename to teshsuite/msg/cloud-simple/cloud-simple.c
index f576b25..ad7b095 100644 (file)
@@ -6,10 +6,10 @@
 #include "simgrid/msg.h"
 XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test, "Messages specific for this msg example");
 
-static int computation_fun(int argc, char *argv[])
+static int computation_fun(int argc, charargv[])
 {
-  const char *pr_name = MSG_process_get_name(MSG_process_self());
-  const char *host_name = MSG_host_get_name(MSG_host_self());
+  const char* pr_name   = MSG_process_get_name(MSG_process_self());
+  const charhost_name = MSG_host_get_name(MSG_host_self());
 
   msg_task_t task = MSG_task_create("Task", 1000000, 1000000, NULL);
 
@@ -26,10 +26,10 @@ static int computation_fun(int argc, char *argv[])
 
 static void launch_computation_worker(msg_host_t host)
 {
-  const char *pr_name = "compute";
-  char **argv = xbt_new(char *, 2);
-  argv[0] = xbt_strdup(pr_name);
-  argv[1] = NULL;
+  const charpr_name = "compute";
+  char** argv         = xbt_new(char*, 2);
+  argv[0]             = xbt_strdup(pr_name);
+  argv[1]             = NULL;
 
   MSG_process_create_with_arguments(pr_name, computation_fun, NULL, host, 1, argv);
 }
@@ -40,17 +40,17 @@ struct task_priv {
   double clock_sta;
 };
 
-static int communication_tx_fun(int argc, char *argv[])
+static int communication_tx_fun(int argc, charargv[])
 {
   xbt_assert(argc == 2);
-  const char *mbox = argv[1];
+  const charmbox = argv[1];
 
   msg_task_t task = MSG_task_create("Task", 1000000, 1000000, NULL);
 
-  struct task_priv *priv = xbt_new(struct task_priv, 1);
-  priv->tx_proc = MSG_process_self();
-  priv->tx_host = MSG_host_self();
-  priv->clock_sta = MSG_get_clock();
+  struct task_privpriv = xbt_new(struct task_priv, 1);
+  priv->tx_proc          = MSG_process_self();
+  priv->tx_host          = MSG_host_self();
+  priv->clock_sta        = MSG_get_clock();
 
   MSG_task_set_data(task, priv);
 
@@ -59,21 +59,21 @@ static int communication_tx_fun(int argc, char *argv[])
   return 0;
 }
 
-static int communication_rx_fun(int argc, char *argv[])
+static int communication_rx_fun(int argc, charargv[])
 {
-  const char *pr_name = MSG_process_get_name(MSG_process_self());
-  const char *host_name = MSG_host_get_name(MSG_host_self());
+  const char* pr_name   = MSG_process_get_name(MSG_process_self());
+  const charhost_name = MSG_host_get_name(MSG_host_self());
   xbt_assert(argc == 2);
-  const char *mbox = argv[1];
+  const charmbox = argv[1];
 
   msg_task_t task = NULL;
   MSG_task_recv(&task, mbox);
 
-  struct task_priv *priv = MSG_task_get_data(task);
-  double clock_end = MSG_get_clock();
+  struct task_privpriv = MSG_task_get_data(task);
+  double clock_end       = MSG_get_clock();
 
-  XBT_INFO("%s:%s to %s:%s => %g sec", MSG_host_get_name(priv->tx_host), MSG_process_get_name(priv->tx_proc),
-      host_name, pr_name, clock_end - priv->clock_sta);
+  XBT_INFO("%s:%s to %s:%s => %g sec", MSG_host_get_name(priv->tx_host), MSG_process_get_name(priv->tx_proc), host_name,
+           pr_name, clock_end - priv->clock_sta);
 
   xbt_free(priv);
   MSG_task_destroy(task);
@@ -83,29 +83,28 @@ static int communication_rx_fun(int argc, char *argv[])
 
 static void launch_communication_worker(msg_host_t tx_host, msg_host_t rx_host)
 {
-  char *mbox = bprintf("MBOX:%s-%s", MSG_host_get_name(tx_host), MSG_host_get_name(rx_host));
-  const char *pr_name_tx =  "comm_tx";
+  char* mbox             = bprintf("MBOX:%s-%s", MSG_host_get_name(tx_host), MSG_host_get_name(rx_host));
+  const char* pr_name_tx = "comm_tx";
 
   char** argv = xbt_new(char*, 3);
-  argv[0] = xbt_strdup(pr_name_tx);
-  argv[1] = xbt_strdup(mbox);
-  argv[2] = NULL;
+  argv[0]     = xbt_strdup(pr_name_tx);
+  argv[1]     = xbt_strdup(mbox);
+  argv[2]     = NULL;
 
   MSG_process_create_with_arguments(pr_name_tx, communication_tx_fun, NULL, tx_host, 2, argv);
 
-  const char *pr_name_rx =  "comm_rx";
-  argv = xbt_new(char *, 3);
-  argv[0] = xbt_strdup(pr_name_rx);
-  argv[1] = xbt_strdup(mbox);
-  argv[2] = NULL;
+  const char* pr_name_rx = "comm_rx";
+  argv                   = xbt_new(char*, 3);
+  argv[0]                = xbt_strdup(pr_name_rx);
+  argv[1]                = xbt_strdup(mbox);
+  argv[2]                = NULL;
 
   MSG_process_create_with_arguments(pr_name_rx, communication_rx_fun, NULL, rx_host, 2, argv);
 
   xbt_free(mbox);
 }
 
-
-static int master_main(int argc, char *argv[])
+static int master_main(int argc, char* argv[])
 {
   msg_host_t pm0 = MSG_host_by_name("Fafard");
   msg_host_t pm1 = MSG_host_by_name("Tremblay");
@@ -140,7 +139,8 @@ static int master_main(int argc, char *argv[])
 
   XBT_INFO("## Test 2 (ended)");
 
-  XBT_INFO("## Test 3 (started): check impact of running a task collocated with a VM (there is no VM noise for the moment)");
+  XBT_INFO(
+      "## Test 3 (started): check impact of running a task collocated with a VM (there is no VM noise for the moment)");
 
   XBT_INFO("### Put a VM on a PM, and put a task to the PM");
   vm0 = MSG_vm_create_core(pm0, "VM0");
@@ -155,7 +155,7 @@ static int master_main(int argc, char *argv[])
            " the moment, there is no degradation for the VMs. Hence, the time should be equals to the time of test 1");
 
   XBT_INFO("### Put two VMs on a PM, and put a task to each VM");
-  vm0 = MSG_vm_create_core(pm0, "VM0");
+  vm0          = MSG_vm_create_core(pm0, "VM0");
   msg_vm_t vm1 = MSG_vm_create_core(pm0, "VM1");
   MSG_vm_start(vm0);
   MSG_vm_start(vm1);
@@ -251,15 +251,15 @@ static int master_main(int argc, char *argv[])
 
 static void launch_master(msg_host_t host)
 {
-  const char *pr_name = "master_";
-  char **argv = xbt_new(char *, 2);
-  argv[0] = xbt_strdup(pr_name);
-  argv[1] = NULL;
+  const charpr_name = "master_";
+  char** argv         = xbt_new(char*, 2);
+  argv[0]             = xbt_strdup(pr_name);
+  argv[1]             = NULL;
 
   MSG_process_create_with_arguments(pr_name, master_main, NULL, host, 1, argv);
 }
 
-int main(int argc, char *argv[])
+int main(int argc, charargv[])
 {
   /* Get the arguments */
   MSG_init(&argc, argv);
@@ -267,7 +267,7 @@ int main(int argc, char *argv[])
   /* load the platform file */
   const char* platform = "../../platforms/small_platform.xml";
   if (argc == 2)
-     platform = argv[1];
+    platform = argv[1];
   MSG_create_environment(platform);
 
   msg_host_t pm0 = MSG_host_by_name("Fafard");