Compare commits

...

1 Commits

Author SHA1 Message Date
langhuihui
2e9cf9a4ca 重连机制修复 2020-07-11 21:54:59 +08:00

View File

@@ -279,10 +279,11 @@ func (client *RTSP) startStream() {
//loggerTime := time.Now().Add(-10 * time.Second)
defer func() {
if client.Err() == nil && config.Reconnect {
Printf("reconnecting:", client.URL)
Printf("reconnecting:%s", client.URL)
client.RTSPClientInfo = RTSPClientInfo{}
if err := client.requestStream(); err != nil {
Println(err)
client.Close()
client.Stop()
return
}
go client.startStream()
@@ -331,6 +332,9 @@ func (client *RTSP) startStream() {
pack = &RTPPack{
Type: RTP_TYPE_AUDIO,
}
if client.ACodec == "" {
continue
}
case client.aRTPControlChannel:
pack = &RTPPack{
Type: RTP_TYPE_AUDIOCONTROL,