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
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
// Copyright 2018 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef THIRD_PARTY_BLINK_RENDERER_MODULES_PEERCONNECTION_RTC_ICE_TRANSPORT_H_
#define THIRD_PARTY_BLINK_RENDERER_MODULES_PEERCONNECTION_RTC_ICE_TRANSPORT_H_
#include <memory>
#include <utility>
#include "base/task/single_thread_task_runner.h"
#include "third_party/blink/renderer/bindings/core/v8/active_script_wrappable.h"
#include "third_party/blink/renderer/bindings/modules/v8/v8_rtc_ice_candidate_pair.h"
#include "third_party/blink/renderer/bindings/modules/v8/v8_rtc_ice_parameters.h"
#include "third_party/blink/renderer/core/execution_context/execution_context_lifecycle_observer.h"
#include "third_party/blink/renderer/modules/event_target_modules.h"
#include "third_party/blink/renderer/modules/peerconnection/adapters/ice_transport_proxy.h"
#include "third_party/blink/renderer/platform/heap/prefinalizer.h"
#include "third_party/blink/renderer/platform/scheduler/public/frame_scheduler.h"
#include "third_party/webrtc/api/transport/enums.h"
namespace webrtc {
class IceTransportInterface;
}
namespace blink {
class ExceptionState;
class IceTransportAdapterCrossThreadFactory;
class RTCIceCandidate;
class RTCPeerConnection;
class V8RTCIceGatheringState;
class V8RTCIceRole;
class V8RTCIceTransportState;
// Blink bindings for the RTCIceTransport JavaScript object.
//
// This class uses the IceTransportProxy to run and interact with the WebRTC
// ICE implementation running on the WebRTC worker thread managed by //content
// (called network_thread here).
//
// This object inherits from ActiveScriptWrappable since it must be kept alive
// while the ICE implementation is active, regardless of the number of
// JavaScript references held to it.
class MODULES_EXPORT RTCIceTransport final
: public EventTarget,
public ActiveScriptWrappable<RTCIceTransport>,
public ExecutionContextLifecycleObserver,
public IceTransportProxy::Delegate {
DEFINE_WRAPPERTYPEINFO();
USING_PRE_FINALIZER(RTCIceTransport, Dispose);
public:
enum class CloseReason {
// stop() was called.
kStopped,
// The ExecutionContext is being destroyed.
kContextDestroyed,
// The object is being garbage collected.
kDisposed,
};
static RTCIceTransport* Create(
ExecutionContext* context,
webrtc::scoped_refptr<webrtc::IceTransportInterface>
ice_transport_channel,
RTCPeerConnection* peer_connection);
RTCIceTransport(
ExecutionContext* context,
scoped_refptr<base::SingleThreadTaskRunner> proxy_thread,
scoped_refptr<base::SingleThreadTaskRunner> host_thread,
std::unique_ptr<IceTransportAdapterCrossThreadFactory> adapter_factory,
RTCPeerConnection* peer_connection);
~RTCIceTransport() override;
// Returns true if start() has been called.
bool IsStarted() const { return role_ != webrtc::ICEROLE_UNKNOWN; }
// Returns the role specified in start().
webrtc::IceRole GetRole() const { return role_; }
webrtc::IceTransportState GetState() const { return state_; }
// Returns true if the RTCIceTransport is in a terminal state.
bool IsClosed() const { return state_ == webrtc::IceTransportState::kClosed; }
void Stop() { Close(CloseReason::kStopped); }
// rtc_ice_transport.idl
std::optional<V8RTCIceRole> role() const;
V8RTCIceTransportState state() const;
V8RTCIceGatheringState gatheringState() const;
const HeapVector<Member<RTCIceCandidate>>& getLocalCandidates() const;
const HeapVector<Member<RTCIceCandidate>>& getRemoteCandidates() const;
RTCIceCandidatePair* getSelectedCandidatePair() const;
RTCIceParameters* getLocalParameters() const;
RTCIceParameters* getRemoteParameters() const;
DEFINE_ATTRIBUTE_EVENT_LISTENER(statechange, kStatechange)
DEFINE_ATTRIBUTE_EVENT_LISTENER(gatheringstatechange, kGatheringstatechange)
DEFINE_ATTRIBUTE_EVENT_LISTENER(selectedcandidatepairchange,
kSelectedcandidatepairchange)
// EventTarget overrides.
const AtomicString& InterfaceName() const override;
ExecutionContext* GetExecutionContext() const override;
// ExecutionContextLifecycleObserver overrides.
void ContextDestroyed() override;
// ActiveScriptWrappable overrides.
bool HasPendingActivity() const final;
// For garbage collection.
void Trace(Visitor* visitor) const override;
private:
// IceTransportProxy::Delegate overrides.
void OnGatheringStateChanged(webrtc::IceGatheringState new_state) override;
void OnCandidateGathered(const webrtc::Candidate& candidate) override;
void OnStateChanged(webrtc::IceTransportState new_state) override;
void OnSelectedCandidatePairChanged(
const std::pair<webrtc::Candidate, webrtc::Candidate>&
selected_candidate_pair) override;
// Permenantly closes the RTCIceTransport with the given reason.
// The RTCIceTransport must not already be closed.
// This will transition the state to closed.
void Close(CloseReason reason);
bool RaiseExceptionIfClosed(ExceptionState& exception_state) const;
void Dispose();
webrtc::IceRole role_ = webrtc::ICEROLE_UNKNOWN;
webrtc::IceTransportState state_ = webrtc::IceTransportState::kNew;
webrtc::IceGatheringState gathering_state_ = webrtc::kIceGatheringNew;
HeapVector<Member<RTCIceCandidate>> local_candidates_;
HeapVector<Member<RTCIceCandidate>> remote_candidates_;
Member<RTCIceParameters> local_parameters_;
Member<RTCIceParameters> remote_parameters_;
Member<RTCIceCandidatePair> selected_candidate_pair_;
const WeakMember<RTCPeerConnection> peer_connection_;
// Handle to the WebRTC ICE transport. Created when this binding is
// constructed and deleted once network traffic should be stopped.
std::unique_ptr<IceTransportProxy> proxy_;
};
} // namespace blink
#endif // THIRD_PARTY_BLINK_RENDERER_MODULES_PEERCONNECTION_RTC_ICE_TRANSPORT_H_
|
