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