From 20d9b41ade28ad770f376f5a6d8e53068a062b27 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Wed, 2 Nov 2011 10:39:55 +0000 Subject: [PATCH] infinite bw hack --- src/transport/gnunet-service-transport_neighbours.c | 5 +++++ src/transport/transport_api.c | 5 +++-- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/src/transport/gnunet-service-transport_neighbours.c b/src/transport/gnunet-service-transport_neighbours.c index a1ce1364f..b3d940bdb 100644 --- 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 2ececc10d..67d3d7674 100644 --- 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); } -- 2.25.1