diff --git a/pkg/network/tcp_peer.go b/pkg/network/tcp_peer.go
index e9e81ffa9..7703e7bd2 100644
--- a/pkg/network/tcp_peer.go
+++ b/pkg/network/tcp_peer.go
@@ -59,6 +59,7 @@ func (p *TCPPeer) Done() chan error {
 
 // Disconnect will fill the peer's done channel with the given error.
 func (p *TCPPeer) Disconnect(err error) {
+	p.conn.Close()
 	p.done <- err
 }