Update tcp.go

nsqio · Oct 12, 2017 · 5c31b2f · 5c31b2f
1 parent 1543cfe
commit 5c31b2f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/nsqlookupd/tcp.go b/nsqlookupd/tcp.go
@@ -21,6 +21,7 @@ func (p *tcpServer) Handle(clientConn net.Conn) {
 	_, err := io.ReadFull(clientConn, buf)
 	if err != nil {
 		p.ctx.nsqlookupd.logf(LOG_ERROR, "failed to read protocol version - %s", err)
+		clientConn.Close()
 		return
 	}
 	protocolMagic := string(buf)