infinite bw hack

diff --git a/src/transport/gnunet-service-transport_neighbours.c b/src/transport/gnunet-service-transport_neighbours.c
index a1ce1364f2a1dd719821d96aeb8b42ae812362e6..b3d940bdbeb84831b78d38911a96d8109d0cffcf 100644 (file)
--- a/src/transport/gnunet-service-transport_neighbours.c
+++ b/src/transport/gnunet-service-transport_neighbours.c
@@ -1583,6 +1583,11 @@ GST_neighbours_calculate_receive_delay (const struct GNUNET_PeerIdentity
   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);

diff --git a/src/transport/transport_api.c b/src/transport/transport_api.c
index 2ececc10da107a7822d48f45c9bbd80a2268d37c..67d3d76740bfb41d5e5b50cde209a8aa995c3fcc 100644 (file)
--- a/src/transport/transport_api.c
+++ b/src/transport/transport_api.c
@@ -681,7 +681,7 @@ transport_notify_ready (void *cls, size_t size, void *buf)
     }
     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 @@ transport_notify_ready (void *cls, size_t size, void *buf)
       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);
   }