blob: ca69d1f23dc6abbc3156eb749ef9f32fdc99ebda (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
// 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.
#ifndef REMOTING_PROTOCOL_ICE_TRANSPORT_CHANNEL_H_
#define REMOTING_PROTOCOL_ICE_TRANSPORT_CHANNEL_H_
#include <string>
#include "base/callback_forward.h"
#include "base/macros.h"
#include "base/threading/thread_checker.h"
#include "base/timer/timer.h"
#include "remoting/protocol/network_settings.h"
#include "remoting/protocol/transport.h"
#include "third_party/webrtc/base/sigslot.h"
namespace cricket {
class Candidate;
class P2PTransportChannel;
class PortAllocator;
class TransportChannel;
class TransportChannelImpl;
} // namespace cricket
namespace remoting {
namespace protocol {
class TransportContext;
class IceTransportChannel : public sigslot::has_slots<> {
public:
class Delegate {
public:
Delegate() {};
virtual ~Delegate() {};
// Called to pass ICE credentials to the session. Used only for STANDARD
// version of ICE, see SetIceVersion().
virtual void OnChannelIceCredentials(IceTransportChannel* transport,
const std::string& ufrag,
const std::string& password) = 0;
// Called when the transport generates a new candidate that needs
// to be passed to the AddRemoteCandidate() method on the remote
// end of the connection.
virtual void OnChannelCandidate(IceTransportChannel* transport,
const cricket::Candidate& candidate) = 0;
// Called when transport route changes. Can be called even before
// the transport is connected.
virtual void OnChannelRouteChange(IceTransportChannel* transport,
const TransportRoute& route) = 0;
// Called when when the channel has failed to connect or reconnect.
virtual void OnChannelFailed(IceTransportChannel* transport) = 0;
// Called when the channel is about to be deleted.
virtual void OnChannelDeleted(IceTransportChannel* transport) = 0;
};
typedef base::Callback<void(scoped_ptr<P2PDatagramSocket>)> ConnectedCallback;
explicit IceTransportChannel(
scoped_refptr<TransportContext> transport_context);
~IceTransportChannel() override;
// Connects the channel and calls the |callback| after that.
void Connect(const std::string& name,
Delegate* delegate,
const ConnectedCallback& callback);
// Sets remote ICE credentials.
void SetRemoteCredentials(const std::string& ufrag,
const std::string& password);
// Adds |candidate| received from the peer.
void AddRemoteCandidate(const cricket::Candidate& candidate);
// Name of the channel. Used to identify the channel and disambiguate
// candidates it generates from candidates generated by parallel connections.
const std::string& name() const;
// Returns true if the channel is already connected.
bool is_connected() const;
private:
void OnPortAllocatorCreated(
scoped_ptr<cricket::PortAllocator> port_allocator);
void NotifyConnected();
// Signal handlers for cricket::TransportChannel.
void OnCandidateGathered(cricket::TransportChannelImpl* channel,
const cricket::Candidate& candidate);
void OnRouteChange(cricket::TransportChannel* channel,
const cricket::Candidate& candidate);
void OnWritableState(cricket::TransportChannel* channel);
// Callback for TransportChannelSocketAdapter to notify when the socket is
// destroyed.
void OnChannelDestroyed();
void NotifyRouteChanged();
// Tries to connect by restarting ICE. Called by |reconnect_timer_|.
void TryReconnect();
scoped_refptr<TransportContext> transport_context_;
std::string name_;
Delegate* delegate_ = nullptr;
ConnectedCallback callback_;
std::string ice_username_fragment_;
scoped_ptr<cricket::PortAllocator> port_allocator_;
std::string remote_ice_username_fragment_;
std::string remote_ice_password_;
std::list<cricket::Candidate> pending_candidates_;
scoped_ptr<cricket::P2PTransportChannel> channel_;
int connect_attempts_left_;
base::RepeatingTimer reconnect_timer_;
base::ThreadChecker thread_checker_;
base::WeakPtrFactory<IceTransportChannel> weak_factory_;
DISALLOW_COPY_AND_ASSIGN(IceTransportChannel);
};
} // namespace protocol
} // namespace remoting
#endif // REMOTING_PROTOCOL_ICE_TRANSPORT_CHANNEL_H_
|
