From 5c1d023f41472660952ee559e2484cd6bbe688d3 Mon Sep 17 00:00:00 2001 From: Sebastien Douheret Date: Wed, 29 Nov 2017 15:17:03 +0100 Subject: Fixed bug introduces by previous commit / refit Signed-off-by: Sebastien Douheret --- lib/xdsserver/sessions.go | 23 ++++++++++------------- lib/xdsserver/webserver.go | 1 + 2 files changed, 11 insertions(+), 13 deletions(-) (limited to 'lib/xdsserver') diff --git a/lib/xdsserver/sessions.go b/lib/xdsserver/sessions.go index 6da9fd8..c1e7b3b 100644 --- a/lib/xdsserver/sessions.go +++ b/lib/xdsserver/sessions.go @@ -5,7 +5,6 @@ import ( "strconv" "time" - "github.com/Sirupsen/logrus" "github.com/gin-gonic/gin" "github.com/googollee/go-socket.io" uuid "github.com/satori/go.uuid" @@ -37,12 +36,10 @@ type ClientSession struct { // Sessions holds client sessions type Sessions struct { *Context - cookieMaxAge int64 - sessMap map[string]ClientSession - mutex sync.Mutex - log *logrus.Logger - LogLevelSilly bool - stop chan struct{} // signals intentional stop + cookieMaxAge int64 + sessMap map[string]ClientSession + mutex sync.Mutex + stop chan struct{} // signals intentional stop } // NewClientSessions . @@ -174,7 +171,7 @@ func (s *Sessions) newSession(prefix string) *ClientSession { s.sessMap[se.ID] = se - s.log.Debugf("NEW session (%d): %s", len(s.sessMap), id) + s.Log.Debugf("NEW session (%d): %s", len(s.sessMap), id) return &se } @@ -200,22 +197,22 @@ func (s *Sessions) monitorSessMap() { for { select { case <-s.stop: - s.log.Debugln("Stop monitorSessMap") + s.Log.Debugln("Stop monitorSessMap") return case <-time.After(sessionMonitorTime * time.Second): if s.LogLevelSilly { - s.log.Debugf("Sessions Map size: %d", len(s.sessMap)) - s.log.Debugf("Sessions Map : %v", s.sessMap) + s.Log.Debugf("Sessions Map size: %d", len(s.sessMap)) + s.Log.Debugf("Sessions Map : %v", s.sessMap) } if len(s.sessMap) > maxSessions { - s.log.Errorln("TOO MUCH sessions, cleanup old ones !") + s.Log.Errorln("TOO MUCH sessions, cleanup old ones !") } s.mutex.Lock() for _, ss := range s.sessMap { if ss.expireAt.Sub(time.Now()) < 0 { - s.log.Debugf("Delete expired session id: %s", ss.ID) + s.Log.Debugf("Delete expired session id: %s", ss.ID) delete(s.sessMap, ss.ID) } } diff --git a/lib/xdsserver/webserver.go b/lib/xdsserver/webserver.go index 0e1676a..ddedd6d 100644 --- a/lib/xdsserver/webserver.go +++ b/lib/xdsserver/webserver.go @@ -47,6 +47,7 @@ func NewWebServer(ctx *Context) *WebServer { r := gin.New() svr := &WebServer{ + Context: ctx, router: r, api: nil, sIOServer: nil, -- cgit 1.2.3-korg