diff --git a/model.go b/model.go index dacaa0cf5..e75670958 100644 --- a/model.go +++ b/model.go @@ -196,10 +196,11 @@ func (m *Model) Close(node string, err error) { defer m.Unlock() conn, ok := m.rawConn[node] - if !ok { - return + if ok { + conn.Close() + } else { + warnln("Close on unknown connection for node", node) } - conn.Close() if err != nil { warnf("Disconnected from node %s: %v", node, err)