[GNUnet-SVN] r16151 - in gnunet/src: arm nse

[gnunet]

Author: grothoff
Date: 2011-07-23 16:37:37 +0200 (Sat, 23 Jul 2011)
New Revision: 16151

Modified:
   gnunet/src/arm/gnunet-arm.c
   gnunet/src/nse/gnunet-service-nse.c
   gnunet/src/nse/test_nse_multipeer.c
Log:
fixes

Modified: gnunet/src/arm/gnunet-arm.c
===================================================================
--- gnunet/src/arm/gnunet-arm.c 2011-07-23 14:27:40 UTC (rev 16150)
+++ gnunet/src/arm/gnunet-arm.c 2011-07-23 14:37:37 UTC (rev 16151)
@@ -39,7 +39,7 @@
 /**
  * Timeout for stopping ARM.  Extra-long since ARM needs to stop everyone else.
  */
-#define STOP_TIMEOUT_ARM GNUNET_TIME_relative_multiply 
(GNUNET_TIME_UNIT_SECONDS, 30)
+#define STOP_TIMEOUT_ARM GNUNET_TIME_relative_multiply 
(GNUNET_TIME_UNIT_SECONDS, 3)
 
 /**
  * Timeout for starting services, very short because of the strange way start 
works

Modified: gnunet/src/nse/gnunet-service-nse.c
===================================================================
--- gnunet/src/nse/gnunet-service-nse.c 2011-07-23 14:27:40 UTC (rev 16150)
+++ gnunet/src/nse/gnunet-service-nse.c 2011-07-23 14:37:37 UTC (rev 16151)
@@ -870,6 +870,7 @@
              if (peer_entry->transmit_task != GNUNET_SCHEDULER_NO_TASK)
                {
                  GNUNET_SCHEDULER_cancel (peer_entry->transmit_task);
+                 peer_entry->transmit_task = GNUNET_SCHEDULER_NO_TASK;
                  peer_entry->previous_round = GNUNET_NO;
                }
              if (peer_entry->th != NULL)
@@ -1019,7 +1020,7 @@
  * @param identity the public identity of this peer
  * @param publicKey the public key of this peer
  */
-void
+static void
 core_init (void *cls, struct GNUNET_CORE_Handle *server,
           const struct GNUNET_PeerIdentity *identity,
           const struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded *publicKey)
@@ -1046,7 +1047,7 @@
   
   for (i=0;i<HISTORY_SIZE;i++)
     {
-      prev_time.abs_value = next_timestamp.abs_value - (HISTORY_SIZE - i - 1) 
* GNUNET_NSE_INTERVAL.rel_value;
+      prev_time.abs_value = current_timestamp.abs_value - (HISTORY_SIZE - i - 
1) * GNUNET_NSE_INTERVAL.rel_value;
       setup_flood_message (i, prev_time);
     }
   estimate_index = HISTORY_SIZE - 1;

Modified: gnunet/src/nse/test_nse_multipeer.c
===================================================================
--- gnunet/src/nse/test_nse_multipeer.c 2011-07-23 14:27:40 UTC (rev 16150)
+++ gnunet/src/nse/test_nse_multipeer.c 2011-07-23 14:37:37 UTC (rev 16151)
@@ -66,13 +66,15 @@
 /**
  * Check whether peers successfully shut down.
  */
