diff --git a/router/connection.go b/router/connection.go index 93e860f1..6a9564c2 100644 --- a/router/connection.go +++ b/router/connection.go @@ -269,10 +269,6 @@ func (conn *LocalConnection) handleShutdown() { // (or write elements which are only read by the same // process). Taking locks is only done for elements which are read // by other processes. - if conn.shutdown { - return - } - conn.shutdown = true if conn.TCPConn != nil { checkWarn(conn.TCPConn.Close()) diff --git a/router/types.go b/router/types.go index 5c236c24..616e364b 100644 --- a/router/types.go +++ b/router/types.go @@ -60,7 +60,6 @@ type LocalConnection struct { Decryptor Decryptor Router *Router UID uint64 - shutdown bool queryChan chan<- *ConnectionInteraction }