mirror of
https://github.com/lukaszraczylo/traefikoidc.git
synced 2026-10-17 04:37:48 +00:00
fixup! fixup! Cleanup.
This commit is contained in:
+9
-9
@@ -173,7 +173,7 @@ func (bt *BackgroundTask) run() {
|
|||||||
|
|
||||||
if bt.logger != nil {
|
if bt.logger != nil {
|
||||||
if !isTestMode() {
|
if !isTestMode() {
|
||||||
bt.logger.Info("Starting background task: %s", bt.name)
|
bt.logger.Debug("Starting background task: %s", bt.name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -182,7 +182,7 @@ func (bt *BackgroundTask) run() {
|
|||||||
case <-bt.stopChan:
|
case <-bt.stopChan:
|
||||||
if bt.logger != nil {
|
if bt.logger != nil {
|
||||||
if !isTestMode() {
|
if !isTestMode() {
|
||||||
bt.logger.Info("Stopping background task: %s (before initial execution)", bt.name)
|
bt.logger.Debug("Stopping background task: %s (before initial execution)", bt.name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
@@ -201,7 +201,7 @@ func (bt *BackgroundTask) run() {
|
|||||||
case <-bt.stopChan:
|
case <-bt.stopChan:
|
||||||
if bt.logger != nil {
|
if bt.logger != nil {
|
||||||
if !isTestMode() {
|
if !isTestMode() {
|
||||||
bt.logger.Info("Stopping background task: %s (during periodic execution)", bt.name)
|
bt.logger.Debug("Stopping background task: %s (during periodic execution)", bt.name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
@@ -211,7 +211,7 @@ func (bt *BackgroundTask) run() {
|
|||||||
case <-bt.stopChan:
|
case <-bt.stopChan:
|
||||||
if bt.logger != nil {
|
if bt.logger != nil {
|
||||||
if !isTestMode() {
|
if !isTestMode() {
|
||||||
bt.logger.Info("Stopping background task: %s (direct stop signal)", bt.name)
|
bt.logger.Debug("Stopping background task: %s (direct stop signal)", bt.name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
@@ -315,7 +315,7 @@ func (cb *TaskCircuitBreaker) CanCreateTask(taskName string) error {
|
|||||||
if time.Now().Unix()-lastFailure > int64(cb.timeout.Seconds()) {
|
if time.Now().Unix()-lastFailure > int64(cb.timeout.Seconds()) {
|
||||||
atomic.StoreInt32(&cb.state, int32(CircuitBreakerHalfOpen))
|
atomic.StoreInt32(&cb.state, int32(CircuitBreakerHalfOpen))
|
||||||
if cb.logger != nil {
|
if cb.logger != nil {
|
||||||
cb.logger.Info("Circuit breaker transitioning to half-open for task: %s", taskName)
|
cb.logger.Debug("Circuit breaker transitioning to half-open for task: %s", taskName)
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
@@ -467,7 +467,7 @@ func (tr *TaskRegistry) RegisterTask(name string, task *BackgroundTask) error {
|
|||||||
tr.cb.OnTaskSuccess(name)
|
tr.cb.OnTaskSuccess(name)
|
||||||
|
|
||||||
if tr.logger != nil {
|
if tr.logger != nil {
|
||||||
tr.logger.Info("Registered background task: %s", name)
|
tr.logger.Debug("Registered background task: %s", name)
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
@@ -483,7 +483,7 @@ func (tr *TaskRegistry) UnregisterTask(name string) {
|
|||||||
delete(tr.tasks, name)
|
delete(tr.tasks, name)
|
||||||
|
|
||||||
if tr.logger != nil {
|
if tr.logger != nil {
|
||||||
tr.logger.Info("Unregistered background task: %s", name)
|
tr.logger.Debug("Unregistered background task: %s", name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -513,7 +513,7 @@ func (tr *TaskRegistry) StopAllTasks() {
|
|||||||
for name, task := range tasksCopy {
|
for name, task := range tasksCopy {
|
||||||
task.Stop()
|
task.Stop()
|
||||||
if tr.logger != nil {
|
if tr.logger != nil {
|
||||||
tr.logger.Info("Stopped background task during shutdown: %s", name)
|
tr.logger.Debug("Stopped background task during shutdown: %s", name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -641,7 +641,7 @@ func (mm *TaskMemoryMonitor) Start(interval time.Duration) error {
|
|||||||
mm.started = true
|
mm.started = true
|
||||||
|
|
||||||
if mm.logger != nil && !isTestMode() {
|
if mm.logger != nil && !isTestMode() {
|
||||||
mm.logger.Info("Started global task memory monitoring with %v interval", interval)
|
mm.logger.Debug("Started global task memory monitoring with %v interval", interval)
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
+1
-1
@@ -963,7 +963,7 @@ func (gd *GracefulDegradation) Close() {
|
|||||||
// Don't set to nil to avoid race conditions
|
// Don't set to nil to avoid race conditions
|
||||||
}
|
}
|
||||||
|
|
||||||
gd.logger.Info("GracefulDegradation shut down successfully")
|
gd.logger.Debug("GracefulDegradation shut down successfully")
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -2521,7 +2521,7 @@ func (t *TraefikOidc) Close() error {
|
|||||||
runtime.GC()
|
runtime.GC()
|
||||||
t.safeLogDebug("Forced garbage collection after shutdown")
|
t.safeLogDebug("Forced garbage collection after shutdown")
|
||||||
|
|
||||||
t.safeLogInfo("TraefikOidc plugin instance closed successfully.")
|
t.safeLogDebug("TraefikOidc plugin instance closed successfully.")
|
||||||
})
|
})
|
||||||
return closeErr
|
return closeErr
|
||||||
}
|
}
|
||||||
|
|||||||
+3
-3
@@ -272,7 +272,7 @@ func NewSessionManager(encryptionKey string, forceHTTPS bool, cookieDomain strin
|
|||||||
|
|
||||||
// Start memory monitoring every 30 seconds (will skip if already started)
|
// Start memory monitoring every 30 seconds (will skip if already started)
|
||||||
if err := sm.memoryMonitor.Start(30 * time.Second); err != nil {
|
if err := sm.memoryMonitor.Start(30 * time.Second); err != nil {
|
||||||
logger.Infof("Failed to start memory monitoring: %v", err)
|
logger.Debugf("Failed to start memory monitoring: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
sm.sessionPool.New = func() interface{} {
|
sm.sessionPool.New = func() interface{} {
|
||||||
@@ -302,7 +302,7 @@ func (sm *SessionManager) Shutdown() error {
|
|||||||
var shutdownErr error
|
var shutdownErr error
|
||||||
sm.shutdownOnce.Do(func() {
|
sm.shutdownOnce.Do(func() {
|
||||||
if sm.logger != nil {
|
if sm.logger != nil {
|
||||||
sm.logger.Info("SessionManager shutdown initiated")
|
sm.logger.Debug("SessionManager shutdown initiated")
|
||||||
}
|
}
|
||||||
|
|
||||||
// Cancel context to stop all background operations
|
// Cancel context to stop all background operations
|
||||||
@@ -324,7 +324,7 @@ func (sm *SessionManager) Shutdown() error {
|
|||||||
runtime.GC()
|
runtime.GC()
|
||||||
|
|
||||||
if sm.logger != nil {
|
if sm.logger != nil {
|
||||||
sm.logger.Info("SessionManager shutdown completed")
|
sm.logger.Debug("SessionManager shutdown completed")
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
return shutdownErr
|
return shutdownErr
|
||||||
|
|||||||
+1
-1
@@ -220,7 +220,7 @@ func (trm *TokenResilienceManager) Reset() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if trm.logger != nil {
|
if trm.logger != nil {
|
||||||
trm.logger.Infof("Token resilience manager has been reset")
|
trm.logger.Debugf("Token resilience manager has been reset")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+2
-2
@@ -431,13 +431,13 @@ func (c *UniversalCache) Close() error {
|
|||||||
// Cleanup routine finished normally
|
// Cleanup routine finished normally
|
||||||
case <-time.After(2 * time.Second):
|
case <-time.After(2 * time.Second):
|
||||||
// Timeout waiting for cleanup routine
|
// Timeout waiting for cleanup routine
|
||||||
c.logger.Info("UniversalCache[%s]: Timeout waiting for cleanup routine", c.config.Type)
|
c.logger.Debug("UniversalCache[%s]: Timeout waiting for cleanup routine", c.config.Type)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Clear all items
|
// Clear all items
|
||||||
c.Clear()
|
c.Clear()
|
||||||
|
|
||||||
c.logger.Infof("UniversalCache[%s]: Closed", c.config.Type)
|
c.logger.Debugf("UniversalCache[%s]: Closed", c.config.Type)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user