gauger changes, thanks bart (:
authorNathan S. Evans <evans@in.tum.de>
Wed, 23 Feb 2011 10:52:16 +0000 (10:52 +0000)
committerNathan S. Evans <evans@in.tum.de>
Wed, 23 Feb 2011 10:52:16 +0000 (10:52 +0000)
src/include/gauger.h
src/transport/test_quota_compliance.c
src/transport/test_transport_api.c
src/transport/test_transport_api_reliability.c
src/transport/test_transport_api_unreliability.c

index b636614b7c82f30bea4e4ef57e4733f1d41d951d..ae3c58ac82eaeb80a9c00de965541c306ef3fb4d 100644 (file)
@@ -1,18 +1,12 @@
 #ifndef __GAUGER_H__
 #define __GAUGER_H__
 
-#ifndef WINDOWS
-
 #include <unistd.h>
 #include <stdio.h>
 #include <sys/wait.h>
 
-#define GAUGER(counter, value) {char __gauger_s[64];pid_t __gauger_p;if(!(__gauger_p=fork())){if(!fork()){sprintf(__gauger_s,"%llu", (unsigned long long) value);execlp("gauger-cli.py","gauger-cli.py",counter, __gauger_s,(char*)NULL);_exit(1);}else{_exit(0);}}else{waitpid(__gauger_p,NULL,0);}}
-
-#else
+#define GAUGER(counter, value, unit) {char* __gauger_v[8];char __gauger_s[32];pid_t __gauger_p; if(!(__gauger_p=fork())){if(!fork()){sprintf(__gauger_s,"%llu", (unsigned long long) (value));__gauger_v[0] = "gauger-cli.py";__gauger_v[1] = "-n";__gauger_v[2] = counter;__gauger_v[3] = "-d";__gauger_v[4] = __gauger_s;__gauger_v[5] = "-u";__gauger_v[6] = unit;__gauger_v[7] = (char *)NULL;execvp("gauger-cli.py",__gauger_v);perror("gauger");_exit(1);}else{_exit(0);}}else{waitpid(__gauger_p,NULL,0);}}
 
-#define GAUGER(counter, value) {}
-
-#endif
+#define GAUGER_ID(counter, value, unit, id) {char* __gauger_v[10];char __gauger_s[32];pid_t __gauger_p; if(!(__gauger_p=fork())){if(!fork()){sprintf(__gauger_s,"%llu", (unsigned long long) (value));__gauger_v[0] = "gauger-cli.py";__gauger_v[1] = "-n";__gauger_v[2] = counter;__gauger_v[3] = "-d";__gauger_v[4] = __gauger_s;__gauger_v[5] = "-u";__gauger_v[6] = unit;__gauger_v[7] = "-i";__gauger_v[8] = id;__gauger_v[9] = (char *)NULL;execvp("gauger-cli.py",__gauger_v);perror("gauger");_exit(1);}else{_exit(0);}}else{waitpid(__gauger_p,NULL,0);}}
 
 #endif
index 20a9b1f156fb58d011e2d8e5b141ce1beb228112..219971725578acc47f2ec042c5019f49ef73da5a 100644 (file)
@@ -669,7 +669,7 @@ exchange_hello (void *cls,
   GNUNET_assert (GNUNET_OK ==
                  GNUNET_HELLO_get_id ((const struct GNUNET_HELLO_Message *)
                                       message, &me->id));
-  GNUNET_TRANSPORT_offer_hello (p2.th, message);
+  GNUNET_TRANSPORT_offer_hello (p2.th, message, NULL, NULL);
   GNUNET_TRANSPORT_get_hello (p2.th, &exchange_hello_last, &p2);
 }
 
index 60cb7866f0c33947c2c1913e019b31eb880ac3e3..d78e3264bb3e85294c727a923b93a41e1f011ef6 100644 (file)
@@ -351,7 +351,7 @@ exchange_hello (void *cls,
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Received HELLO size %d\n", GNUNET_HELLO_size((const struct GNUNET_HELLO_Message *)message));
 
-  GNUNET_TRANSPORT_offer_hello (p2.th, message);
+  GNUNET_TRANSPORT_offer_hello (p2.th, message, NULL, NULL);
   GNUNET_TRANSPORT_get_hello (p2.th, &exchange_hello_last, &p2);
 }
 
index 472c30d0d46935077544ff4fc1f2985a819294c9..a5929ff48ae6d93d371c9767847a42044a76436d 100644 (file)
@@ -133,8 +133,8 @@ end ()
   fprintf (stderr,
           "\nThroughput was %llu kb/s\n",
           total_bytes * 1000 / 1024 / delta);
-  GNUNET_asprintf(&value_name, "reliable-%s_kb/s", test_name);
-  GAUGER (value_name, (int)(total_bytes * 1000 / 1024 /delta));
+  GNUNET_asprintf(&value_name, "reliable_%s", test_name);
+  GAUGER (value_name, (int)(total_bytes * 1000 / 1024 /delta), "kbs");
   GNUNET_free(value_name);
   ok = 0;
 
@@ -527,7 +527,7 @@ exchange_hello (void *cls,
               "Received HELLO size %d\n",
              GNUNET_HELLO_size((const struct GNUNET_HELLO_Message *)message));
 #endif
-  GNUNET_TRANSPORT_offer_hello (p2.th, message);
+  GNUNET_TRANSPORT_offer_hello (p2.th, message, NULL, NULL);
   GNUNET_TRANSPORT_get_hello (p2.th, &exchange_hello_last, &p2);
 }
 
