blob: 445eef942fd1504b4ddf441af708c1db6670dc19 [file] [log] [blame]
// Copyright 2015 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include <array>
#include <list>
#include <memory>
#include <string>
#include <vector>
#include "base/macros.h"
#include "base/memory/ref_counted.h"
#include "remoting/protocol/ice_config.h"
#include "remoting/protocol/network_settings.h"
#include "remoting/protocol/transport.h"
namespace remoting {
class OAuthTokenGetter;
class SignalStrategy;
class UrlRequestFactory;
namespace protocol {
class PortAllocatorFactory;
class IceConfigRequest;
// TransportContext is responsible for storing all parameters required for
// P2P transport initialization. It's also responsible for fetching STUN and
// TURN configuration.
class TransportContext : public base::RefCountedThreadSafe<TransportContext> {
enum RelayMode {
static const int kNumRelayModes = RelayMode::LAST_RELAYMODE + 1;
typedef base::Callback<void(const IceConfig& ice_config)>
static scoped_refptr<TransportContext> ForTests(TransportRole role);
TransportContext(SignalStrategy* signal_strategy,
std::unique_ptr<PortAllocatorFactory> port_allocator_factory,
std::unique_ptr<UrlRequestFactory> url_request_factory,
const NetworkSettings& network_settings,
TransportRole role);
void set_turn_ice_config(const IceConfig& ice_config) {
ice_config_[TURN] = ice_config;
// Sets URL to fetch ICE config. If |oauth_token_getter| is not nullptr then
// it's used to get OAuth token for the ICE config request, otherwise the
// request is not authenticated.
void set_ice_config_url(const std::string& ice_config_url,
OAuthTokenGetter* oauth_token_getter) {
ice_config_url_ = ice_config_url;
oauth_token_getter_ = oauth_token_getter;
// Sets relay mode for all future calls of GetIceConfig(). Doesn't affect
// previous GetIceConfig() requests.
void set_relay_mode(RelayMode relay_mode) { relay_mode_ = relay_mode; }
// Prepares fresh JingleInfo. It may be called while connection is being
// negotiated to minimize the chance that the following GetIceConfig() will
// be blocking.
void Prepare();
// Requests fresh STUN and TURN information.
void GetIceConfig(const GetIceConfigCallback& callback);
PortAllocatorFactory* port_allocator_factory() {
return port_allocator_factory_.get();
UrlRequestFactory* url_request_factory() {
return url_request_factory_.get();
const NetworkSettings& network_settings() const { return network_settings_; }
TransportRole role() const { return role_; }
friend class base::RefCountedThreadSafe<TransportContext>;
void EnsureFreshIceConfig();
void OnIceConfig(RelayMode relay_mode, const IceConfig& ice_config);
SignalStrategy* signal_strategy_;
std::unique_ptr<PortAllocatorFactory> port_allocator_factory_;
std::unique_ptr<UrlRequestFactory> url_request_factory_;
NetworkSettings network_settings_;
TransportRole role_;
std::string ice_config_url_;
OAuthTokenGetter* oauth_token_getter_ = nullptr;
RelayMode relay_mode_ = RelayMode::GTURN;
std::array<std::unique_ptr<IceConfigRequest>, kNumRelayModes>
std::array<IceConfig, kNumRelayModes> ice_config_;
// When there is an active |ice_config_request_| stores list of callbacks to
// be called once the request is finished.
std::array<std::list<GetIceConfigCallback>, kNumRelayModes>
} // namespace protocol
} // namespace remoting