Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
cleanups (among which example simplification)
authormquinson <mquinson@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Tue, 6 Nov 2007 08:01:54 +0000 (08:01 +0000)
committermquinson <mquinson@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Tue, 6 Nov 2007 08:01:54 +0000 (08:01 +0000)
git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@4973 48e7efb5-ca39-0410-a469-dd3cf9ba447f

examples/msg/properties/msg_prop.c
examples/msg/properties/msg_prop.tesh
examples/msg/properties/msg_test.tesh [deleted file]

index 8547755..9706ed0 100644 (file)
@@ -1,6 +1,6 @@
 /*     $Id$     */
 
-/* Copyright (c) 2006. All rights reserved.        */
+/* Copyright (c) 2007. SimGrid Team. All rights reserved.                   */
 
 /* This program is free software; you can redistribute it and/or modify it
  * under the terms of the license (GNU LGPL) which comes with this package. */
@@ -22,44 +22,14 @@ int slave(int argc, char *argv[]);
 int forwarder(int argc, char *argv[]);
 MSG_error_t test_all(const char *platform_file, const char *application_file);
 
-typedef enum {
-  PORT_22 = 0,
-  MAX_CHANNEL
-} channel_t;
-
-#define FINALIZE ((void*)221297) /* a magic number to tell people to stop working */
-
 /** Emitter function  */
 int master(int argc, char *argv[])
 {
   int slaves_count = 0;
   m_host_t *slaves = NULL;
-  m_task_t *todo = NULL;
-  int number_of_tasks = 0;
-  double task_comp_size = 0;
-  double task_comm_size = 0;
-
 
   int i;
 
-  xbt_assert1(sscanf(argv[1],"%d", &number_of_tasks),
-        "Invalid argument %s\n",argv[1]);
-  xbt_assert1(sscanf(argv[2],"%lg", &task_comp_size),
-        "Invalid argument %s\n",argv[2]);
-  xbt_assert1(sscanf(argv[3],"%lg", &task_comm_size),
-        "Invalid argument %s\n",argv[3]);
-
-  {                  /*  Task creation */
-    char sprintf_buffer[64];
-
-    todo = xbt_new(m_task_t, sizeof(m_task_t) * number_of_tasks);
-
-    for (i = 0; i < number_of_tasks; i++) {
-      sprintf(sprintf_buffer, "Task_%d", i);
-      todo[i] = MSG_task_create(sprintf_buffer, task_comp_size, task_comm_size, NULL);
-    }
-  }
-
   {                  /* Process organisation */
     slaves_count = argc - 4;
     slaves = xbt_new(m_host_t, sizeof(m_host_t) * slaves_count);
@@ -79,7 +49,7 @@ int master(int argc, char *argv[])
       }
 
      /* Try to get a property that does not exist */
-     char noexist[]="Unknown";
+     const char *noexist="Unknown";
      const char*value = MSG_host_get_property_value(slaves[i-4], noexist);
      if ( value == NULL) 
        INFO2("Property: %s for host %s is undefined", noexist, argv[i]);
@@ -90,120 +60,44 @@ int master(int argc, char *argv[])
       INFO0("Trying to modify a host property");
       char exist[]="Hdd";
       value = MSG_host_get_property_value(slaves[i-4],exist);
-      if ( value == NULL) 
-        INFO1("\tProperty: %s is undefined", exist);
-      else {
-        INFO2("\tProperty: %s old value: %s", exist, value);
-        xbt_dict_set(props, exist, strdup("250"), free);  
-      }
+      xbt_assert1(value,"\tProperty %s is undefined", exist);
+      INFO2("\tProperty: %s old value: %s", exist, value);
+      xbt_dict_set(props, exist, xbt_strdup("250"), free);  
  
       /* Test if we have changed the value */
       value = MSG_host_get_property_value(slaves[i-4],exist);
-      if ( value == NULL) 
-        INFO1("\tProperty: %s is undefined", exist);
-      else
-        INFO2("\tProperty: %s new value: %s", exist, value);
+      xbt_assert1(value,"\tProperty %s is undefined", exist);
+      INFO2("\tProperty: %s new value: %s", exist, value);
     }
   }
-
-  for (i = 0; i < number_of_tasks; i++) {
-    if(MSG_host_self()==slaves[i % slaves_count]) {
-    }
-    MSG_task_put(todo[i], slaves[i % slaves_count],
-                 PORT_22);
-  }
-  
-  for (i = 0; i < slaves_count; i++) 
-    MSG_task_put(MSG_task_create("finalize", 0, 0, FINALIZE),
-                slaves[i], PORT_22);
   
   free(slaves);
-  free(todo);
   return 0;
 } /* end_of_master */
 
 /** Receiver function  */
 int slave(int argc, char *argv[])
 {
-  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));
-      if(MSG_task_get_data(task)==FINALIZE) {
-       MSG_task_destroy(task);
-       break;
-      }
-
-      /* Get the property list of current slave process */
-      xbt_dict_t props = MSG_process_get_properties(MSG_process_self());
-      xbt_dict_cursor_t cursor=NULL;
-      char *key,*data;
-
-      /* Print the properties of the process */
-      xbt_dict_foreach(props,cursor,key,data) {
-         INFO3("Property: %s for process %s has value: %s",key,MSG_process_get_name(MSG_process_self()),data);
-      }
-
-      /* Try to get a property that does not exist */
-      char noexist[]="UnknownProcessProp";
-      const char *value = MSG_process_get_property_value(MSG_process_self(),noexist);
-      if ( value == NULL) 
-        INFO2("Property: %s for process %s is undefined", noexist, MSG_process_get_name(MSG_process_self()));
-      else
-        INFO3("Property: %s for process %s has value: %s", noexist, MSG_process_get_name(MSG_process_self()), value);
-
-      MSG_task_execute(task);
-      MSG_task_destroy(task);
-    } else {
-       xbt_die("Hey ?! What's up ?");
-    }
+  /* Get the property list of current slave process */
+  xbt_dict_t props = MSG_process_get_properties(MSG_process_self());
+  xbt_dict_cursor_t cursor=NULL;
+  char *key,*data;
+
+  /* Print the properties of the process */
+  xbt_dict_foreach(props,cursor,key,data) {
+     INFO3("Property: %s for process %s has value: %s",key,MSG_process_get_name(MSG_process_self()),data);
   }
