summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-05-23 14:03:51 +0200
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-05-23 14:03:51 +0200
commit8022a834f45d7f099120860c3c0624e07fd21a14 (patch)
tree16d99362deb943f8f693a5c7313fee14141e0b16
parentab3d38ebaa25459ea5fdc2e34102b128ea6d08e0 (diff)
Fix: Cancel requests before closing socket.
-rw-r--r--src/main/java/com/orbekk/protobuf/RpcChannel.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/java/com/orbekk/protobuf/RpcChannel.java b/src/main/java/com/orbekk/protobuf/RpcChannel.java
index ffc0d76..1937ab3 100644
--- a/src/main/java/com/orbekk/protobuf/RpcChannel.java
+++ b/src/main/java/com/orbekk/protobuf/RpcChannel.java
@@ -226,8 +226,8 @@ public class RpcChannel implements com.google.protobuf.RpcChannel {
private void tryCloseSocket(Socket socket) {
try {
- socket.close();
cancelAllRequests("channel closed");
+ socket.close();
} catch (IOException e1) {
logger.log(Level.WARNING,
"Unable to close socket " + socket,