Skip to content

Commit ede5014

Browse files
committed
add session reset
1 parent 94d7217 commit ede5014

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

registry.go

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,21 @@ func SendToTarget(m Messagable, sessionID SessionID) error {
5050
return session.queueForSend(msg)
5151
}
5252

53+
//ResetSession resets session's sequence numbers
54+
func ResetSession(sessionID SessionID) error {
55+
session, ok := lookupSession(sessionID)
56+
if !ok {
57+
return errUnknownSession
58+
}
59+
session.log.OnEvent("Session reset")
60+
session.State.ShutdownNow(session)
61+
if err := session.dropAndReset(); err != nil {
62+
session.logError(err)
63+
}
64+
65+
return nil
66+
}
67+
5368
//UnregisterSession removes a session from the set of known sessions
5469
func UnregisterSession(sessionID SessionID) error {
5570
sessionsLock.Lock()

0 commit comments

Comments
 (0)