Index: webrtc/voice_engine/test/channel_transport/udp_transport_impl.h |
diff --git a/webrtc/voice_engine/test/channel_transport/udp_transport_impl.h b/webrtc/voice_engine/test/channel_transport/udp_transport_impl.h |
deleted file mode 100644 |
index 236ff53f5fcbe5511fe7ff7bdff3c94350deded5..0000000000000000000000000000000000000000 |
--- a/webrtc/voice_engine/test/channel_transport/udp_transport_impl.h |
+++ /dev/null |
@@ -1,259 +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_VOICE_ENGINE_TEST_CHANNEL_TRANSPORT_UDP_TRANSPORT_IMPL_H_ |
-#define WEBRTC_VOICE_ENGINE_TEST_CHANNEL_TRANSPORT_UDP_TRANSPORT_IMPL_H_ |
- |
-#include "webrtc/voice_engine/test/channel_transport/udp_socket_wrapper.h" |
-#include "webrtc/voice_engine/test/channel_transport/udp_transport.h" |
- |
-namespace webrtc { |
- |
-class CriticalSectionWrapper; |
-class RWLockWrapper; |
- |
-namespace test { |
- |
-class UdpSocketManager; |
- |
-class UdpTransportImpl : public UdpTransport |
-{ |
-public: |
- // A factory that returns a wrapped UDP socket or equivalent. |
- class SocketFactoryInterface { |
- public: |
- virtual ~SocketFactoryInterface() {} |
- virtual UdpSocketWrapper* CreateSocket(const int32_t id, |
- UdpSocketManager* mgr, |
- CallbackObj obj, |
- IncomingSocketCallback cb, |
- bool ipV6Enable, |
- bool disableGQOS) = 0; |
- }; |
- |
- // Constructor, only called by UdpTransport::Create and tests. |
- // The constructor takes ownership of the "maker". |
- // The constructor does not take ownership of socket_manager. |
- UdpTransportImpl(const int32_t id, |
- SocketFactoryInterface* maker, |
- UdpSocketManager* socket_manager); |
- virtual ~UdpTransportImpl(); |
- |
- // UdpTransport functions |
- int32_t InitializeSendSockets(const char* ipAddr, |
- const uint16_t rtpPort, |
- const uint16_t rtcpPort = 0) override; |
- int32_t InitializeReceiveSockets(UdpTransportData* const packetCallback, |
- const uint16_t rtpPort, |
- const char* ipAddr = NULL, |
- const char* multicastIpAddr = NULL, |
- const uint16_t rtcpPort = 0) override; |
- int32_t InitializeSourcePorts(const uint16_t rtpPort, |
- const uint16_t rtcpPort = 0) override; |
- int32_t SourcePorts(uint16_t& rtpPort, uint16_t& rtcpPort) const override; |
- int32_t ReceiveSocketInformation( |
- char ipAddr[kIpAddressVersion6Length], |
- uint16_t& rtpPort, |
- uint16_t& rtcpPort, |
- char multicastIpAddr[kIpAddressVersion6Length]) const override; |
- int32_t SendSocketInformation(char ipAddr[kIpAddressVersion6Length], |
- uint16_t& rtpPort, |
- uint16_t& rtcpPort) const override; |
- int32_t RemoteSocketInformation(char ipAddr[kIpAddressVersion6Length], |
- uint16_t& rtpPort, |
- uint16_t& rtcpPort) const override; |
- int32_t SetQoS(const bool QoS, |
- const int32_t serviceType, |
- const uint32_t maxBitrate = 0, |
- const int32_t overrideDSCP = 0, |
- const bool audio = false) override; |
- int32_t QoS(bool& QoS, |
- int32_t& serviceType, |
- int32_t& overrideDSCP) const override; |
- int32_t SetToS(const int32_t DSCP, |
- const bool useSetSockOpt = false) override; |
- int32_t ToS(int32_t& DSCP, bool& useSetSockOpt) const override; |
- int32_t SetPCP(const int32_t PCP) override; |
- int32_t PCP(int32_t& PCP) const override; |
- int32_t EnableIpV6() override; |
- bool IpV6Enabled() const override; |
- int32_t SetFilterIP( |
- const char filterIPAddress[kIpAddressVersion6Length]) override; |
- int32_t FilterIP( |
- char filterIPAddress[kIpAddressVersion6Length]) const override; |
- int32_t SetFilterPorts(const uint16_t rtpFilterPort, |
- const uint16_t rtcpFilterPort) override; |
- int32_t FilterPorts(uint16_t& rtpFilterPort, |
- uint16_t& rtcpFilterPort) const override; |
- int32_t StartReceiving(const uint32_t numberOfSocketBuffers) override; |
- int32_t StopReceiving() override; |
- bool Receiving() const override; |
- bool SendSocketsInitialized() const override; |
- bool SourcePortsInitialized() const override; |
- bool ReceiveSocketsInitialized() const override; |
- int32_t SendRaw(const int8_t* data, |
- size_t length, |
- int32_t isRTCP, |
- uint16_t portnr = 0, |
- const char* ip = NULL) override; |
- int32_t SendRTPPacketTo(const int8_t* data, |
- size_t length, |
- const SocketAddress& to) override; |
- int32_t SendRTCPPacketTo(const int8_t* data, |
- size_t length, |
- const SocketAddress& to) override; |
- int32_t SendRTPPacketTo(const int8_t* data, |
- size_t length, |
- uint16_t rtpPort) override; |
- int32_t SendRTCPPacketTo(const int8_t* data, |
- size_t length, |
- uint16_t rtcpPort) override; |
- // Transport functions |
- bool SendRtp(const uint8_t* data, |
- size_t length, |
- const PacketOptions& packet_options) override; |
- bool SendRtcp(const uint8_t* data, size_t length) override; |
- |
- // UdpTransport functions continue. |
- int32_t SetSendIP(const char* ipaddr) override; |
- int32_t SetSendPorts(const uint16_t rtpPort, |
- const uint16_t rtcpPort = 0) override; |
- |
- ErrorCode LastError() const override; |
- |
- int32_t IPAddressCached(const SocketAddress& address, |
- char* ip, |
- uint32_t& ipSize, |
- uint16_t& sourcePort) override; |
- |
- int32_t Id() const {return _id;} |
-protected: |
- // IncomingSocketCallback signature functions for receiving callbacks from |
- // UdpSocketWrapper. |
- static void IncomingRTPCallback(CallbackObj obj, |
- const int8_t* rtpPacket, |
- size_t rtpPacketLength, |
- const SocketAddress* from); |
- static void IncomingRTCPCallback(CallbackObj obj, |
- const int8_t* rtcpPacket, |
- size_t rtcpPacketLength, |
- const SocketAddress* from); |
- |
- void CloseSendSockets(); |
- void CloseReceiveSockets(); |
- |
- // Update _remoteRTPAddr according to _destPort and _destIP |
- void BuildRemoteRTPAddr(); |
- // Update _remoteRTCPAddr according to _destPortRTCP and _destIP |
- void BuildRemoteRTCPAddr(); |
- |
- void BuildSockaddrIn(uint16_t portnr, const char* ip, |
- SocketAddress& remoteAddr) const; |
- |
- ErrorCode BindLocalRTPSocket(); |
- ErrorCode BindLocalRTCPSocket(); |
- |
- ErrorCode BindRTPSendSocket(); |
- ErrorCode BindRTCPSendSocket(); |
- |
- void IncomingRTPFunction(const int8_t* rtpPacket, |
- size_t rtpPacketLength, |
- const SocketAddress* from); |
- void IncomingRTCPFunction(const int8_t* rtcpPacket, |
- size_t rtcpPacketLength, |
- const SocketAddress* from); |
- |
- bool FilterIPAddress(const SocketAddress* fromAddress); |
- |
- bool SetSockOptUsed(); |
- |
- int32_t EnableQoS(int32_t serviceType, bool audio, |
- uint32_t maxBitrate, int32_t overrideDSCP); |
- |
- int32_t DisableQoS(); |
- |
-private: |
- void GetCachedAddress(char* ip, uint32_t& ipSize, |
- uint16_t& sourcePort); |
- |
- int32_t _id; |
- SocketFactoryInterface* _socket_creator; |
- // Protects the sockets from being re-configured while receiving packets. |
- CriticalSectionWrapper* _crit; |
- CriticalSectionWrapper* _critFilter; |
- // _packetCallback's critical section. |
- CriticalSectionWrapper* _critPacketCallback; |
- UdpSocketManager* _mgr; |
- ErrorCode _lastError; |
- |
- // Remote RTP and RTCP ports. |
- uint16_t _destPort; |
- uint16_t _destPortRTCP; |
- |
- // Local RTP and RTCP ports. |
- uint16_t _localPort; |
- uint16_t _localPortRTCP; |
- |
- // Local port number when the local port for receiving and local port number |
- // for sending are not the same. |
- uint16_t _srcPort; |
- uint16_t _srcPortRTCP; |
- |
- // Remote port from which last received packet was sent. |
- uint16_t _fromPort; |
- uint16_t _fromPortRTCP; |
- |
- char _fromIP[kIpAddressVersion6Length]; |
- char _destIP[kIpAddressVersion6Length]; |
- char _localIP[kIpAddressVersion6Length]; |
- char _localMulticastIP[kIpAddressVersion6Length]; |
- |
- UdpSocketWrapper* _ptrRtpSocket; |
- UdpSocketWrapper* _ptrRtcpSocket; |
- |
- // Local port when the local port for receiving and local port for sending |
- // are not the same. |
- UdpSocketWrapper* _ptrSendRtpSocket; |
- UdpSocketWrapper* _ptrSendRtcpSocket; |
- |
- SocketAddress _remoteRTPAddr; |
- SocketAddress _remoteRTCPAddr; |
- |
- SocketAddress _localRTPAddr; |
- SocketAddress _localRTCPAddr; |
- |
- int32_t _tos; |
- bool _receiving; |
- bool _useSetSockOpt; |
- bool _qos; |
- int32_t _pcp; |
- bool _ipV6Enabled; |
- int32_t _serviceType; |
- int32_t _overrideDSCP; |
- uint32_t _maxBitrate; |
- |
- // Cache used by GetCachedAddress(..). |
- RWLockWrapper* _cachLock; |
- SocketAddress _previousAddress; |
- char _previousIP[kIpAddressVersion6Length]; |
- uint32_t _previousIPSize; |
- uint16_t _previousSourcePort; |
- |
- SocketAddress _filterIPAddress; |
- uint16_t _rtpFilterPort; |
- uint16_t _rtcpFilterPort; |
- |
- UdpTransportData* _packetCallback; |
-}; |
- |
-} // namespace test |
-} // namespace webrtc |
- |
-#endif // WEBRTC_VOICE_ENGINE_TEST_CHANNEL_TRANSPORT_UDP_TRANSPORT_IMPL_H_ |