zishuo/rtsp-simple-server
1
0
Fork 0
mirror of https://github.com/aler9/rtsp-simple-server synced 2025-10-15 12:10:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

remove useless append()

Browse Source
This commit is contained in:
aler9
2022-08-14 13:14:08 +02:00
parent 3606472e82
commit f952ff25f6
4 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/core/rtsp_session.go
View File

@@ -395,7 +395,7 @@ func (s *rtspSession) onPacketRTP(ctx *gortsplib.ServerHandlerOnPacketRTPCtx) {
rtpPacket: ctx.Packet, rtpPacket: ctx.Packet,
ptsEqualsDTS: ctx.PTSEqualsDTS, ptsEqualsDTS: ctx.PTSEqualsDTS,
pts: ctx.H264PTS, pts: ctx.H264PTS,
h264NALUs: append([][]byte(nil), ctx.H264NALUs...), h264NALUs: ctx.H264NALUs,
}) })
} else { } else {
s.stream.writeData(&data{ s.stream.writeData(&data{

2
internal/core/rtsp_source.go
View File

@@ -146,7 +146,7 @@ func (s *rtspSource) run(ctx context.Context) error {
rtpPacket: ctx.Packet, rtpPacket: ctx.Packet,
ptsEqualsDTS: ctx.PTSEqualsDTS, ptsEqualsDTS: ctx.PTSEqualsDTS,
pts: ctx.H264PTS, pts: ctx.H264PTS,
h264NALUs: append([][]byte(nil), ctx.H264NALUs...), h264NALUs: ctx.H264NALUs,
}) })
} else { } else {
res.stream.writeData(&data{ res.stream.writeData(&data{

4
internal/core/streamtrack_h264.go
View File

@@ -40,12 +40,12 @@ func (t *streamTrackH264) updateTrackParameters(nalus [][]byte) {
switch typ { switch typ {
case h264.NALUTypeSPS: case h264.NALUTypeSPS:
if !bytes.Equal(nalu, t.track.SafeSPS()) { if !bytes.Equal(nalu, t.track.SafeSPS()) {
t.track.SafeSetSPS(append([]byte(nil), nalu...)) t.track.SafeSetSPS(nalu)
} }
case h264.NALUTypePPS: case h264.NALUTypePPS:
if !bytes.Equal(nalu, t.track.SafePPS()) { if !bytes.Equal(nalu, t.track.SafePPS()) {
t.track.SafeSetPPS(append([]byte(nil), nalu...)) t.track.SafeSetPPS(nalu)
} }
} }
} }

4
internal/hls/muxer_variant_fmp4_segmenter.go
View File

@@ -163,7 +163,7 @@ func (m *muxerVariantFMP4Segmenter) writeH264Entry(sample *fmp4.VideoSample) err
m.videoFirstIDRReceived = true m.videoFirstIDRReceived = true
m.videoDTSExtractor = h264.NewDTSExtractor() m.videoDTSExtractor = h264.NewDTSExtractor()
m.videoSPS = append([]byte(nil), m.videoTrack.SafeSPS()...) m.videoSPS = m.videoTrack.SafeSPS()
var err error var err error
sample.DTS, err = m.videoDTSExtractor.Extract(sample.NALUs, sample.PTS) sample.DTS, err = m.videoDTSExtractor.Extract(sample.NALUs, sample.PTS)
@@ -249,7 +249,7 @@ func (m *muxerVariantFMP4Segmenter) writeH264Entry(sample *fmp4.VideoSample) err
// if SPS changed, reset adjusted part duration // if SPS changed, reset adjusted part duration
if spsChanged { if spsChanged {
m.videoSPS = append([]byte(nil), sps...) m.videoSPS = sps
m.firstSegmentFinalized = false m.firstSegmentFinalized = false
m.sampleDurations = make(map[time.Duration]struct{}) m.sampleDurations = make(map[time.Duration]struct{})
} }