BlockingClient.writeBytes() error handling improvement.

bisq-network · Apr 2, 2019 · d3a5616 · d3a5616
1 parent 465a9ea
commit d3a5616
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/core/src/main/java/org/bitcoinj/net/BlockingClient.java b/core/src/main/java/org/bitcoinj/net/BlockingClient.java
@@ -149,10 +149,11 @@ public synchronized void writeBytes(byte[] message) throws IOException {
                 OutputStream stream = socket.getOutputStream();
                 stream.write(message);
                 stream.flush();
+            } else {
+                log.warn("Attempted to write to a closed socket.");
             }
         } catch (IOException e) {
-            if(!(e instanceof SocketException && e.toString().equals("Socket is closed")))
-                log.error("Error writing message to connection, closing connection", e);
+            log.error("Error writing message to connection, closing connection", e);
             closeConnection();
             throw e;
         }