packetPool: flush old packets whenever new payload starts (#21)

Author: tmm1

packet_pool.go

@@ -53,15 +53,12 @@ func (b *packetPool) add(p *Packet) (ps []*Packet) {
 		return
 	}
 
-	// Add packet
-	if len(mps) > 0 || (len(mps) == 0 && p.Header.PayloadUnitStartIndicator) {
-		mps = append(mps, p)
-	}
-
-	// Check payload unit start indicator
-	if p.Header.PayloadUnitStartIndicator && len(mps) > 1 {
-		ps = mps[:len(mps)-1]
+	// Flush buffer if new payload starts here
+	if p.Header.PayloadUnitStartIndicator {
+		ps = mps
 		mps = []*Packet{p}
+	} else {
+		mps = append(mps, p)
 	}
 
 	// Assign

packet_pool_test.go

@@ -25,7 +25,7 @@ func TestPacketPool(t *testing.T) {
 	ps := b.add(&Packet{Header: &PacketHeader{ContinuityCounter: 0, HasPayload: true, PID: 1}})
 	assert.Len(t, ps, 0)
 	ps = b.add(&Packet{Header: &PacketHeader{ContinuityCounter: 1, HasPayload: true, PayloadUnitStartIndicator: true, PID: 1}})
-	assert.Len(t, ps, 0)
+	assert.Len(t, ps, 1)
 	ps = b.add(&Packet{Header: &PacketHeader{ContinuityCounter: 1, HasPayload: true, PayloadUnitStartIndicator: true, PID: 2}})
 	assert.Len(t, ps, 0)
 	ps = b.add(&Packet{Header: &PacketHeader{ContinuityCounter: 2, HasPayload: true, PID: 1}})
@@ -35,7 +35,7 @@ func TestPacketPool(t *testing.T) {
 	ps = b.add(&Packet{Header: &PacketHeader{ContinuityCounter: 5, HasPayload: true, PID: 1}})
 	assert.Len(t, ps, 0)
 	ps = b.add(&Packet{Header: &PacketHeader{ContinuityCounter: 6, HasPayload: true, PayloadUnitStartIndicator: true, PID: 1}})
-	assert.Len(t, ps, 0)
+	assert.Len(t, ps, 1)
 	ps = b.add(&Packet{Header: &PacketHeader{ContinuityCounter: 7, HasPayload: true, PID: 1}})
 	assert.Len(t, ps, 0)
 	ps = b.dump()