diff --git a/cmd/influxd/restore/restore.go b/cmd/influxd/restore/restore.go index c4c5bc34da3..616419fd2f5 100644 --- a/cmd/influxd/restore/restore.go +++ b/cmd/influxd/restore/restore.go @@ -248,5 +248,12 @@ func (ln *nopListener) Accept() (net.Conn, error) { return nil, errors.New("listener closing") } -func (ln *nopListener) Close() error { close(ln.closing); return nil } +func (ln *nopListener) Close() error { + if ln.closing != nil { + close(ln.closing) + ln.closing = nil + } + return nil +} + func (ln *nopListener) Addr() net.Addr { return nil } diff --git a/meta/state.go b/meta/state.go index a4c6b60be49..2612302c30f 100644 --- a/meta/state.go +++ b/meta/state.go @@ -209,11 +209,6 @@ func (r *localRaft) close() error { r.transport = nil } - if r.raftLayer != nil { - r.raftLayer.Close() - r.raftLayer = nil - } - // Shutdown raft. if r.raft != nil { if err := r.raft.Shutdown().Error(); err != nil {