OLD | NEW |
---|---|
1 /* | 1 /* |
2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 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 | 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 | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 145 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
156 void OnAllocate(); | 156 void OnAllocate(); |
157 void DoAllocate(); | 157 void DoAllocate(); |
158 void OnNetworksChanged(); | 158 void OnNetworksChanged(); |
159 void OnAllocationSequenceObjectsCreated(); | 159 void OnAllocationSequenceObjectsCreated(); |
160 void DisableEquivalentPhases(rtc::Network* network, | 160 void DisableEquivalentPhases(rtc::Network* network, |
161 PortConfiguration* config, | 161 PortConfiguration* config, |
162 uint32_t* flags); | 162 uint32_t* flags); |
163 void AddAllocatedPort(Port* port, AllocationSequence* seq, | 163 void AddAllocatedPort(Port* port, AllocationSequence* seq, |
164 bool prepare_address); | 164 bool prepare_address); |
165 void OnCandidateReady(Port* port, const Candidate& c); | 165 void OnCandidateReady(Port* port, const Candidate& c); |
166 void MaybeSignalPortReady(Port* port); | |
167 void MaybeSignalCandidatesReady(Port* port, | |
168 const std::vector<Candidate>& candidates); | |
169 bool IsPortInUse(Port* port) const; | |
166 void OnPortComplete(Port* port); | 170 void OnPortComplete(Port* port); |
167 void OnPortError(Port* port); | 171 void OnPortError(Port* port); |
168 void OnProtocolEnabled(AllocationSequence* seq, ProtocolType proto); | 172 void OnProtocolEnabled(AllocationSequence* seq, ProtocolType proto); |
169 void OnPortDestroyed(PortInterface* port); | 173 void OnPortDestroyed(PortInterface* port); |
170 void MaybeSignalCandidatesAllocationDone(); | 174 void MaybeSignalCandidatesAllocationDone(); |
171 void OnPortAllocationComplete(AllocationSequence* seq); | 175 void OnPortAllocationComplete(AllocationSequence* seq); |
172 PortData* FindPort(Port* port); | 176 PortData* FindPort(Port* port); |
173 void GetNetworks(std::vector<rtc::Network*>* networks); | 177 void GetNetworks(std::vector<rtc::Network*>* networks); |
174 | 178 |
175 bool CheckCandidateFilter(const Candidate& c) const; | 179 bool CheckCandidateFilter(const Candidate& c) const; |
176 bool CandidatePairable(const Candidate& c, const Port* port) const; | 180 bool CandidatePairable(const Candidate& c, const Port* port) const; |
177 // Clear the related address according to the flags and candidate filter | 181 // Clear the related address according to the flags and candidate filter |
178 // in order to avoid leaking any information. | 182 // in order to avoid leaking any information. |
179 Candidate SanitizeRelatedAddress(const Candidate& c) const; | 183 Candidate SanitizeRelatedAddress(const Candidate& c) const; |
180 | 184 |
181 BasicPortAllocator* allocator_; | 185 BasicPortAllocator* allocator_; |
182 rtc::Thread* network_thread_; | 186 rtc::Thread* network_thread_; |
183 std::unique_ptr<rtc::PacketSocketFactory> owned_socket_factory_; | 187 std::unique_ptr<rtc::PacketSocketFactory> owned_socket_factory_; |
184 rtc::PacketSocketFactory* socket_factory_; | 188 rtc::PacketSocketFactory* socket_factory_; |
185 bool allocation_started_; | 189 bool allocation_started_; |
186 bool network_manager_started_; | 190 bool network_manager_started_; |
187 bool running_; // set when StartGetAllPorts is called | 191 bool running_; // set when StartGetAllPorts is called |
188 bool allocation_sequences_created_; | 192 bool allocation_sequences_created_; |
189 std::vector<PortConfiguration*> configs_; | 193 std::vector<PortConfiguration*> configs_; |
190 std::vector<AllocationSequence*> sequences_; | 194 std::vector<AllocationSequence*> sequences_; |
191 std::vector<PortData> ports_; | 195 std::vector<PortData> ports_; |
192 uint32_t candidate_filter_ = CF_ALL; | 196 uint32_t candidate_filter_ = CF_ALL; |
193 | 197 |
198 typedef std::vector<Port*> PortArray; | |
pthatcher1
2016/06/27 20:35:55
I'd prefer not to have a typedef and just have
s
honghaiz3
2016/06/28 01:49:26
Done.
| |
199 // The currently used turn ports keyed by the network names. | |
200 std::map<std::string, PortArray> turn_ports_in_use_by_network_names_; | |
pthatcher1
2016/06/27 20:35:55
Why not just turn_ports_by_network_name?
honghaiz3
2016/06/28 01:49:26
Removed this.
| |
201 | |
pthatcher1
2016/06/27 20:35:55
Actually, instead of having a separate map for tur
honghaiz3
2016/06/28 01:49:26
Done.
| |
194 friend class AllocationSequence; | 202 friend class AllocationSequence; |
195 }; | 203 }; |
196 | 204 |
197 // Records configuration information useful in creating ports. | 205 // Records configuration information useful in creating ports. |
198 // TODO(deadbeef): Rename "relay" to "turn_server" in this struct. | 206 // TODO(deadbeef): Rename "relay" to "turn_server" in this struct. |
199 struct PortConfiguration : public rtc::MessageData { | 207 struct PortConfiguration : public rtc::MessageData { |
200 // TODO(jiayl): remove |stun_address| when Chrome is updated. | 208 // TODO(jiayl): remove |stun_address| when Chrome is updated. |
201 rtc::SocketAddress stun_address; | 209 rtc::SocketAddress stun_address; |
202 ServerAddresses stun_servers; | 210 ServerAddresses stun_servers; |
203 std::string username; | 211 std::string username; |
(...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
319 std::unique_ptr<rtc::AsyncPacketSocket> udp_socket_; | 327 std::unique_ptr<rtc::AsyncPacketSocket> udp_socket_; |
320 // There will be only one udp port per AllocationSequence. | 328 // There will be only one udp port per AllocationSequence. |
321 UDPPort* udp_port_; | 329 UDPPort* udp_port_; |
322 std::vector<TurnPort*> turn_ports_; | 330 std::vector<TurnPort*> turn_ports_; |
323 int phase_; | 331 int phase_; |
324 }; | 332 }; |
325 | 333 |
326 } // namespace cricket | 334 } // namespace cricket |
327 | 335 |
328 #endif // WEBRTC_P2P_CLIENT_BASICPORTALLOCATOR_H_ | 336 #endif // WEBRTC_P2P_CLIENT_BASICPORTALLOCATOR_H_ |
OLD | NEW |