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

[gnunet]

Author: grothoff
Date: 2011-11-02 11:39:55 +0100 (Wed, 02 Nov 2011)
New Revision: 17914

Modified:
   gnunet/src/transport/gnunet-service-transport_neighbours.c
   gnunet/src/transport/transport_api.c
Log:
infinite bw hack

Modified: gnunet/src/transport/gnunet-service-transport_neighbours.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport_neighbours.c  2011-11-02 
10:39:05 UTC (rev 17913)
+++ gnunet/src/transport/gnunet-service-transport_neighbours.c  2011-11-02 
10:39:55 UTC (rev 17914)
@@ -1583,6 +1583,11 @@
   struct NeighbourMapEntry *n;
   struct GNUNET_TIME_Relative ret;
 
+  if (NULL != getenv ("infinite-bandwidth"))
+    {
+      *do_forward = GNUNET_YES;
+      return GNUNET_TIME_UNIT_ZERO;
+    }
   GNUNET_assert (neighbours != NULL);
 
   n = lookup_neighbour (sender);

Modified: gnunet/src/transport/transport_api.c
===================================================================
--- gnunet/src/transport/transport_api.c        2011-11-02 10:39:05 UTC (rev 
17913)
+++ gnunet/src/transport/transport_api.c        2011-11-02 10:39:55 UTC (rev 
17914)
@@ -681,7 +681,7 @@
     }
     th = n->th;
     if (th->notify_size + sizeof (struct OutboundMessage) > size)
-      break;                    /* does not fit */
+      break;                    /* does not fit */    
     if (GNUNET_BANDWIDTH_tracker_get_delay
         (&n->out_tracker, th->notify_size).rel_value > 0)
       break;                    /* too early */
@@ -708,7 +708,8 @@
       memcpy (&cbuf[ret], &obm, sizeof (struct OutboundMessage));
       ret += (mret + sizeof (struct OutboundMessage));
       size -= (mret + sizeof (struct OutboundMessage));
-      GNUNET_BANDWIDTH_tracker_consume (&n->out_tracker, mret);
+      if (NULL == getenv ("infinite-bandwidth"))
+       GNUNET_BANDWIDTH_tracker_consume (&n->out_tracker, mret);
     }
     GNUNET_free (th);
   }