diff --git a/core/src/main/java/com/google/bitcoin/core/PeerSocketHandler.java b/core/src/main/java/com/google/bitcoin/core/PeerSocketHandler.java index afb6ae9e..5eb6a146 100644 --- a/core/src/main/java/com/google/bitcoin/core/PeerSocketHandler.java +++ b/core/src/main/java/com/google/bitcoin/core/PeerSocketHandler.java @@ -189,9 +189,11 @@ public abstract class PeerSocketHandler extends AbstractTimeoutHandler implement */ @Override public void setWriteTarget(MessageWriteTarget writeTarget) { + checkArgument(writeTarget != null); lock.lock(); boolean closeNow = false; try { + checkArgument(this.writeTarget == null); closeNow = closePending; this.writeTarget = writeTarget; } finally {