diff --git a/les/handler.go b/les/handler.go index 9854d6b494..0352f5b039 100644 --- a/les/handler.go +++ b/les/handler.go @@ -211,6 +211,10 @@ func (pm *ProtocolManager) Stop() { close(pm.quitSync) // quits syncer, fetcher + if pm.servingQueue != nil { + pm.servingQueue.stop() + } + // Disconnect existing sessions. // This also closes the gate for any new registrations on the peer set. // sessions which are already established but not added to pm.peers yet