From d7ad1dc725f958dfd8b1fa3c534f12dca892de7b Mon Sep 17 00:00:00 2001 From: ydajiang Date: Fri, 8 Aug 2025 17:48:54 +0800 Subject: [PATCH] chore: update module avformat to v0.0.2 --- gb28181/talk_source.go | 2 +- go.mod | 8 ++++---- jt1078/jt_demuxer.go | 2 +- stream/mw_buffer.go | 2 +- 4 files changed, 7 insertions(+), 7 deletions(-) diff --git a/gb28181/talk_source.go b/gb28181/talk_source.go index c06651b..cd52e38 100644 --- a/gb28181/talk_source.go +++ b/gb28181/talk_source.go @@ -33,7 +33,7 @@ func (d *Demuxer) Input(data []byte) (int, error) { for i := 0; i < length; { n := bufio.MinInt(length-i, 320) _, _ = d.DataPipeline.Write(data[i:i+n], 0, utils.AVMediaTypeAudio) - pkt, _ := d.DataPipeline.Feat(0) + pkt, _ := d.DataPipeline.Fetch(0) d.OnAudioPacket(0, utils.AVCodecIdPCMALAW, pkt, d.ts) d.ts += int64(n) i += n diff --git a/go.mod b/go.mod index 47aa499..b3ba64f 100644 --- a/go.mod +++ b/go.mod @@ -2,10 +2,10 @@ module github.com/lkmio/lkm require ( github.com/lkmio/audio-transcoder v0.2.1 - github.com/lkmio/avformat v0.0.1 - github.com/lkmio/flv v0.0.2 - github.com/lkmio/mpeg v0.0.3 - github.com/lkmio/rtmp v0.0.2 + github.com/lkmio/avformat v0.0.2 + github.com/lkmio/flv v0.0.3 + github.com/lkmio/mpeg v0.0.4 + github.com/lkmio/rtmp v0.0.3 github.com/lkmio/rtp v0.0.2 github.com/lkmio/transport v0.0.1 ) diff --git a/jt1078/jt_demuxer.go b/jt1078/jt_demuxer.go index 31c33c1..b3cf978 100644 --- a/jt1078/jt_demuxer.go +++ b/jt1078/jt_demuxer.go @@ -17,7 +17,7 @@ type Demuxer struct { func (d *Demuxer) ProcessPrevPacket() error { var codec utils.AVCodecID index := d.FindBufferIndex(int(d.prevPacket.pt)) - bytes, err := d.BaseDemuxer.DataPipeline.Feat(index) + bytes, err := d.BaseDemuxer.DataPipeline.Fetch(index) if err != nil { return err } else /*if d.prevPacket.packetType > AudioFrameMark { diff --git a/stream/mw_buffer.go b/stream/mw_buffer.go index 1e8923e..2190796 100644 --- a/stream/mw_buffer.go +++ b/stream/mw_buffer.go @@ -102,7 +102,7 @@ func (m *mergeWritingBuffer) alloc(size int, ts int64, videoPkt, videoKey bool) func (m *mergeWritingBuffer) FlushSegment() (*collections.ReferenceCounter[[]byte], bool) { buffer := m.buffers.Peek(m.buffers.Size() - 1) - data := buffer.buffer.Feat() + data := buffer.buffer.Fetch() if len(data) == 0 { return nil, false }