BlockingClient.writeBytes() error handling improvement.

oscarguindzberg · Apr 1, 2019 · 4baf363 · 4baf363
1 parent 630662f
commit 4baf363
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;
         }