index 26d4cb035cb1b6217a9e508440420c5c9818e016..62c9a56834f3a69bc08782b7882b299f2c5c1e2c 100644 (file)
@@ -186,8 +186,8 @@ end ()
              "Transports disconnected, returning success!\n");
 #endif
   delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value;
-  GNUNET_asprintf(&value_name, "unreliable-%s_kb/s", test_name);
-  GAUGER (value_name, (int)(total_bytes * 1000 / 1024 /delta));
+  GNUNET_asprintf(&value_name, "unreliable_%s", test_name);
+  GAUGER (value_name, (int)(total_bytes * 1000 / 1024 /delta), "kbs");
   GNUNET_free(value_name);
   fprintf (stderr,
           "\nThroughput was %llu kb/s\n",
@@ -227,11 +227,11 @@ end_unreliably ()
   fprintf (stderr,
            "\nThroughput was %llu kb/s\n",
            total_bytes * 1000 / 1024 / delta);
-  GNUNET_asprintf(&value_name, "unreliable-%s_kb/s", test_name);
-  GAUGER (value_name, (int)(total_bytes * 1000 / 1024 /delta));
+  GNUNET_asprintf(&value_name, "unreliable_%s", test_name);
+  GAUGER (value_name, (int)(total_bytes * 1000 / 1024 /delta), "kbs");
   GNUNET_free(value_name);
-  GNUNET_asprintf(&value_name, "unreliable-%s_failed messages", test_name);
-  GAUGER (value_name, (int)num_failed);
+  GNUNET_asprintf(&value_name, "unreliable_failed_%s", test_name);
+  GAUGER (value_name, (int)num_failed, "count");
   GNUNET_free(value_name);
   GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "Had %d failed messages!\n", num_failed);
   ok = 0;
@@ -624,7 +624,7 @@ exchange_hello (void *cls,
               "Received HELLO size %d\n",
              GNUNET_HELLO_size((const struct GNUNET_HELLO_Message *)message));
 #endif
-  GNUNET_TRANSPORT_offer_hello (p2.th, message);
+  GNUNET_TRANSPORT_offer_hello (p2.th, message, NULL, NULL);
   GNUNET_TRANSPORT_get_hello (p2.th, &exchange_hello_last, &p2);
 }