Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(437)

Unified Diff: webrtc/test/channel_transport/udp_transport.h

Issue 2319583005: Moved webrtc/test/channel_transport/ into webrtc/voice_engine/test/ (Closed)
Patch Set: rebase Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: webrtc/test/channel_transport/udp_transport.h
diff --git a/webrtc/test/channel_transport/udp_transport.h b/webrtc/test/channel_transport/udp_transport.h
deleted file mode 100644
index 0c5079e69ff01803c491bd80d237657468bf8ef8..0000000000000000000000000000000000000000
--- a/webrtc/test/channel_transport/udp_transport.h
+++ /dev/null
@@ -1,381 +0,0 @@
-/*
- * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved.
- *
- * Use of this source code is governed by a BSD-style license
- * that can be found in the LICENSE file in the root of the source
- * tree. An additional intellectual property rights grant can be found
- * in the file PATENTS. All contributing project authors may
- * be found in the AUTHORS file in the root of the source tree.
- */
-
-#ifndef WEBRTC_TEST_CHANNEL_TRANSPORT_UDP_TRANSPORT_H_
-#define WEBRTC_TEST_CHANNEL_TRANSPORT_UDP_TRANSPORT_H_
-
-#include "webrtc/common_types.h"
-#include "webrtc/transport.h"
-#include "webrtc/typedefs.h"
-
-/*
- * WARNING
- * This code is not use in production/testing and might have security issues
- * for example: http://code.google.com/p/webrtc/issues/detail?id=1028
- *
- */
-
-#define SS_MAXSIZE 128
-#define SS_ALIGNSIZE (sizeof (uint64_t))
-#define SS_PAD1SIZE (SS_ALIGNSIZE - sizeof(int16_t))
-#define SS_PAD2SIZE (SS_MAXSIZE - (sizeof(int16_t) + SS_PAD1SIZE +\
- SS_ALIGNSIZE))
-
-// BSD requires use of HAVE_STRUCT_SOCKADDR_SA_LEN
-namespace webrtc {
-namespace test {
-
-struct SocketAddressIn {
- // sin_family should be either AF_INET (IPv4) or AF_INET6 (IPv6)
-#ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
- int8_t sin_length;
- int8_t sin_family;
-#else
- int16_t sin_family;
-#endif
- uint16_t sin_port;
- uint32_t sin_addr;
- int8_t sin_zero[8];
-};
-
-struct Version6InAddress {
- union {
- uint8_t _s6_u8[16];
- uint32_t _s6_u32[4];
- uint64_t _s6_u64[2];
- } Version6AddressUnion;
-};
-
-struct SocketAddressInVersion6 {
- // sin_family should be either AF_INET (IPv4) or AF_INET6 (IPv6)
-#ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
- int8_t sin_length;
- int8_t sin_family;
-#else
- int16_t sin_family;
-#endif
- // Transport layer port number.
- uint16_t sin6_port;
- // IPv6 traffic class and flow info or ip4 address.
- uint32_t sin6_flowinfo;
- // IPv6 address
- struct Version6InAddress sin6_addr;
- // Set of interfaces for a scope.
- uint32_t sin6_scope_id;
-};
-
-struct SocketAddressStorage {
- // sin_family should be either AF_INET (IPv4) or AF_INET6 (IPv6)
-#ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
- int8_t sin_length;
- int8_t sin_family;
-#else
- int16_t sin_family;
-#endif
- int8_t __ss_pad1[SS_PAD1SIZE];
- uint64_t __ss_align;
- int8_t __ss_pad2[SS_PAD2SIZE];
-};
-
-struct SocketAddress {
- union {
- struct SocketAddressIn _sockaddr_in;
- struct SocketAddressInVersion6 _sockaddr_in6;
- struct SocketAddressStorage _sockaddr_storage;
- };
-};
-
-// Callback class that receives packets from UdpTransport.
-class UdpTransportData {
- public:
- virtual ~UdpTransportData() {};
-
- virtual void IncomingRTPPacket(const int8_t* incomingRtpPacket,
- const size_t rtpPacketLength,
- const char* fromIP,
- const uint16_t fromPort) = 0;
-
- virtual void IncomingRTCPPacket(const int8_t* incomingRtcpPacket,
- const size_t rtcpPacketLength,
- const char* fromIP,
- const uint16_t fromPort) = 0;
-};
-
-class UdpTransport : public Transport {
- public:
- enum
- {
- kIpAddressVersion6Length = 64,
- kIpAddressVersion4Length = 16
- };
- enum ErrorCode
- {
- kNoSocketError = 0,
- kFailedToBindPort = 1,
- kIpAddressInvalid = 2,
- kAddressInvalid = 3,
- kSocketInvalid = 4,
- kPortInvalid = 5,
- kTosInvalid = 6,
- kMulticastAddressInvalid = 7,
- kQosError = 8,
- kSocketAlreadyInitialized = 9,
- kIpVersion6Error = 10,
- FILTER_ERROR = 11,
- kStartReceiveError = 12,
- kStopReceiveError = 13,
- kCannotFindLocalIp = 14,
- kTosError = 16,
- kNotInitialized = 17,
- kPcpError = 18
- };
-
- // Factory method. Constructor disabled.
- static UdpTransport* Create(const int32_t id, uint8_t& numSocketThreads);
- static void Destroy(UdpTransport* module);
-
- // Prepares the class for sending RTP packets to ipAddr:rtpPort and RTCP
- // packets to ipAddr:rtpPort+1 if rtcpPort is zero. Otherwise to
- // ipAddr:rtcpPort.
- virtual int32_t InitializeSendSockets(const char* ipAddr,
- const uint16_t rtpPort,
- const uint16_t rtcpPort = 0) = 0;
-
- // Register packetCallback for receiving incoming packets. Set the local
- // RTP port to rtpPort. Bind local IP address to ipAddr. If ipAddr is NULL
- // bind to local IP ANY. Set the local rtcp port to rtcpPort or rtpPort + 1
- // if rtcpPort is 0.
- virtual int32_t InitializeReceiveSockets(
- UdpTransportData* const packetCallback,
- const uint16_t rtpPort,
- const char* ipAddr = NULL,
- const char* multicastIpAddr = NULL,
- const uint16_t rtcpPort = 0) = 0;
-
- // Set local RTP port to rtpPort and RTCP port to rtcpPort or rtpPort + 1 if
- // rtcpPort is 0. These ports will be used for sending instead of the local
- // ports set by InitializeReceiveSockets(..).
- virtual int32_t InitializeSourcePorts(const uint16_t rtpPort,
- const uint16_t rtcpPort = 0) = 0;
-
- // Retrieve local ports used for sending if other than the ports specified
- // by InitializeReceiveSockets(..). rtpPort is set to the RTP port.
- // rtcpPort is set to the RTCP port.
- virtual int32_t SourcePorts(uint16_t& rtpPort,
- uint16_t& rtcpPort) const = 0;
-
- // Set ipAddr to the IP address that is currently being listened on. rtpPort
- // to the RTP port listened to. rtcpPort to the RTCP port listened on.
- // multicastIpAddr to the multicast IP address group joined (the address
- // is NULL terminated).
- virtual int32_t ReceiveSocketInformation(
- char ipAddr[kIpAddressVersion6Length],
- uint16_t& rtpPort,
- uint16_t& rtcpPort,
- char multicastIpAddr[kIpAddressVersion6Length]) const = 0;
-
- // Set ipAddr to the IP address being sent from. rtpPort to the local RTP
- // port used for sending and rtcpPort to the local RTCP port used for
- // sending.
- virtual int32_t SendSocketInformation(char ipAddr[kIpAddressVersion6Length],
- uint16_t& rtpPort,
- uint16_t& rtcpPort) const = 0;
-
- // Put the IP address, RTP port and RTCP port from the last received packet
- // into ipAddr, rtpPort and rtcpPort respectively.
- virtual int32_t RemoteSocketInformation(
- char ipAddr[kIpAddressVersion6Length],
- uint16_t& rtpPort,
- uint16_t& rtcpPort) const = 0;
-
- // Enable/disable quality of service if QoS is true or false respectively.
- // Set the type of service to serviceType, max bitrate in kbit/s to
- // maxBitrate and override DSCP if overrideDSCP is not 0.
- // Note: Must be called both InitializeSendSockets() and
- // InitializeReceiveSockets() has been called.
- virtual int32_t SetQoS(const bool QoS,
- const int32_t serviceType,
- const uint32_t maxBitrate = 0,
- const int32_t overrideDSCP = 0,
- const bool audio = false) = 0;
-
- // Set QoS to true if quality of service has been turned on. If QoS is true,
- // also set serviceType to type of service and overrideDSCP to override
- // DSCP.
- virtual int32_t QoS(bool& QoS,
- int32_t& serviceType,
- int32_t& overrideDSCP) const = 0;
-
- // Set type of service.
- virtual int32_t SetToS(const int32_t DSCP,
- const bool useSetSockOpt = false) = 0;
-
- // Get type of service configuration.
- virtual int32_t ToS(int32_t& DSCP,
- bool& useSetSockOpt) const = 0;
-
- // Set Priority Code Point (IEEE 802.1Q)
- // Note: for Linux this function will set the priority for the socket,
- // which then can be mapped to a PCP value with vconfig.
- virtual int32_t SetPCP(const int32_t PCP) = 0;
-
- // Get Priority Code Point
- virtual int32_t PCP(int32_t& PCP) const = 0;
-
- // Enable IPv6.
- // Note: this API must be called before any call to
- // InitializeReceiveSockets() or InitializeSendSockets(). It is not
- // possible to go back to IPv4 (default) after this call.
- virtual int32_t EnableIpV6() = 0;
-
- // Return true if IPv6 has been enabled.
- virtual bool IpV6Enabled() const = 0;
-
- // Only allow packets received from filterIPAddress to be processed.
- // Note: must be called after EnableIPv6(), if IPv6 is used.
- virtual int32_t SetFilterIP(
- const char filterIPAddress[kIpAddressVersion6Length]) = 0;
-
- // Write the filter IP address (if any) to filterIPAddress.
- virtual int32_t FilterIP(
- char filterIPAddress[kIpAddressVersion6Length]) const = 0;
-
- // Only allow RTP packets from rtpFilterPort and RTCP packets from
- // rtcpFilterPort be processed.
- // Note: must be called after EnableIPv6(), if IPv6 is used.
- virtual int32_t SetFilterPorts(const uint16_t rtpFilterPort,
- const uint16_t rtcpFilterPort) = 0;
-
- // Set rtpFilterPort to the filter RTP port and rtcpFilterPort to the
- // filter RTCP port (if filtering based on port is enabled).
- virtual int32_t FilterPorts(uint16_t& rtpFilterPort,
- uint16_t& rtcpFilterPort) const = 0;
-
- // Set the number of buffers that the socket implementation may use for
- // receiving packets to numberOfSocketBuffers. I.e. the number of packets
- // that can be received in parallell.
- // Note: this API only has effect on Windows.
- virtual int32_t StartReceiving(const uint32_t numberOfSocketBuffers) = 0;
-
- // Stop receive incoming packets.
- virtual int32_t StopReceiving() = 0;
-
- // Return true incoming packets are received.
- virtual bool Receiving() const = 0;
-
- // Return true if send sockets have been initialized.
- virtual bool SendSocketsInitialized() const = 0;
-
- // Return true if local ports for sending has been set.
- virtual bool SourcePortsInitialized() const = 0;
-
- // Return true if receive sockets have been initialized.
- virtual bool ReceiveSocketsInitialized() const = 0;
-
- // Send data with size length to ip:portnr. The same port as the set
- // with InitializeSendSockets(..) is used if portnr is 0. The same IP
- // address as set with InitializeSendSockets(..) is used if ip is NULL.
- // If isRTCP is true the port used will be the RTCP port.
- virtual int32_t SendRaw(const int8_t* data,
- size_t length,
- int32_t isRTCP,
- uint16_t portnr = 0,
- const char* ip = NULL) = 0;
-
- // Send RTP data with size length to the address specified by to.
- virtual int32_t SendRTPPacketTo(const int8_t* data,
- size_t length,
- const SocketAddress& to) = 0;
-
-
- // Send RTCP data with size length to the address specified by to.
- virtual int32_t SendRTCPPacketTo(const int8_t* data,
- size_t length,
- const SocketAddress& to) = 0;
-
- // Send RTP data with size length to ip:rtpPort where ip is the ip set by
- // the InitializeSendSockets(..) call.
- virtual int32_t SendRTPPacketTo(const int8_t* data,
- size_t length,
- uint16_t rtpPort) = 0;
-
-
- // Send RTCP data with size length to ip:rtcpPort where ip is the ip set by
- // the InitializeSendSockets(..) call.
- virtual int32_t SendRTCPPacketTo(const int8_t* data,
- size_t length,
- uint16_t rtcpPort) = 0;
-
- // Set the IP address to which packets are sent to ipaddr.
- virtual int32_t SetSendIP(
- const char ipaddr[kIpAddressVersion6Length]) = 0;
-
- // Set the send RTP and RTCP port to rtpPort and rtcpPort respectively.
- virtual int32_t SetSendPorts(const uint16_t rtpPort,
- const uint16_t rtcpPort = 0) = 0;
-
- // Retreive the last registered error code.
- virtual ErrorCode LastError() const = 0;
-
- // Put the local IPv4 address in localIP.
- // Note: this API is for IPv4 only.
- static int32_t LocalHostAddress(uint32_t& localIP);
-
- // Put the local IP6 address in localIP.
- // Note: this API is for IPv6 only.
- static int32_t LocalHostAddressIPV6(char localIP[16]);
-
- // Return a copy of hostOrder (host order) in network order.
- static uint16_t Htons(uint16_t hostOrder);
-
- // Return a copy of hostOrder (host order) in network order.
- static uint32_t Htonl(uint32_t hostOrder);
-
- // Return IPv4 address in ip as 32 bit integer.
- static uint32_t InetAddrIPV4(const char* ip);
-
- // Convert the character string src into a network address structure in
- // the af address family and put it in dst.
- // Note: same functionality as inet_pton(..)
- static int32_t InetPresentationToNumeric(int32_t af,
- const char* src,
- void* dst);
-
- // Set ip and sourcePort according to address. As input parameter ipSize
- // is the length of ip. As output parameter it's the number of characters
- // written to ip (not counting the '\0' character).
- // Note: this API is only implemented on Windows and Linux.
- static int32_t IPAddress(const SocketAddress& address,
- char* ip,
- uint32_t& ipSize,
- uint16_t& sourcePort);
-
- // Set ip and sourcePort according to address. As input parameter ipSize
- // is the length of ip. As output parameter it's the number of characters
- // written to ip (not counting the '\0' character).
- // Note: this API is only implemented on Windows and Linux.
- // Additional note: this API caches the address of the last call to it. If
- // address is likley to be the same for multiple calls it may be beneficial
- // to call this API instead of IPAddress().
- virtual int32_t IPAddressCached(const SocketAddress& address,
- char* ip,
- uint32_t& ipSize,
- uint16_t& sourcePort) = 0;
-
- // Return true if ipaddr is a valid IP address.
- // If ipV6 is false ipaddr is interpreted as an IPv4 address otherwise it
- // is interptreted as IPv6.
- static bool IsIpAddressValid(const char* ipaddr, const bool ipV6);
-};
-
-} // namespace test
-} // namespace webrtc
-
-#endif // WEBRTC_TEST_CHANNEL_TRANSPORT_UDP_TRANSPORT_H_
« no previous file with comments | « webrtc/test/channel_transport/udp_socket_wrapper_unittest.cc ('k') | webrtc/test/channel_transport/udp_transport_impl.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698