diff options
Diffstat (limited to 'src/main/java/org/gnunet/util/Connection.java')
-rw-r--r-- | src/main/java/org/gnunet/util/Connection.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/java/org/gnunet/util/Connection.java b/src/main/java/org/gnunet/util/Connection.java index 1fd1458..1c569c4 100644 --- a/src/main/java/org/gnunet/util/Connection.java +++ b/src/main/java/org/gnunet/util/Connection.java | |||
@@ -214,7 +214,7 @@ public class Connection { | |||
214 | int n = connectionChannel.read(recvBuffer); | 214 | int n = connectionChannel.read(recvBuffer); |
215 | if (n == -1) { | 215 | if (n == -1) { |
216 | currentReceiveHelper = null; | 216 | currentReceiveHelper = null; |
217 | logger.warn("lost connection to service"); | 217 | logger.warn("lost connection to service, {}", connectionChannel.socket().toString()); |
218 | connectionChannel.close(); | 218 | connectionChannel.close(); |
219 | connectionChannel = null; | 219 | connectionChannel = null; |
220 | if (Connection.this.currentTransmitHelper != null) { | 220 | if (Connection.this.currentTransmitHelper != null) { |
@@ -384,7 +384,8 @@ public class Connection { | |||
384 | String.format("tried to send message with binary size %s but size in header %s", | 384 | String.format("tried to send message with binary size %s but size in header %s", |
385 | b.length, gm.header.messageSize)); | 385 | b.length, gm.header.messageSize)); |
386 | } | 386 | } |
387 | logger.debug("sending message (size={},type={})", b.length, gm.header.messageType); | 387 | logger.debug("sending message (size={},type={}) over {}", |
388 | new String[] {String.valueOf(b.length), String.valueOf(gm.header.messageType), connectionChannel.socket().toString()}); | ||
388 | if (transmitBuffer.remaining() < b.length) { | 389 | if (transmitBuffer.remaining() < b.length) { |
389 | ByteBuffer buf = ByteBuffer.allocate(b.length + transmitBuffer.capacity()); | 390 | ByteBuffer buf = ByteBuffer.allocate(b.length + transmitBuffer.capacity()); |
390 | transmitBuffer.flip(); | 391 | transmitBuffer.flip(); |