[GNUnet-SVN] r36520 - gnunet/src/transport

[gnunet]

Author: grothoff
Date: 2015-10-17 21:43:02 +0200 (Sat, 17 Oct 2015)
New Revision: 36520

Modified:
   gnunet/src/transport/gnunet-service-transport_clients.c
Log:
add logging to watch for transmission delays within transport service

Modified: gnunet/src/transport/gnunet-service-transport_clients.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport_clients.c     2015-10-17 
19:34:43 UTC (rev 36519)
+++ gnunet/src/transport/gnunet-service-transport_clients.c     2015-10-17 
19:43:02 UTC (rev 36520)
@@ -688,6 +688,11 @@
    * Peer that was the target.
    */
   struct GNUNET_PeerIdentity target;
+
+  /**
+   * At what time did we receive the message?
+   */
+  struct GNUNET_TIME_Absolute send_time;
 };
 
 
@@ -708,7 +713,28 @@
 {
   struct SendTransmitContinuationContext *stcc = cls;
   struct SendOkMessage send_ok_msg;
+  struct GNUNET_TIME_Relative delay;
 
+  delay = GNUNET_TIME_absolute_get_duration (stcc->send_time);
+  if (delay.rel_value_us > GNUNET_CONSTANTS_LATENCY_WARN.rel_value_us)
+    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+                "It took us %s to send %u/%u bytes to %s (%d)\n",
+                GNUNET_STRINGS_relative_time_to_string (delay,
+                                                        GNUNET_YES),
+                (unsigned int) bytes_payload,
+                (unsigned int) bytes_on_wire,
+                GNUNET_i2s (&stcc->target),
+                success);
+  else
+    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+                "It took us %s to send %u/%u bytes to %s (%d)\n",
+                GNUNET_STRINGS_relative_time_to_string (delay,
+                                                        GNUNET_YES),
+                (unsigned int) bytes_payload,
+                (unsigned int) bytes_on_wire,
+                GNUNET_i2s (&stcc->target),
+                success);
+
   if (GST_neighbours_test_connected (&stcc->target))
   {
     /* Only send confirmation if we are still connected */
@@ -800,6 +826,7 @@
   stcc = GNUNET_new (struct SendTransmitContinuationContext);
   stcc->target = obm->peer;
   stcc->client = client;
+  stcc->send_time = GNUNET_TIME_absolute_get ();
   GNUNET_SERVER_client_keep (client);
   GST_manipulation_send (&obm->peer,
                          obmm,