Go/Ocean
Go/Ocean
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add documentation

Browse Source
This commit is contained in:
Thorsten Sommer 2015-06-18 17:44:22 +02:00
parent 81c4d15d9f
commit 9be6bfc5fa
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
ICCC/CacheTimerLogic.go
View File

@ -10,18 +10,26 @@ import (
"time" "time"
) )
// Internal function for the timer logic thread.
func cacheTimerLogic(waiting bool) { func cacheTimerLogic(waiting bool) {
// Case: This server goes down now.
if Shutdown.IsDown() { if Shutdown.IsDown() {
return return
} }
// Define the query and get the iterator:
lastCount := cacheListenerDatabase.Len() lastCount := cacheListenerDatabase.Len()
selection := bson.D{{`IsActive`, true}} selection := bson.D{{`IsActive`, true}}
entriesIterator := collectionListener.Find(selection).Iter() entriesIterator := collectionListener.Find(selection).Iter()
entry := Scheme.Listener{}
entry := Scheme.Listener{}
cacheListenerDatabaseLock.Lock() cacheListenerDatabaseLock.Lock()
// Re-init the cache:
cacheListenerDatabase.Init() cacheListenerDatabase.Init()
// Loop over all entries
for entriesIterator.Next(&entry) { for entriesIterator.Next(&entry) {
cacheListenerDatabase.PushBack(entry) cacheListenerDatabase.PushBack(entry)
} }
@ -29,6 +37,7 @@ func cacheTimerLogic(waiting bool) {
cacheListenerDatabaseLock.Unlock() cacheListenerDatabaseLock.Unlock()
Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameEXECUTE, `The listener cache was refreshed with the values from the database.`, fmt.Sprintf(`last count=%d`, lastCount), fmt.Sprintf(`new count=%d`, cacheListenerDatabase.Len())) Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameEXECUTE, `The listener cache was refreshed with the values from the database.`, fmt.Sprintf(`last count=%d`, lastCount), fmt.Sprintf(`new count=%d`, cacheListenerDatabase.Len()))
// In case, that this function runs at a thread, we want to wait:
if waiting { if waiting {
nextDuration := time.Duration(5) * time.Minute nextDuration := time.Duration(5) * time.Minute
if cacheListenerDatabase.Len() == 0 { if cacheListenerDatabase.Len() == 0 {