From a1873e74e5cb5bdaeaaea4af8fd13c13aacf8de8 Mon Sep 17 00:00:00 2001
From: zzz <zzz@mail.i2p>
Date: Wed, 3 Oct 2012 17:40:31 +0000
Subject: [PATCH] cleanup
---
.../i2p/router/transport/ntcp/NTCPConnection.java | 15 ++++++++-------
1 file changed, 8 insertions(+), 7 deletions(-)
diff --git a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java
index 33f4eb15d1..eb84d6c909 100644
--- a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java
+++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java
@@ -957,9 +957,10 @@ class NTCPConnection implements FIFOBandwidthLimiter.CompleteListener {
if (clearMessage) {
// see synchronization comments in prepareNextWriteFast()
synchronized (_outbound) {
- if (_currentOutbound != null)
+ if (_currentOutbound != null) {
msg = _currentOutbound;
- _currentOutbound = null;
+ _currentOutbound = null;
+ }
}
if (msg != null) {
_lastSendTime = System.currentTimeMillis();
@@ -1032,11 +1033,11 @@ class NTCPConnection implements FIFOBandwidthLimiter.CompleteListener {
//_sendBps15s = (0.955f)*_sendBps15s + (0.045f)*((float)sent*1000f)/(float)time;
//_recvBps15s = (0.955f)*_recvBps15s + (0.045f)*((float)recv*1000)/(float)time;
- if (_log.shouldLog(Log.DEBUG))
- _log.debug("Rates updated to "
- + _sendBps + '/' + _recvBps + "Bps in/out "
- //+ _sendBps15s + "/" + _recvBps15s + "Bps in/out 15s after "
- + sent + '/' + recv + " in " + DataHelper.formatDuration(time));
+ //if (_log.shouldLog(Log.DEBUG))
+ // _log.debug("Rates updated to "
+ // + _sendBps + '/' + _recvBps + "Bps in/out "
+ // //+ _sendBps15s + "/" + _recvBps15s + "Bps in/out 15s after "
+ // + sent + '/' + recv + " in " + DataHelper.formatDuration(time));
}
}
--
GitLab