-void
+static void
 shutdown_callback (void *cls, const char *emsg)
 {
   if (emsg != NULL)
     {
 #if VERBOSE
-      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Shutdown of peers failed!\n");
+      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+                 "Shutdown of peers failed: %s!\n",
+                 emsg);
 #endif
       if (ok == 0)
         ok = 666;
@@ -119,9 +121,17 @@
 handle_estimate (void *cls, double estimate, double std_dev)
 {
   struct NSEPeer *peer = cls;
-  fprintf(stderr, "Received network size estimate from peer %s. Size: %f 
std.dev. %f\n", GNUNET_i2s(&peer->daemon->id), estimate, std_dev);
+
+  fprintf (stderr,
+          "Received network size estimate from peer %s. logSize: %f std.dev. 
%f (%f/%u)\n", 
+          GNUNET_i2s(&peer->daemon->id), 
+          estimate, 
+          std_dev,
+          GNUNET_NSE_log_estimate_to_n (estimate),
+          num_peers);
 }
 
+
 static void
 connect_nse_service (void *cls,
                      const struct GNUNET_SCHEDULER_TaskContext *tc)
@@ -135,13 +145,15 @@
     {
       current_peer = GNUNET_malloc(sizeof(struct NSEPeer));
       current_peer->daemon = GNUNET_TESTING_daemon_get(pg, i);
-      current_peer->nse_handle = GNUNET_NSE_connect 
(current_peer->daemon->cfg, &handle_estimate, current_peer);
+      current_peer->nse_handle = GNUNET_NSE_connect (current_peer->daemon->cfg,
+                                                    &handle_estimate, 
+                                                    current_peer);
       GNUNET_assert(current_peer->nse_handle != NULL);
-
       GNUNET_CONTAINER_DLL_insert (peer_head, peer_tail, current_peer);
     }
 }
 
+
 static void
 my_cb (void *cls,
        const char *emsg)
@@ -159,13 +171,15 @@
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Peer Group started successfully, connecting to NSE service for 
each peer!\n");
 #endif
-  GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Have %u connections\n", 
total_connections);
+  GNUNET_log (GNUNET_ERROR_TYPE_WARNING, 
+             "Have %u connections\n", total_connections);
 
   GNUNET_SCHEDULER_add_now(&connect_nse_service, NULL);
 }
 
+
 /**
- * Prototype of a function that will be called whenever
+ * Function that will be called whenever
  * two daemons are connected by the testing library.
  *
  * @param cls closure
@@ -178,15 +192,16 @@
  * @param second_daemon handle for the second daemon
  * @param emsg error message (NULL on success)
  */
-void connect_cb (void *cls,
-                 const struct GNUNET_PeerIdentity *first,
-                 const struct GNUNET_PeerIdentity *second,
-                 uint32_t distance,
-                 const struct GNUNET_CONFIGURATION_Handle *first_cfg,
-                 const struct GNUNET_CONFIGURATION_Handle *second_cfg,
-                 struct GNUNET_TESTING_Daemon *first_daemon,
-                 struct GNUNET_TESTING_Daemon *second_daemon,
-                 const char *emsg)
+static void 
+connect_cb (void *cls,
+           const struct GNUNET_PeerIdentity *first,
+           const struct GNUNET_PeerIdentity *second,
+           uint32_t distance,
+           const struct GNUNET_CONFIGURATION_Handle *first_cfg,
+           const struct GNUNET_CONFIGURATION_Handle *second_cfg,
+           struct GNUNET_TESTING_Daemon *first_daemon,
+           struct GNUNET_TESTING_Daemon *second_daemon,
+           const char *emsg)
 {
   char *second_id;
 
@@ -207,16 +222,22 @@
 {
   struct GNUNET_CONFIGURATION_Handle *testing_cfg;
   unsigned long long total_peers;
+
   ok = 1;
   testing_cfg = GNUNET_CONFIGURATION_create();
   GNUNET_assert(GNUNET_OK == GNUNET_CONFIGURATION_load(testing_cfg, cfgfile));
+
 #if VERBOSE
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Starting daemons.\n");
-  GNUNET_CONFIGURATION_set_value_string (testing_cfg, "testing",
-                                           "use_progressbars",
-                                           "YES");
+  GNUNET_CONFIGURATION_set_value_string (testing_cfg,
+                                        "testing",
+                                        "use_progressbars",
+                                        "YES");
 #endif
-  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (testing_cfg, 
"testing", "num_peers", &total_peers))
+  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (testing_cfg, 
+                                                         "testing",
+                                                         "num_peers",
+                                                         &total_peers))
     total_peers = NUM_PEERS;
 
   peers_left = total_peers;
@@ -231,6 +252,7 @@
   GNUNET_SCHEDULER_add_delayed (TIMEOUT, &shutdown_task, NULL);
 }
 
+
 static int
 check ()
 {