apps/plugin-rtsp
1
0
Fork 0
mirror of https://github.com/Monibuca/plugin-rtsp.git synced 2025-09-30 21:42:09 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

增加重连时的判断

Browse Source
This commit is contained in:
langhuihui
2020-07-09 22:04:00 +08:00
parent cb733b368f
commit 67da93d8e2
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
client.go
View File

@@ -277,8 +277,8 @@ func (client *RTSP) requestStream() (err error) {
func (client *RTSP) startStream() { func (client *RTSP) startStream() {
//startTime := time.Now() //startTime := time.Now()
//loggerTime := time.Now().Add(-10 * time.Second) //loggerTime := time.Now().Add(-10 * time.Second)
if config.Reconnect {
defer func() { defer func() {
if client.Err() == nil && config.Reconnect {
Printf("reconnecting:", client.URL) Printf("reconnecting:", client.URL)
if err := client.requestStream(); err != nil { if err := client.requestStream(); err != nil {
Println(err) Println(err)
@@ -286,10 +286,10 @@ func (client *RTSP) startStream() {
return return
} }
go client.startStream() go client.startStream()
}()
} else { } else {
defer client.Stop() client.Stop()
} }
}()
for client.Err() == nil { for client.Err() == nil {
//if client.OptionIntervalMillis > 0 { //if client.OptionIntervalMillis > 0 {
// if time.Since(startTime) > time.Duration(client.OptionIntervalMillis)*time.Millisecond { // if time.Since(startTime) > time.Duration(client.OptionIntervalMillis)*time.Millisecond {