mirror of
https://github.com/Monibuca/plugin-rtsp.git
synced 2025-09-27 12:02:20 +08:00
Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
fbc24a1253 | ||
![]() |
e19b9a34ba | ||
![]() |
e6d0489d9c | ||
![]() |
68d0d9aa08 |
@@ -42,6 +42,7 @@ func (rtsp *RTSPClient) PullStream(streamPath string, rtspUrl string) (err error
|
||||
time.Sleep(time.Second * 5)
|
||||
}
|
||||
if rtsp.IsTimeout {
|
||||
rtsp.processFunc = nil
|
||||
go rtsp.PullStream(streamPath, rtspUrl)
|
||||
}
|
||||
}()
|
||||
|
@@ -97,6 +97,14 @@ func (sh *RTSPServer) OnDescribe(ctx *gortsplib.ServerHandlerOnDescribeCtx) (*ba
|
||||
}
|
||||
var st uint32
|
||||
onVideo := func(ts uint32, pack *engine.VideoPack) {
|
||||
if pack.IDR {
|
||||
for _, nalu := range sub.vt.ExtraData.NALUs {
|
||||
for _, packet := range vpacketer.Packetize(nalu, 0) {
|
||||
buf, _ := packet.Marshal()
|
||||
stream.WritePacketRTP(trackId, buf)
|
||||
}
|
||||
}
|
||||
}
|
||||
for i, nalu := range pack.NALUs {
|
||||
var samples uint32
|
||||
if i == len(pack.NALUs)-1 {
|
||||
|
Reference in New Issue
Block a user