59 lines
1.5 KiB
Go
59 lines
1.5 KiB
Go
package Log
|
|
|
|
import (
|
|
"github.com/SommerEngineering/Ocean/Log/Device"
|
|
"github.com/SommerEngineering/Ocean/Log/Meta"
|
|
)
|
|
|
|
// Queue a log event before delivery to the devices.
|
|
func deviceDelay(newEntry Meta.Entry) {
|
|
defer checkDeviceDelaySize()
|
|
|
|
// Insert the new entry at the correct position (time).
|
|
// To ensure that the causality is guaranteed.
|
|
for logEvent := deviceDelayBuffer.Front(); logEvent != nil; logEvent = logEvent.Next() {
|
|
currentEvent := logEvent.Value.(Meta.Entry)
|
|
if newEntry.Time.Before(currentEvent.Time) {
|
|
mutexDeviceDelays.Lock()
|
|
deviceDelayBuffer.InsertBefore(newEntry, logEvent)
|
|
mutexDeviceDelays.Unlock()
|
|
return
|
|
}
|
|
}
|
|
|
|
// Default: Insert at the back!
|
|
mutexDeviceDelays.Lock()
|
|
deviceDelayBuffer.PushBack(newEntry)
|
|
mutexDeviceDelays.Unlock()
|
|
}
|
|
|
|
// Check if the size of the buffer is huge enough to deliver entries.
|
|
func checkDeviceDelaySize() {
|
|
|
|
// Get exklusive access:
|
|
mutexDeviceDelays.Lock()
|
|
|
|
// Is the size huge enough?
|
|
if deviceDelayBuffer.Len() >= logDeviceDelayNumberEvents {
|
|
|
|
// Read all entries:
|
|
dataArray := logEntryListToArray(deviceDelayBuffer)
|
|
|
|
// Re-init the buffer:
|
|
deviceDelayBuffer.Init()
|
|
|
|
// Loop over all devices:
|
|
mutexDevices.RLock()
|
|
for entry := devices.Front(); entry != nil; entry = entry.Next() {
|
|
dev := entry.Value.(Device.Device)
|
|
|
|
// Deliver the data with a new thread:
|
|
go dev.Log(dataArray)
|
|
}
|
|
mutexDevices.RUnlock()
|
|
}
|
|
|
|
// Release the lock:
|
|
mutexDeviceDelays.Unlock()
|
|
}
|