Clean up shutdownSessions
This commit is contained in:
parent
3260fa88ab
commit
67e59cb35c
|
@ -88,10 +88,10 @@ func (m *manager) shutdownSessions(err error) {
|
||||||
}
|
}
|
||||||
closeSessionErr := &errClosedSession{
|
closeSessionErr := &errClosedSession{
|
||||||
message: err.Error(),
|
message: err.Error(),
|
||||||
}
|
|
||||||
// Usually connection with remote has been closed, so set this to true to skip unregistering from remote
|
// Usually connection with remote has been closed, so set this to true to skip unregistering from remote
|
||||||
// context.Canceled is an exception because that means session is being closed by our side
|
// context.Canceled is an exception because that means session is being closed by our side
|
||||||
closeSessionErr.byRemote = !errors.Is(err, context.Canceled)
|
byRemote: !errors.Is(err, context.Canceled),
|
||||||
|
}
|
||||||
for _, s := range m.sessions {
|
for _, s := range m.sessions {
|
||||||
s.close(closeSessionErr)
|
s.close(closeSessionErr)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue