aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/gnunet/util/Connection.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/gnunet/util/Connection.java')
-rw-r--r--src/main/java/org/gnunet/util/Connection.java5
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();