From cd2bbb861bcc7d25cc500aebfac5754fe9ba2926 Mon Sep 17 00:00:00 2001 From: kira1928 Date: Sat, 11 Feb 2023 20:06:54 +0900 Subject: [PATCH] fix flv-parser write bug (#387) --- src/pkg/parser/native/flv/flv.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/pkg/parser/native/flv/flv.go b/src/pkg/parser/native/flv/flv.go index c0045e0..92945fe 100644 --- a/src/pkg/parser/native/flv/flv.go +++ b/src/pkg/parser/native/flv/flv.go @@ -157,7 +157,7 @@ func (p *Parser) doWrite(ctx context.Context, b []byte) error { leftInputSize := len(b) var logger *interfaces.Logger = nil for retryLeft := ioRetryCount; retryLeft > 0 && leftInputSize > 0; retryLeft-- { - writtenCount, err := p.o.Write(b) + writtenCount, err := p.o.Write(b[len(b)-leftInputSize:]) leftInputSize -= writtenCount if err != nil { return err