| Index: webrtc/p2p/client/fakeportallocator.h
|
| diff --git a/webrtc/p2p/client/fakeportallocator.h b/webrtc/p2p/client/fakeportallocator.h
|
| deleted file mode 100644
|
| index d16c9b6d5c19388431df413580f7c178f15db603..0000000000000000000000000000000000000000
|
| --- a/webrtc/p2p/client/fakeportallocator.h
|
| +++ /dev/null
|
| @@ -1,189 +0,0 @@
|
| -/*
|
| - * Copyright 2010 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_P2P_CLIENT_FAKEPORTALLOCATOR_H_
|
| -#define WEBRTC_P2P_CLIENT_FAKEPORTALLOCATOR_H_
|
| -
|
| -#include <memory>
|
| -#include <string>
|
| -
|
| -#include "webrtc/p2p/base/basicpacketsocketfactory.h"
|
| -#include "webrtc/p2p/base/portallocator.h"
|
| -#include "webrtc/p2p/base/udpport.h"
|
| -#include "webrtc/base/scoped_ptr.h"
|
| -
|
| -namespace rtc {
|
| -class SocketFactory;
|
| -class Thread;
|
| -}
|
| -
|
| -namespace cricket {
|
| -
|
| -class TestUDPPort : public UDPPort {
|
| - public:
|
| - static TestUDPPort* Create(rtc::Thread* thread,
|
| - rtc::PacketSocketFactory* factory,
|
| - rtc::Network* network,
|
| - const rtc::IPAddress& ip,
|
| - uint16_t min_port,
|
| - uint16_t max_port,
|
| - const std::string& username,
|
| - const std::string& password,
|
| - const std::string& origin,
|
| - bool emit_localhost_for_anyaddress) {
|
| - TestUDPPort* port = new TestUDPPort(thread, factory, network, ip, min_port,
|
| - max_port, username, password, origin,
|
| - emit_localhost_for_anyaddress);
|
| - if (!port->Init()) {
|
| - delete port;
|
| - port = nullptr;
|
| - }
|
| - return port;
|
| - }
|
| - void SendBindingResponse(StunMessage* request,
|
| - const rtc::SocketAddress& addr) override {
|
| - UDPPort::SendBindingResponse(request, addr);
|
| - sent_binding_response_ = true;
|
| - }
|
| - bool sent_binding_response() { return sent_binding_response_; }
|
| - void set_sent_binding_response(bool response) {
|
| - sent_binding_response_ = response;
|
| - }
|
| -
|
| - protected:
|
| - TestUDPPort(rtc::Thread* thread,
|
| - rtc::PacketSocketFactory* factory,
|
| - rtc::Network* network,
|
| - const rtc::IPAddress& ip,
|
| - uint16_t min_port,
|
| - uint16_t max_port,
|
| - const std::string& username,
|
| - const std::string& password,
|
| - const std::string& origin,
|
| - bool emit_localhost_for_anyaddress)
|
| - : UDPPort(thread,
|
| - factory,
|
| - network,
|
| - ip,
|
| - min_port,
|
| - max_port,
|
| - username,
|
| - password,
|
| - origin,
|
| - emit_localhost_for_anyaddress) {}
|
| -
|
| - bool sent_binding_response_ = false;
|
| -};
|
| -
|
| -class FakePortAllocatorSession : public PortAllocatorSession {
|
| - public:
|
| - FakePortAllocatorSession(rtc::Thread* worker_thread,
|
| - rtc::PacketSocketFactory* factory,
|
| - const std::string& content_name,
|
| - int component,
|
| - const std::string& ice_ufrag,
|
| - const std::string& ice_pwd)
|
| - : PortAllocatorSession(content_name, component, ice_ufrag, ice_pwd,
|
| - cricket::kDefaultPortAllocatorFlags),
|
| - worker_thread_(worker_thread),
|
| - factory_(factory),
|
| - network_("network", "unittest",
|
| - rtc::IPAddress(INADDR_LOOPBACK), 8),
|
| - port_(), running_(false),
|
| - port_config_count_(0) {
|
| - network_.AddIP(rtc::IPAddress(INADDR_LOOPBACK));
|
| - }
|
| -
|
| - virtual void StartGettingPorts() {
|
| - if (!port_) {
|
| - port_.reset(TestUDPPort::Create(worker_thread_, factory_, &network_,
|
| - network_.GetBestIP(), 0, 0, username(),
|
| - password(), std::string(), false));
|
| - AddPort(port_.get());
|
| - }
|
| - ++port_config_count_;
|
| - running_ = true;
|
| - }
|
| -
|
| - virtual void StopGettingPorts() { running_ = false; }
|
| - virtual bool IsGettingPorts() { return running_; }
|
| - virtual void ClearGettingPorts() {}
|
| -
|
| - int port_config_count() { return port_config_count_; }
|
| -
|
| - void AddPort(cricket::Port* port) {
|
| - port->set_component(component_);
|
| - port->set_generation(0);
|
| - port->SignalPortComplete.connect(
|
| - this, &FakePortAllocatorSession::OnPortComplete);
|
| - port->PrepareAddress();
|
| - SignalPortReady(this, port);
|
| - }
|
| - void OnPortComplete(cricket::Port* port) {
|
| - SignalCandidatesReady(this, port->Candidates());
|
| - SignalCandidatesAllocationDone(this);
|
| - }
|
| -
|
| - private:
|
| - rtc::Thread* worker_thread_;
|
| - rtc::PacketSocketFactory* factory_;
|
| - rtc::Network network_;
|
| - std::unique_ptr<cricket::Port> port_;
|
| - bool running_;
|
| - int port_config_count_;
|
| -};
|
| -
|
| -class FakePortAllocator : public cricket::PortAllocator {
|
| - public:
|
| - FakePortAllocator(rtc::Thread* worker_thread,
|
| - rtc::PacketSocketFactory* factory)
|
| - : worker_thread_(worker_thread), factory_(factory) {
|
| - if (factory_ == NULL) {
|
| - owned_factory_.reset(new rtc::BasicPacketSocketFactory(
|
| - worker_thread_));
|
| - factory_ = owned_factory_.get();
|
| - }
|
| - }
|
| -
|
| - void SetIceServers(
|
| - const ServerAddresses& stun_servers,
|
| - const std::vector<RelayServerConfig>& turn_servers) override {
|
| - stun_servers_ = stun_servers;
|
| - turn_servers_ = turn_servers;
|
| - }
|
| -
|
| - void SetNetworkIgnoreMask(int network_ignore_mask) override {}
|
| -
|
| - const ServerAddresses& stun_servers() const { return stun_servers_; }
|
| -
|
| - const std::vector<RelayServerConfig>& turn_servers() const {
|
| - return turn_servers_;
|
| - }
|
| -
|
| - virtual cricket::PortAllocatorSession* CreateSessionInternal(
|
| - const std::string& content_name,
|
| - int component,
|
| - const std::string& ice_ufrag,
|
| - const std::string& ice_pwd) override {
|
| - return new FakePortAllocatorSession(
|
| - worker_thread_, factory_, content_name, component, ice_ufrag, ice_pwd);
|
| - }
|
| -
|
| - private:
|
| - rtc::Thread* worker_thread_;
|
| - rtc::PacketSocketFactory* factory_;
|
| - std::unique_ptr<rtc::BasicPacketSocketFactory> owned_factory_;
|
| - ServerAddresses stun_servers_;
|
| - std::vector<RelayServerConfig> turn_servers_;
|
| -};
|
| -
|
| -} // namespace cricket
|
| -
|
| -#endif // WEBRTC_P2P_CLIENT_FAKEPORTALLOCATOR_H_
|
|
|