psa/rtsp_reader-writer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added ignoring "lost package error".

Browse Source
This commit is contained in:
Сергей Петров 2025-04-22 16:38:38 +05:00
parent c432174dca
commit 26d94558be
1 changed files with 36 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
writer/internal/ingest/rtsp/rtsp.go
View File

@ -254,6 +254,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -349,6 +352,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -474,6 +480,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -687,6 +696,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -832,6 +844,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -942,6 +957,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -1030,6 +1048,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -1118,6 +1139,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -1208,6 +1232,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -1296,6 +1323,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -1393,6 +1423,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {
@ -1490,6 +1523,9 @@ func rtsp(dir string, period int, link string, number int) error {
return err return err
} }
// Skip "lost packet error".
c.OnPacketsLost = func(lost uint64) {}
// Set program if the client gets request. // Set program if the client gets request.
c.OnRequest = func(req *base.Request) { c.OnRequest = func(req *base.Request) {
switch req.Method { switch req.Method {