From 2d7133714601ffba634d6a6710e7ed43ae7b2c73 Mon Sep 17 00:00:00 2001 From: Gabe Kangas Date: Thu, 15 Oct 2020 16:17:33 -0700 Subject: [PATCH] Rename functions to be clearer that it is for offline cleanup --- core/streamState.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/core/streamState.go b/core/streamState.go index 6531091c9..2f0254529 100644 --- a/core/streamState.go +++ b/core/streamState.go @@ -24,7 +24,7 @@ func SetStreamAsConnected() { _stats.LastConnectTime = utils.NullTime{time.Now(), true} _stats.LastDisconnectTime = utils.NullTime{time.Now(), false} - StopCleanupTimer() + StopOfflineCleanupTimer() if _yp != nil { _yp.Start() } @@ -111,11 +111,11 @@ func SetStreamAsDisconnected() { _storage.Save(playlistFilePath, 0) } - StartCleanupTimer() + StartOfflineCleanupTimer() } -// StartCleanupTimer will fire a cleanup after n minutes being disconnected -func StartCleanupTimer() { +// StartOfflineCleanupTimer will fire a cleanup after n minutes being disconnected +func StartOfflineCleanupTimer() { _cleanupTimer = time.NewTimer(5 * time.Minute) go func() { for { @@ -130,8 +130,8 @@ func StartCleanupTimer() { }() } -// StopCleanupTimer will stop the previous cleanup timer -func StopCleanupTimer() { +// StopOfflineCleanupTimer will stop the previous cleanup timer +func StopOfflineCleanupTimer() { if _cleanupTimer != nil { _cleanupTimer.Stop() }