-  return 0;
-} /* end_of_slave */
-
-/** Forwarder function */
-int forwarder(int argc, char *argv[])
-{
-  int i;
-  int slaves_count;
-  m_host_t *slaves;
 
-  {                  /* Process organisation */
-    slaves_count = argc - 1;
-    slaves = calloc(slaves_count, sizeof(m_host_t));
-    
-    for (i = 1; i < argc; i++) {
-      slaves[i-1] = MSG_get_host_by_name(argv[i]);
-      xbt_assert1(slaves[i-1]!=NULL, "Unknown host %s. Stopping Now! ", argv[i]);
-    }
-  }
+  /* Try to get a property that does not exist */
+  const char *noexist="UnknownProcessProp";
+  const char *value = MSG_process_get_property_value(MSG_process_self(),noexist);
+  if ( value == NULL) 
+    INFO2("Property: %s for process %s is undefined", noexist, MSG_process_get_name(MSG_process_self()));
+  else
+    INFO3("Property: %s for process %s has value: %s", noexist, MSG_process_get_name(MSG_process_self()), value);
 
-  i=0;
-  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));
-      if(MSG_task_get_data(task)==FINALIZE) {
-       INFO0("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);
-       MSG_task_destroy(task);
-       break;
-      }
-      MSG_task_put(task, slaves[i % slaves_count],
-                  PORT_22);
-      i++;
-    } else {
-       xbt_die("Hey ?! What's up ?");    
-      }
-  }
   return 0;
-} /* end_of_forwarder */
+} /* end_of_slave */
 
 /** Test function */
 MSG_error_t test_all(const char *platform_file,
@@ -213,14 +107,13 @@ MSG_error_t test_all(const char *platform_file,
 
   /* MSG_config("surf_workstation_model","KCCFLN05"); */
   {                            /*  Simulation setting */
-    MSG_set_channel_number(MAX_CHANNEL);
+//    MSG_set_channel_number(MAX_CHANNEL);
     MSG_paje_output("msg_test.trace");
     MSG_create_environment(platform_file);
   }
   {                            /*   Application deployment */
     MSG_function_register("master", master);
     MSG_function_register("slave", slave);
-    MSG_function_register("forwarder", forwarder);
     MSG_launch_application(application_file);
   }
   res = MSG_main();
index 7a86f5b..23fc6b0 100644 (file)
@@ -8,9 +8,7 @@ $ $SG_TEST_EXENV properties/msg_prop$EXEEXT ${srcdir:=.}/../platforms/prop.xml $
 > [C1-01:master:(1) 0.000000] [test/INFO] Trying to modify a host property
 > [C1-01:master:(1) 0.000000] [test/INFO]      Property: Hdd old value: 120
 > [C1-01:master:(1) 0.000000] [test/INFO]      Property: Hdd new value: 250
-> [C1-00:slave:(2) 0.020200] [test/INFO] Received "Task_0" 
-> [C1-00:slave:(2) 0.020200] [test/INFO] Property: SomeProp for process slave has value: SomeValue
-> [C1-00:slave:(2) 0.020200] [test/INFO] Property: UnknownProcessProp for process slave is undefined
-> [C1-00:slave:(2) 0.070400] [test/INFO] Received "finalize" 
-> [0.070400] [test/INFO] Simulation time 0.0704
+> [C1-00:slave:(2) 0.000000] [test/INFO] Property: SomeProp for process slave has value: SomeValue
+> [C1-00:slave:(2) 0.000000] [test/INFO] Property: UnknownProcessProp for process slave is undefined
+> [0.000000] [test/INFO] Simulation time 0
 
diff --git a/examples/msg/properties/msg_test.tesh b/examples/msg/properties/msg_test.tesh
deleted file mode 100644 (file)
index 918763b..0000000
+++ /dev/null
@@ -1,13 +0,0 @@
-#! ./tesh
-
-p Testing a MSG application with properties in the XML for Hosts, Links and Processes
-
-$ $SG_TEST_EXENV ./msg_prop$EXEEXT ${srcdir:=.}/deployment_platform.xml ${srcdir:=.}/deployment_properties.xml 
-> [Jacquelin:master:(1) 0.000000] [msg_test/INFO] Property: mem for host: Boivin has value: 654321
-> [Jacquelin:master:(1) 0.000000] [msg_test/INFO] Property: disk for host: Boivin has value: 123456
-> [Jacquelin:master:(1) 0.000000] [msg_test/INFO] Property: Unknown for host Boivin is undefined
-> [Boivin:slave:(2) 0.303833] [msg_test/INFO] Received "Task_0" 
-> [Boivin:slave:(2) 0.303833] [msg_test/INFO] Property: SomeProp for process slave has value: SomeValue
-> [Boivin:slave:(2) 0.303833] [msg_test/INFO] Property: UnknownProcessProp for process slave is undefined
-> [Boivin:slave:(2) 0.814139] [msg_test/INFO] Received "finalize" 
-> [0.814139] [msg_test/INFO] Simulation time 0.814139