I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit 23ad9693 authored by kytv's avatar kytv
Browse files

merge of '9c2afc5c3b2920c5284346d3b93a8075fc9d2f37'

     and 'cba0dcc238e5631aff5850f49d9cb07ec70e8f65'
parents fda3ef2c b475e31f
No related branches found
No related tags found
No related merge requests found
...@@ -42,7 +42,7 @@ public class I2PTunnelHTTPClientRunner extends I2PTunnelRunner { ...@@ -42,7 +42,7 @@ public class I2PTunnelHTTPClientRunner extends I2PTunnelRunner {
*/ */
@Override @Override
protected void close(OutputStream out, InputStream in, OutputStream i2pout, InputStream i2pin, protected void close(OutputStream out, InputStream in, OutputStream i2pout, InputStream i2pin,
Socket s, I2PSocket i2ps, Thread t1, Thread t2) throws InterruptedException, IOException { Socket s, I2PSocket i2ps, Thread t1, Thread t2) throws InterruptedException {
try { try {
i2pin.close(); i2pin.close();
} catch (IOException ioe) { } catch (IOException ioe) {
......
...@@ -143,6 +143,7 @@ public class I2PTunnelRunner extends I2PAppThread implements I2PSocket.SocketErr ...@@ -143,6 +143,7 @@ public class I2PTunnelRunner extends I2PAppThread implements I2PSocket.SocketErr
InputStream i2pin = i2ps.getInputStream(); InputStream i2pin = i2ps.getInputStream();
OutputStream i2pout = i2ps.getOutputStream(); //new BufferedOutputStream(i2ps.getOutputStream(), MAX_PACKET_SIZE); OutputStream i2pout = i2ps.getOutputStream(); //new BufferedOutputStream(i2ps.getOutputStream(), MAX_PACKET_SIZE);
if (initialI2PData != null) { if (initialI2PData != null) {
// why synchronize this? we could be in here a LONG time for large initial data
synchronized (slock) { synchronized (slock) {
// this does not increment totalSent // this does not increment totalSent
i2pout.write(initialI2PData); i2pout.write(initialI2PData);
...@@ -182,8 +183,11 @@ public class I2PTunnelRunner extends I2PAppThread implements I2PSocket.SocketErr ...@@ -182,8 +183,11 @@ public class I2PTunnelRunner extends I2PAppThread implements I2PSocket.SocketErr
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
_log.debug("runner has a timeout job, totalReceived = " + totalReceived _log.debug("runner has a timeout job, totalReceived = " + totalReceived
+ " totalSent = " + totalSent + " job = " + onTimeout); + " totalSent = " + totalSent + " job = " + onTimeout);
// should we only look at totalReceived? // Run even if totalSent > 0, as that's probably POST data.
if ( (totalSent <= 0) && (totalReceived <= 0) ) // This will be run even if initialSocketData != null, it's the timeout job's
// responsibility to know that and decide whether or not to write to the socket.
// HTTPClient never sets initialSocketData.
if (totalReceived <= 0)
onTimeout.run(); onTimeout.run();
} }
...@@ -234,7 +238,7 @@ public class I2PTunnelRunner extends I2PAppThread implements I2PSocket.SocketErr ...@@ -234,7 +238,7 @@ public class I2PTunnelRunner extends I2PAppThread implements I2PSocket.SocketErr
} }
protected void close(OutputStream out, InputStream in, OutputStream i2pout, InputStream i2pin, protected void close(OutputStream out, InputStream in, OutputStream i2pout, InputStream i2pin,
Socket s, I2PSocket i2ps, Thread t1, Thread t2) throws InterruptedException, IOException { Socket s, I2PSocket i2ps, Thread t1, Thread t2) throws InterruptedException {
try { try {
out.flush(); out.flush();
} catch (IOException ioe) { } catch (IOException ioe) {
......
* 2011-10-19 zzz * 2011-10-19 zzz
* I2PTunnel: Fix timeout message on POST (ticket # )
* NetDB: Reduce RI max expiration again * NetDB: Reduce RI max expiration again
* 2011-10-18 zzz * 2011-10-18 zzz
......
...@@ -18,7 +18,7 @@ public class RouterVersion { ...@@ -18,7 +18,7 @@ public class RouterVersion {
/** deprecated */ /** deprecated */
public final static String ID = "Monotone"; public final static String ID = "Monotone";
public final static String VERSION = CoreVersion.VERSION; public final static String VERSION = CoreVersion.VERSION;
public final static long BUILD = 4; public final static long BUILD = 5;
/** for example "-test" */ /** for example "-test" */
public final static String EXTRA = "-rc"; public final static String EXTRA = "-rc";
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment