I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

dont buffer the reads, since we dont want that buffer to interfere with either the bandwidth limiting or the AES decryption

Browse Source 
logging
This commit is contained in:
jrandom
2004-06-20 00:46:57 +00:00
committed by zzz
parent 95a7938328
commit c9ee2a92a3
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
router/java/src/net/i2p/router/transport/tcp/RestrictiveTCPConnection.java
View File

@ -227,12 +227,17 @@ class RestrictiveTCPConnection extends TCPConnection {
sockCreator.setPriority(I2PThread.MIN_PRIORITY); sockCreator.setPriority(I2PThread.MIN_PRIORITY);
sockCreator.start(); sockCreator.start();
if (_log.shouldLog(Log.DEBUG)) _log.debug("Before joining socket creator via peer callback..."); if (_log.shouldLog(Log.DEBUG))
_log.debug("Before joining socket creator via peer callback...");
try { try {
synchronized (creator) { synchronized (creator) {
creator.wait(TCPTransport.SOCKET_CREATE_TIMEOUT); creator.wait(TCPTransport.SOCKET_CREATE_TIMEOUT);
} }
} catch (InterruptedException ie) {} } catch (InterruptedException ie) {
if (_log.shouldLog(Log.DEBUG))
_log.debug("Timed out waiting to connect to " + peer.getHost()
+ ':' + peer.getPort());
}
boolean established = creator.couldEstablish(); boolean established = creator.couldEstablish();
// returns a socket if and only if the connection was established and the I2P handshake byte sent and received // returns a socket if and only if the connection was established and the I2P handshake byte sent and received
@ -289,7 +294,7 @@ class RestrictiveTCPConnection extends TCPConnection {
if (_log.shouldLog(Log.INFO)) if (_log.shouldLog(Log.INFO))
_log.info("TCP connection " + _id + " established with " + _remoteIdentity.getHash().toBase64()); _log.info("TCP connection " + _id + " established with " + _remoteIdentity.getHash().toBase64());
_in = new AESInputStream(_context, new BandwidthLimitedInputStream(_context, new BufferedInputStream(_in, BUF_SIZE), _remoteIdentity), _key, _iv); _in = new AESInputStream(_context, new BandwidthLimitedInputStream(_context, _in, _remoteIdentity), _key, _iv);
_out = new AESOutputStream(_context, new BufferedOutputStream(new BandwidthLimitedOutputStream(_context, _out, _remoteIdentity), BUF_SIZE), _key, _iv); _out = new AESOutputStream(_context, new BufferedOutputStream(new BandwidthLimitedOutputStream(_context, _out, _remoteIdentity), BUF_SIZE), _key, _iv);
_socket.setSoTimeout(0); _socket.setSoTimeout(0);
success = _context.clock().now(); success = _context.clock().now();