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

client: rename ClientTransportMulticast into ClientTransportUDPMulticast

Browse Source
This commit is contained in:
aler9
2021-10-22 16:26:33 +02:00
parent 7735bcd9ec
commit b64c32c621
3 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
client.go
View File

@@ -41,7 +41,7 @@ type ClientTransport int
// standard client transports.
const (
ClientTransportUDP ClientTransport = iota
ClientTransportMulticast
ClientTransportUDPMulticast
ClientTransportTCP
)

2
client_read_test.go
View File

@@ -397,7 +397,7 @@ func TestClientRead(t *testing.T) {
return &v
case "multicast":
v := ClientTransportMulticast
v := ClientTransportUDPMulticast
return &v
default: // tcp, tls

10
clientconn.go
View File

@@ -449,7 +449,7 @@ func (cc *ClientConn) backgroundClose(isSwitchingProtocol bool) {
func (cc *ClientConn) runBackground() {
cc.backgroundInnerDone <- func() error {
if cc.state == clientConnStatePlay {
if *cc.protocol == ClientTransportUDP || *cc.protocol == ClientTransportMulticast {
if *cc.protocol == ClientTransportUDP || *cc.protocol == ClientTransportUDPMulticast {
return cc.runBackgroundPlayUDP()
}
return cc.runBackgroundPlayTCP()
@@ -1257,7 +1257,7 @@ func (cc *ClientConn) doSetup(
rtcpListener.port(),
}
case ClientTransportMulticast:
case ClientTransportUDPMulticast:
v1 := base.StreamDeliveryMulticast
th.Delivery = &v1
th.Protocol = base.StreamProtocolUDP
@@ -1337,7 +1337,7 @@ func (cc *ClientConn) doSetup(
}
}
case ClientTransportMulticast:
case ClientTransportUDPMulticast:
if thRes.Delivery == nil || *thRes.Delivery != base.StreamDeliveryMulticast {
return nil, liberrors.ErrClientTransportHeaderInvalidDelivery{}
}
@@ -1422,7 +1422,7 @@ func (cc *ClientConn) doSetup(
rtcpListener.streamType = StreamTypeRTCP
cct.udpRTCPListener = rtcpListener
case ClientTransportMulticast:
case ClientTransportUDPMulticast:
rtpListener.remoteReadIP = cc.nconn.RemoteAddr().(*net.TCPAddr).IP
rtpListener.remoteWriteIP = *thRes.Destination
rtpListener.remoteZone = ""
@@ -1700,7 +1700,7 @@ func (cc *ClientConn) WriteFrame(trackID int, streamType StreamType, payload []b
}
switch *cc.protocol {
case ClientTransportUDP, ClientTransportMulticast:
case ClientTransportUDP, ClientTransportUDPMulticast:
if streamType == StreamTypeRTP {
return cc.tracks[trackID].udpRTPListener.write(payload)
}