apps/plugin-rtsp
1
0
Fork 0
mirror of https://github.com/Monibuca/plugin-rtsp.git synced 2026-04-22 15:27:05 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #44 from umaYnit/v4

Browse Source 
fix: 修复错误的流地址导致的Disconnect时panic
This commit is contained in:
dexter
2023-08-31 08:42:12 +08:00
committed by GitHub
parent 9936b2ca20 5df8f237de
commit 4a5ba9b834
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client.go
+5 -4
View File
@@ -28,7 +28,7 @@ func (p *RTSPClient) Disconnect() {
}
func (p *RTSPPuller) Connect() error {
p.Client = &gortsplib.Client{
client := &gortsplib.Client{
DialContext: p.DialContext,
ReadBufferCount: rtspConfig.ReadBufferCount,
AnyPortEnable: true,
@@ -37,10 +37,10 @@ func (p *RTSPPuller) Connect() error {
switch rtspConfig.PullProtocol {
case "tcp", "TCP":
p.Transport = gortsplib.TransportTCP
p.Client.Transport = &p.Transport
client.Transport = &p.Transport
case "udp", "UDP":
p.Transport = gortsplib.TransportUDP
p.Client.Transport = &p.Transport
client.Transport = &p.Transport
}
// parse URL
u, err := url.Parse(p.RemoteURL)
@@ -48,9 +48,10 @@ func (p *RTSPPuller) Connect() error {
return err
}
// connect to the server
if err = p.Client.Start(u.Scheme, u.Host); err != nil {
if err = client.Start(u.Scheme, u.Host); err != nil {
return err
}
p.Client = client
p.SetIO(p.Client)
return nil
}