From 4eeace28f993d9cc88c8ee1ec2ad5bf9c7388e32 Mon Sep 17 00:00:00 2001 From: DarkGopher Date: Mon, 23 Jun 2025 14:10:31 +0200 Subject: [PATCH] MilisPerSecDuration --- session.go | 4 ++-- storage/files/files.go | 2 +- storage/memory/memory.go | 2 +- tests/t_test.go | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/session.go b/session.go index b8fde93..8e41fbf 100644 --- a/session.go +++ b/session.go @@ -33,8 +33,8 @@ func ProviderNames() []string { } // MilisPerSec return time resolution (milliseconds / 1sec) changed for short time in testing -func MilisPerSec() int64 { - return milis +func MilisPerSecDuration() time.Duration { + return time.Duration(milis) } // Provider interace implement lifecycle for one session diff --git a/storage/files/files.go b/storage/files/files.go index 8c8b9b4..1e535ff 100644 --- a/storage/files/files.go +++ b/storage/files/files.go @@ -155,7 +155,7 @@ func (pder *ProviderFiles) GC(maxlifetime int64) { if at, err = pder.getAtime(sid); err != nil { continue } - if at.UnixMilli()+(maxlifetime*session.MilisPerSec()) < time.Now().UnixMilli() { + if at.UnixMilli()+(maxlifetime*int64(session.MilisPerSecDuration())) < time.Now().UnixMilli() { log.Printf("GC remove session: %s atime: %v now: %v", sid, at, time.Now()) pder.li.Remove(ssel) delete(pder.sessions, sid) diff --git a/storage/memory/memory.go b/storage/memory/memory.go index cc30e12..43a45f3 100644 --- a/storage/memory/memory.go +++ b/storage/memory/memory.go @@ -100,7 +100,7 @@ func (pder *ProviderMemory) GC(maxlifetime int64) { if ssel == nil { break } - if ssel.Value.(*SessionMemory).atime.UnixMilli()+(maxlifetime*session.MilisPerSec()) < time.Now().UnixMilli() { + if ssel.Value.(*SessionMemory).atime.UnixMilli()+(maxlifetime*int64(session.MilisPerSecDuration())) < time.Now().UnixMilli() { pder.li.Remove(ssel) delete(pder.sessions, ssel.Value.(*SessionMemory).sid) } else { diff --git a/tests/t_test.go b/tests/t_test.go index 7797739..9a3c0dc 100644 --- a/tests/t_test.go +++ b/tests/t_test.go @@ -181,7 +181,7 @@ func (ts *TestServer) sessionGC(w http.ResponseWriter, r *http.Request) { io.WriteString(w, err.Error()) return } - time.Sleep(200 * time.Millisecond) + time.Sleep(200 * time.Millisecond * time.Duration(session.MilisPerSecDuration())) if sm.Exists(ses.SessionID()) { io.WriteString(w, fmt.Sprintf("Session id: %s must not exists in storage after GC", ses.SessionID()))