use lower of segment duration and keyframe interval (#649)

livekit · Apr 10, 2024 · 1ed7616 · 1ed7616
1 parent 6b1c207
commit 1ed7616
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/config/output.go b/pkg/config/output.go
@@ -145,6 +145,11 @@ func (p *PipelineConfig) updateEncodedOutputs(req egress.EncodedOutput) error {
 	}
 
 	if segmentConf := p.Outputs[types.EgressTypeSegments]; segmentConf != nil {
+		if stream != nil && p.KeyFrameInterval > 0 {
+			// segment duration must match keyframe interval - use the lower of the two
+			conf := segmentConf[0].(*SegmentConfig)
+			conf.SegmentDuration = min(int(p.KeyFrameInterval), conf.SegmentDuration)
+		}
 		p.KeyFrameInterval = 0
 	} else if p.KeyFrameInterval == 0 && p.Outputs[types.EgressTypeStream] != nil {
 		// default 4s for streams