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
|
// 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.
#include "third_party/blink/renderer/modules/peerconnection/adapters/ice_transport_proxy.h"
#include <utility>
#include "base/task/single_thread_task_runner.h"
#include "third_party/blink/renderer/core/frame/local_frame.h"
#include "third_party/blink/renderer/modules/peerconnection/adapters/ice_transport_host.h"
#include "third_party/blink/renderer/modules/peerconnection/adapters/web_rtc_cross_thread_copier.h"
#include "third_party/blink/renderer/platform/scheduler/public/post_cross_thread_task.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_copier_std.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_functional.h"
namespace blink {
IceTransportProxy::IceTransportProxy(
LocalFrame& frame,
scoped_refptr<base::SingleThreadTaskRunner> proxy_thread,
scoped_refptr<base::SingleThreadTaskRunner> host_thread,
Delegate* delegate,
std::unique_ptr<IceTransportAdapterCrossThreadFactory> adapter_factory)
: proxy_thread_(std::move(proxy_thread)),
host_thread_(std::move(host_thread)),
host_(nullptr, base::OnTaskRunnerDeleter(host_thread_)),
delegate_(delegate),
feature_handle_for_scheduler_(frame.GetFrameScheduler()->RegisterFeature(
SchedulingPolicy::Feature::kWebRTC,
{SchedulingPolicy::DisableAggressiveThrottling(),
SchedulingPolicy::DisableAlignWakeUps()})) {
DCHECK(host_thread_);
DCHECK(delegate_);
DCHECK(adapter_factory);
DCHECK(proxy_thread_->BelongsToCurrentThread());
adapter_factory->InitializeOnMainThread(frame);
// Wait to initialize the host until the weak_ptr_factory_ is initialized.
// The IceTransportHost is constructed on the proxy thread but should only be
// interacted with via PostTask to the host thread. The OnTaskRunnerDeleter
// (configured above) will ensure it gets deleted on the host thread.
host_.reset(new IceTransportHost(proxy_thread_, host_thread_,
weak_ptr_factory_.GetWeakPtr()));
PostCrossThreadTask(*host_thread_, FROM_HERE,
CrossThreadBindOnce(&IceTransportHost::Initialize,
CrossThreadUnretained(host_.get()),
std::move(adapter_factory)));
}
IceTransportProxy::~IceTransportProxy() {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
// Note: The IceTransportHost will be deleted on the host thread.
}
scoped_refptr<base::SingleThreadTaskRunner> IceTransportProxy::proxy_thread()
const {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
return proxy_thread_;
}
scoped_refptr<base::SingleThreadTaskRunner> IceTransportProxy::host_thread()
const {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
return host_thread_;
}
void IceTransportProxy::OnGatheringStateChanged(
webrtc::IceGatheringState new_state) {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
delegate_->OnGatheringStateChanged(new_state);
}
void IceTransportProxy::OnCandidateGathered(
const webrtc::Candidate& candidate) {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
delegate_->OnCandidateGathered(candidate);
}
void IceTransportProxy::OnStateChanged(webrtc::IceTransportState new_state) {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
delegate_->OnStateChanged(new_state);
}
void IceTransportProxy::OnSelectedCandidatePairChanged(
const std::pair<webrtc::Candidate, webrtc::Candidate>&
selected_candidate_pair) {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
delegate_->OnSelectedCandidatePairChanged(selected_candidate_pair);
}
} // namespace blink
|
