package/gortsplib
1
0
Fork 0
mirror of https://github.com/aler9/gortsplib synced 2025-10-08 16:40:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

rename LoopUDP into LoopUdp

Browse Source
This commit is contained in:
aler9
2020-08-15 22:38:04 +02:00
parent 9d622d2880
commit c889483a7a
3 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
conn-client.go
View File

@@ -573,10 +573,10 @@ func (c *ConnClient) Play(u *url.URL) (*Response, error) {
return res, nil return res, nil
} }
// LoopUDP must be called after SetupUDP() and Play(); it keeps // LoopUdp must be called after SetupUDP() and Play(); it keeps
// the TCP connection open through keepalives, and returns when the TCP // the TCP connection open through keepalives, and returns when the TCP
// connection closes. // connection closes.
func (c *ConnClient) LoopUDP(u *url.URL) error { func (c *ConnClient) LoopUdp(u *url.URL) error {
// send a first keepalive before starting reading // send a first keepalive before starting reading
_, err := c.Do(&Request{ _, err := c.Do(&Request{
Method: OPTIONS, Method: OPTIONS,

2
examples/client-tcp.go
View File

@@ -54,7 +54,7 @@ func main() {
break break
} }
fmt.Printf("packet from track %d, type %v: %v\n", fmt.Printf("frame from track %d, type %v: %v\n",
frame.TrackId, frame.StreamType, frame.Content) frame.TrackId, frame.StreamType, frame.Content)
} }
} }

10
examples/client-udp.go
View File

@@ -60,7 +60,7 @@ func main() {
for trackId, lp := range listeners { for trackId, lp := range listeners {
wg.Add(2) wg.Add(2)
// receive RTP packets // receive RTP frames
go func(trackId int, l *gortsplib.ConnClientUdpListener) { go func(trackId int, l *gortsplib.ConnClientUdpListener) {
defer wg.Done() defer wg.Done()
@@ -71,11 +71,11 @@ func main() {
break break
} }
fmt.Printf("packet from track %d, type RTP: %v\n", trackId, buf[:n]) fmt.Printf("frame from track %d, type RTP: %v\n", trackId, buf[:n])
} }
}(trackId, lp.rtpl) }(trackId, lp.rtpl)
// receive RTCP packets // receive RTCP frames
go func(trackId int, l *gortsplib.ConnClientUdpListener) { go func(trackId int, l *gortsplib.ConnClientUdpListener) {
defer wg.Done() defer wg.Done()
@@ -86,12 +86,12 @@ func main() {
break break
} }
fmt.Printf("packet from track %d, type RTCP: %v\n", trackId, buf[:n]) fmt.Printf("frame from track %d, type RTCP: %v\n", trackId, buf[:n])
} }
}(trackId, lp.rtcpl) }(trackId, lp.rtcpl)
} }
err = conn.LoopUDP(u) err = conn.LoopUdp(u)
fmt.Println("connection is closed (%s)", err) fmt.Println("connection is closed (%s)", err)
for _, lp := range listeners { for _, lp := range listeners {