From: Christian Grothoff <christian@grothoff.org>
Date: Sun, 5 Jun 2011 12:31:10 +0000 (+0000)
Subject: fix
X-Git-Tag: initial-import-from-subversion-38251~18332
X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=d8dc57a9aafa0bfa3669e84a5a09a8feeed63e68;p=oweals%2Fgnunet.git

fix
---

diff --git a/src/transport/transport_api_new.c b/src/transport/transport_api_new.c
index 5ec5cb6d1..86cf7f175 100644
--- a/src/transport/transport_api_new.c
+++ b/src/transport/transport_api_new.c
@@ -625,6 +625,7 @@ transport_notify_ready (void *cls, size_t size, void *buf)
   struct GNUNET_TRANSPORT_TransmitHandle *th;
   struct Neighbour *n;
   char *cbuf;
+  struct GNUNET_TIME_Relative delay;
   struct OutboundMessage obm;
   size_t ret;
   size_t nret;
@@ -676,7 +677,15 @@ 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 */
+	{
+	  delay = GNUNET_BANDWIDTH_tracker_get_delay (&n->out_tracker, size);
+	  if (delay.rel_value > GNUNET_TIME_absolute_get_remaining (n->th->timeout).rel_value)
+	    delay.rel_value = 0; /* notify immediately (with failure) */
+	  n->hn = GNUNET_CONTAINER_heap_insert (h->ready_heap,
+						n, 
+						delay.rel_value);
+	  break; /* does not fit */
+	}
       n->th = NULL;
       n->is_ready = GNUNET_NO;
       GNUNET_assert (size >= sizeof (struct OutboundMessage));