les: shut down serving queue

This commit is contained in:
Zsolt Felfoldi 2019-01-29 01:59:49 +01:00
parent bd460f3deb
commit 591f861d3d

View file

@ -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