From 7ac2f71de1fa951e5a4e834062f1e9fcccf37874 Mon Sep 17 00:00:00 2001 From: Cedric Verstraeten Date: Mon, 30 Jan 2023 16:16:07 +0100 Subject: [PATCH] Update main.go --- machinery/src/capture/main.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/machinery/src/capture/main.go b/machinery/src/capture/main.go index 69d1874..9cc2291 100644 --- a/machinery/src/capture/main.go +++ b/machinery/src/capture/main.go @@ -353,6 +353,16 @@ func HandleRecordStream(queue *pubsub.Queue, configuration *models.Configuration if err := myMuxer.WritePacket(pkt); err != nil { log.Log.Error(err.Error()) } + + // We will sync to file every keyframe. + if pkt.IsKeyFrame { + err := file.Sync() + if err != nil { + log.Log.Error(err.Error()) + } else { + log.Log.Info("HandleRecordStream: Synced file: " + name) + } + } } pkt = nextPkt