muxer: prevent creating empty parts before switching segments

muxer.go

@@ -72,42 +72,6 @@
 	return 90000
 }
 
-func partDurationIsCompatible(partDuration time.Duration, sampleDuration time.Duration) bool {
-	if sampleDuration > partDuration {
-		return false
-	}
-
-	f := (partDuration / sampleDuration)
-	if (partDuration % sampleDuration) != 0 {
-		f++
-	}
-	f *= sampleDuration
-
-	return partDuration > ((f * 85) / 100)
-}
-
-func partDurationIsCompatibleWithAll(partDuration time.Duration, sampleDurations map[time.Duration]struct{}) bool {
-	for sd := range sampleDurations {
-		if !partDurationIsCompatible(partDuration, sd) {
-			return false
-		}
-	}
-	return true
-}
-
-func findCompatiblePartDuration(
-	minPartDuration time.Duration,
-	sampleDurations map[time.Duration]struct{},
-) time.Duration {
-	i := minPartDuration
-	for ; i < 5*time.Second; i += 5 * time.Millisecond {
-		if partDurationIsCompatibleWithAll(i, sampleDurations) {
-			break
-		}
-	}
-	return i
-}
-
 type fmp4AugmentedSample struct {
 	fmp4.PartSample
 	dts time.Duration
@@ -168,7 +132,6 @@
 	nextSegmentID      uint64
 	nextPartID         uint64 // low-latency only
 	segmentDeleteCount int
-	nextPartHasSamples bool
 }
 
 // Start initializes the muxer.
@@ -406,19 +369,12 @@
 }
 
 func (m *Muxer) rotatePartsInner(nextDTS time.Duration, createNew bool) error {
-	if !m.nextPartHasSamples {
-		for _, stream := range m.streams {
-			stream.nextPart = nil
-		}
-	} else {
-		m.nextPartID++
-		m.nextPartHasSamples = false
+	m.nextPartID++
 
-		for _, stream := range m.streams {
-			err := stream.rotateParts(nextDTS, createNew)
-			if err != nil {
-				return err
-			}
+	for _, stream := range m.streams {
+		err := stream.rotateParts(nextDTS, createNew)
+		if err != nil {
+			return err
 		}
 	}
 
@@ -448,9 +404,11 @@
 	nextNTP time.Time,
 	force bool,
 ) error {
-	err := m.rotatePartsInner(nextDTS, false)
-	if err != nil {
-		return err
+	if m.Variant != MuxerVariantMPEGTS {
+		err := m.rotatePartsInner(nextDTS, false)
+		if err != nil {
+			return err
+		}
 	}
 
 	m.nextSegmentID++

muxer_part.go

@@ -9,13 +9,12 @@ import (
 )
 
 type muxerPart struct {
-	stream                *muxerStream
-	segment               *muxerSegmentFMP4
-	startDTS              time.Duration
-	prefix                string
-	id                    uint64
-	storage               storage.Part
-	setNextPartHasSamples func()
+	stream   *muxerStream
+	segment  *muxerSegmentFMP4
+	startDTS time.Duration
+	prefix   string
+	id       uint64
+	storage  storage.Part
 
 	path          string
 	isIndependent bool
@@ -73,6 +72,4 @@ func (p *muxerPart) writeSample(track *muxerTrack, sample *fmp4AugmentedSample)
 	}
 
 	track.fmp4Samples = append(track.fmp4Samples, &sample.PartSample)
-
-	p.setNextPartHasSamples()
 }

muxer_segment_fmp4.go

@@ -9,18 +9,16 @@ import (
 )
 
 type muxerSegmentFMP4 struct {
-	variant               MuxerVariant
-	segmentMaxSize        uint64
-	prefix                string
-	nextPartID            uint64
-	storageFactory        storage.Factory
-	rotateParts           func(time.Duration) error
-	setNextPartHasSamples func()
-	stream                *muxerStream
-	id                    uint64
-	startNTP              time.Time
-	startDTS              time.Duration
-	fromForcedRotation    bool
+	variant            MuxerVariant
+	segmentMaxSize     uint64
+	prefix             string
+	nextPartID         uint64
+	storageFactory     storage.Factory
+	stream             *muxerStream
+	id                 uint64
+	startNTP           time.Time
+	startDTS           time.Duration
+	fromForcedRotation bool
 
 	path    string
 	storage storage.File
@@ -39,13 +37,12 @@ func (s *muxerSegmentFMP4) initialize() error {
 	}
 
 	s.stream.nextPart = &muxerPart{
-		stream:                s.stream,
-		segment:               s,
-		startDTS:              s.startDTS,
-		prefix:                s.prefix,
-		id:                    s.nextPartID,
-		storage:               s.storage.NewPart(),
-		setNextPartHasSamples: s.setNextPartHasSamples,
+		stream:   s.stream,
+		segment:  s,
+		startDTS: s.startDTS,
+		prefix:   s.prefix,
+		id:       s.nextPartID,
+		storage:  s.storage.NewPart(),
 	}
 	s.stream.nextPart.initialize()
 
@@ -87,8 +84,6 @@ func (s *muxerSegmentFMP4) finalize(nextDTS time.Duration) error {
 func (s *muxerSegmentFMP4) writeSample(
 	track *muxerTrack,
 	sample *fmp4AugmentedSample,
-	nextDTS time.Duration,
-	adjustedPartDuration time.Duration,
 ) error {
 	size := uint64(len(sample.Payload))
 	if (s.size + size) > s.segmentMaxSize {
@@ -98,14 +93,5 @@ func (s *muxerSegmentFMP4) writeSample(
 
 	s.stream.nextPart.writeSample(track, sample)
 
-	// switch part
-	if (s.variant == MuxerVariantLowLatency) && track.isLeading &&
-		s.stream.nextPart.computeDuration(nextDTS) >= adjustedPartDuration {
-		err := s.rotateParts(nextDTS)
-		if err != nil {
-			return err
-		}
-	}
-
 	return nil
 }