kerberos-io/agent
1
0
Fork 0
mirror of https://github.com/kerberos-io/agent.git synced 2026-10-19 17:38:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

change cursors

Browse Source
This commit is contained in:
Cedric Verstraeten
2022-10-20 15:16:15 +02:00
parent 630b34ca27
commit f891ac375b
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
machinery/src/components/Kerberos.go
+4 -4
View File
@@ -152,21 +152,21 @@ func RunAgent(configuration *models.Configuration, communication *models.Communi
}
// Handle processing of motion
motionCursor := queue.Oldest()
motionCursor := queue.Latest()
communication.HandleMotion = make(chan models.MotionDataPartial, 1)
go computervision.ProcessMotion(motionCursor, configuration, communication, mqttClient, decoder, &decoderMutex)
// Handle livestream SD (low resolution over MQTT)
livestreamCursor := queue.Oldest()
livestreamCursor := queue.Latest()
go cloud.HandleLiveStreamSD(livestreamCursor, configuration, communication, mqttClient, decoder, &decoderMutex)
// Handle livestream HD (high resolution over WEBRTC)
communication.HandleLiveHDHandshake = make(chan models.SDPPayload, 1)
if subStreamEnabled {
livestreamHDCursor := subQueue.Oldest()
livestreamHDCursor := subQueue.Latest()
go cloud.HandleLiveStreamHD(livestreamHDCursor, configuration, communication, mqttClient, subStreams, subDecoder, &decoderMutex)
} else {
livestreamHDCursor := queue.Oldest()
livestreamHDCursor := queue.Latest()
go cloud.HandleLiveStreamHD(livestreamHDCursor, configuration, communication, mqttClient, streams, decoder, &decoderMutex)
}