Mirror/Erupe
1
0
Fork 0
mirror of https://github.com/Mezeporta/Erupe.git synced 2025-12-13 15:34:38 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix invalidateSessions

Browse Source
This commit is contained in:
wish
2025-02-27 20:06:05 +11:00
parent 5028355cfc
commit 3c0d29ed41
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
server/channelserver/sys_channel_server.go
View File

@@ -280,13 +280,18 @@ func (s *Server) manageSessions() {
} }
func (s *Server) invalidateSessions() { func (s *Server) invalidateSessions() {
for _, session := range s.sessions { for {
if time.Now().Add(-30 * time.Second).After(session.lastPacket) { if s.isShuttingDown {
s.logger.Info("Session timeout", zap.String("Name", session.Name)) break
logoutPlayer(session)
} }
for _, sess := range s.sessions {
if time.Now().Sub(sess.lastPacket) > time.Second*time.Duration(30) {
s.logger.Info("session timeout", zap.String("Name", sess.Name))
logoutPlayer(sess)
}
}
time.Sleep(time.Second * 10)
} }
time.Sleep(30 * time.Second)
} }
// BroadcastMHF queues a MHFPacket to be sent to all sessions. // BroadcastMHF queues a MHFPacket to be sent to all sessions.