| OLD | NEW |
| (Empty) |
| 1 /* | |
| 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. | |
| 3 * | |
| 4 * Use of this source code is governed by a BSD-style license | |
| 5 * that can be found in the LICENSE file in the root of the source | |
| 6 * tree. An additional intellectual property rights grant can be found | |
| 7 * in the file PATENTS. All contributing project authors may | |
| 8 * be found in the AUTHORS file in the root of the source tree. | |
| 9 */ | |
| 10 | |
| 11 #ifndef WEBRTC_VOICE_ENGINE_TEST_CHANNEL_TRANSPORT_UDP_SOCKET2_WINDOWS_H_ | |
| 12 #define WEBRTC_VOICE_ENGINE_TEST_CHANNEL_TRANSPORT_UDP_SOCKET2_WINDOWS_H_ | |
| 13 | |
| 14 // Disable deprication warning from traffic.h | |
| 15 #pragma warning(disable : 4995) | |
| 16 | |
| 17 // Don't change include order for these header files. | |
| 18 #include <Winsock2.h> | |
| 19 #include <Ntddndis.h> | |
| 20 #include <traffic.h> | |
| 21 | |
| 22 #include "webrtc/base/event.h" | |
| 23 #include "webrtc/system_wrappers/include/atomic32.h" | |
| 24 #include "webrtc/system_wrappers/include/event_wrapper.h" | |
| 25 #include "webrtc/system_wrappers/include/rw_lock_wrapper.h" | |
| 26 #include "webrtc/system_wrappers/include/trace.h" | |
| 27 #include "webrtc/voice_engine/test/channel_transport/udp_socket2_manager_win.h" | |
| 28 #include "webrtc/voice_engine/test/channel_transport/udp_socket_wrapper.h" | |
| 29 | |
| 30 namespace webrtc { | |
| 31 namespace test { | |
| 32 | |
| 33 class UdpSocket2ManagerWindows; | |
| 34 class TrafficControlWindows; | |
| 35 struct PerIoContext; | |
| 36 | |
| 37 class UdpSocket2Windows : public UdpSocketWrapper | |
| 38 { | |
| 39 public: | |
| 40 UdpSocket2Windows(const int32_t id, UdpSocketManager* mgr, | |
| 41 bool ipV6Enable = false, bool disableGQOS = false); | |
| 42 virtual ~UdpSocket2Windows(); | |
| 43 | |
| 44 bool ValidHandle() override; | |
| 45 | |
| 46 bool SetCallback(CallbackObj, IncomingSocketCallback) override; | |
| 47 | |
| 48 bool Bind(const SocketAddress& name) override; | |
| 49 bool SetSockopt(int32_t level, | |
| 50 int32_t optname, | |
| 51 const int8_t* optval, | |
| 52 int32_t optlen) override; | |
| 53 | |
| 54 bool StartReceiving(const uint32_t receiveBuffers) override; | |
| 55 inline bool StartReceiving() override { return StartReceiving(8); } | |
| 56 bool StopReceiving() override; | |
| 57 | |
| 58 int32_t SendTo(const int8_t* buf, | |
| 59 size_t len, | |
| 60 const SocketAddress& to) override; | |
| 61 | |
| 62 void CloseBlocking() override; | |
| 63 | |
| 64 SOCKET GetFd() { return _socket;} | |
| 65 | |
| 66 bool SetQos(int32_t serviceType, | |
| 67 int32_t tokenRate, | |
| 68 int32_t bucketSize, | |
| 69 int32_t peekBandwith, | |
| 70 int32_t minPolicedSize, | |
| 71 int32_t maxSduSize, | |
| 72 const SocketAddress& stRemName, | |
| 73 int32_t overrideDSCP = 0) override; | |
| 74 | |
| 75 int32_t SetTOS(const int32_t serviceType) override; | |
| 76 int32_t SetPCP(const int32_t pcp) override; | |
| 77 | |
| 78 uint32_t ReceiveBuffers() override { return _receiveBuffers.Value(); } | |
| 79 | |
| 80 protected: | |
| 81 void IOCompleted(PerIoContext* pIOContext, uint32_t ioSize, uint32_t error); | |
| 82 | |
| 83 int32_t PostRecv(); | |
| 84 // Use pIoContext to post a new WSARecvFrom(..). | |
| 85 int32_t PostRecv(PerIoContext* pIoContext); | |
| 86 | |
| 87 private: | |
| 88 friend class UdpSocket2WorkerWindows; | |
| 89 | |
| 90 // Set traffic control (TC) flow adding it the interface that matches this | |
| 91 // sockets address. | |
| 92 // A filter is created and added to the flow. | |
| 93 // The flow consists of: | |
| 94 // (1) QoS send and receive information (flow specifications). | |
| 95 // (2) A DS object (for specifying exact DSCP value). | |
| 96 // (3) Possibly a traffic object (for specifying exact 802.1p priority (PCP) | |
| 97 // value). | |
| 98 // | |
| 99 // dscp values: | |
| 100 // -1 don't change the current dscp value. | |
| 101 // 0 don't add any flow to TC, unless pcp is specified. | |
| 102 // 1-63 Add a flow to TC with the specified dscp value. | |
| 103 // pcp values: | |
| 104 // -2 Don't add pcp info to the flow, (3) will not be added. | |
| 105 // -1 Don't change the current value. | |
| 106 // 0-7 Add pcp info to the flow with the specified value, | |
| 107 // (3) will be added. | |
| 108 // | |
| 109 // If both dscp and pcp are -1 no flow will be created or added to TC. | |
| 110 // If dscp is 0 and pcp is 0-7 (1), (2) and (3) will be created. | |
| 111 // Note: input parameter values are assumed to be in valid range, checks | |
| 112 // must be done by caller. | |
| 113 int32_t SetTrafficControl(int32_t dscp, int32_t pcp, | |
| 114 const struct sockaddr_in* name, | |
| 115 FLOWSPEC* send = NULL, | |
| 116 FLOWSPEC* recv = NULL); | |
| 117 int32_t CreateFlowSpec(int32_t serviceType, | |
| 118 int32_t tokenRate, | |
| 119 int32_t bucketSize, | |
| 120 int32_t peekBandwith, | |
| 121 int32_t minPolicedSize, | |
| 122 int32_t maxSduSize, FLOWSPEC *f); | |
| 123 | |
| 124 int32_t _id; | |
| 125 RWLockWrapper* _ptrCbRWLock; | |
| 126 IncomingSocketCallback _incomingCb; | |
| 127 CallbackObj _obj; | |
| 128 bool _qos; | |
| 129 | |
| 130 SocketAddress _remoteAddr; | |
| 131 SOCKET _socket; | |
| 132 int32_t _iProtocol; | |
| 133 UdpSocket2ManagerWindows* _mgr; | |
| 134 | |
| 135 Atomic32 _outstandingCalls; | |
| 136 Atomic32 _outstandingCallComplete; | |
| 137 volatile bool _terminate; | |
| 138 volatile bool _addedToMgr; | |
| 139 | |
| 140 rtc::Event delete_event_; | |
| 141 | |
| 142 RWLockWrapper* _ptrDestRWLock; | |
| 143 bool _outstandingCallsDisabled; | |
| 144 bool NewOutstandingCall(); | |
| 145 void OutstandingCallCompleted(); | |
| 146 void DisableNewOutstandingCalls(); | |
| 147 | |
| 148 void RemoveSocketFromManager(); | |
| 149 | |
| 150 // RWLockWrapper is used as a reference counter for the socket. Write lock | |
| 151 // is used for creating and deleting socket. Read lock is used for | |
| 152 // accessing the socket. | |
| 153 RWLockWrapper* _ptrSocketRWLock; | |
| 154 bool AquireSocket(); | |
| 155 void ReleaseSocket(); | |
| 156 bool InvalidateSocket(); | |
| 157 | |
| 158 // Traffic control handles and structure pointers. | |
| 159 HANDLE _clientHandle; | |
| 160 HANDLE _flowHandle; | |
| 161 HANDLE _filterHandle; | |
| 162 PTC_GEN_FLOW _flow; | |
| 163 // TrafficControlWindows implements TOS and PCP. | |
| 164 TrafficControlWindows* _gtc; | |
| 165 // Holds the current pcp value. Can be -2 or 0 - 7. | |
| 166 int _pcp; | |
| 167 | |
| 168 Atomic32 _receiveBuffers; | |
| 169 }; | |
| 170 | |
| 171 } // namespace test | |
| 172 } // namespace webrtc | |
| 173 | |
| 174 #endif // WEBRTC_VOICE_ENGINE_TEST_CHANNEL_TRANSPORT_UDP_SOCKET2_WINDOWS_H_ | |
| OLD | NEW |