From 9f1189e606bbc9b77c6bad3e89dfb7f7e3760c59 Mon Sep 17 00:00:00 2001
From: jrandom <jrandom>
Date: Sun, 13 Jun 2004 19:39:42 +0000
Subject: [PATCH] use a bandwidth limited stream instead of asking for the
 allocation of the entire buffer at once (since, uh, its not likely that the
 bandwidth limiter will ever have hundreds of KBytes available for use)

---
 router/java/src/net/i2p/router/SubmitMessageHistoryJob.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/router/java/src/net/i2p/router/SubmitMessageHistoryJob.java b/router/java/src/net/i2p/router/SubmitMessageHistoryJob.java
index 8ad99d565..e23b9bc07 100644
--- a/router/java/src/net/i2p/router/SubmitMessageHistoryJob.java
+++ b/router/java/src/net/i2p/router/SubmitMessageHistoryJob.java
@@ -8,6 +8,8 @@ import net.i2p.util.HTTPSendData;
 import net.i2p.util.I2PThread;
 import net.i2p.util.Log;
 
+import net.i2p.router.transport.BandwidthLimitedInputStream;
+
 /**
  * Job that, if its allowed to, will submit the data gathered by the MessageHistory
  * component to some URL so that the network can be debugged more easily.  By default
@@ -87,8 +89,8 @@ public class SubmitMessageHistoryJob extends JobImpl {
             if (size > 0)
                 expectedSend += (int)size/10; // compression
             FileInputStream fin = new FileInputStream(dataFile);
-            _context.bandwidthLimiter().delayOutbound(null, expectedSend);
-            boolean sent = HTTPSendData.postData(url, size, fin);
+            BandwidthLimitedInputStream in = new BandwidthLimitedInputStream(_context, fin, null, true);
+            boolean sent = HTTPSendData.postData(url, size, in);
             fin.close();
             boolean deleted = dataFile.delete();
             _log.debug("Submitted " + size + " bytes? " + sent + " and deleted? " + deleted);