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

client: remove useless code

Browse Source
This commit is contained in:
aler9
2022-03-13 14:56:02 +01:00
parent 6fad3354e9
commit d54f478e16
1 changed files with 11 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
client.go
View File

@@ -709,37 +709,19 @@ func (c *Client) playRecordStart() {
v := time.Now().Unix() v := time.Now().Unix()
c.tcpLastFrameTime = &v c.tcpLastFrameTime = &v
} }
} else { } else if *c.effectiveTransport == TransportUDP {
switch *c.effectiveTransport { for trackID, cct := range c.tracks {
case TransportUDP: ctrackID := trackID
for trackID, cct := range c.tracks {
ctrackID := trackID
cct.rtcpSender = rtcpsender.New(c.udpSenderReportPeriod, cct.rtcpSender = rtcpsender.New(c.udpSenderReportPeriod,
cct.track.ClockRate(), func(pkt rtcp.Packet) { cct.track.ClockRate(), func(pkt rtcp.Packet) {
c.WritePacketRTCP(ctrackID, pkt) c.WritePacketRTCP(ctrackID, pkt)
}) })
} }
for _, cct := range c.tracks { for _, cct := range c.tracks {
cct.udpRTPListener.start(true) cct.udpRTPListener.start(true)
cct.udpRTCPListener.start(true) cct.udpRTCPListener.start(true)
}
case TransportUDPMulticast:
for trackID, cct := range c.tracks {
ctrackID := trackID
cct.rtcpSender = rtcpsender.New(c.udpSenderReportPeriod,
cct.track.ClockRate(), func(pkt rtcp.Packet) {
c.WritePacketRTCP(ctrackID, pkt)
})
}
for _, cct := range c.tracks {
cct.udpRTPListener.start(true)
cct.udpRTCPListener.start(true)
}
} }
} }