fix duration

livekit · Sep 20, 2023 · 925d71d · 925d71d
1 parent 149a08c
commit 925d71d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/pipeline/sink/segments.go b/pkg/pipeline/sink/segments.go
@@ -187,8 +187,9 @@ func (s *SegmentSink) endSegment(filename string, endTime uint64) error {
 	}
 	delete(s.openSegmentsStartTime, filename)
 
+	duration := float64(time.Duration(endTime-t) / time.Second)
 	segmentStartTime := s.startTime.Add(time.Duration(t - s.startRunningTime))
-	if err := s.playlist.Append(segmentStartTime, float64(endTime-t), filename); err != nil {
+	if err := s.playlist.Append(segmentStartTime, duration, filename); err != nil {
 		return err
 	}