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
|
// Copyright 2022 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/webrtc_video_perf_reporter.h"
#include "base/check.h"
#include "base/task/single_thread_task_runner.h"
#include "media/base/video_codecs.h"
#include "third_party/blink/renderer/platform/heap/cross_thread_handle.h"
namespace blink {
WebrtcVideoPerfReporter::WebrtcVideoPerfReporter(
scoped_refptr<base::SingleThreadTaskRunner> task_runner,
ContextLifecycleNotifier* notifier,
mojo::PendingRemote<media::mojom::blink::WebrtcVideoPerfRecorder>
perf_recorder)
: task_runner_(task_runner),
perf_recorder_(notifier),
weak_handle_(MakeCrossThreadWeakHandle(this)) {
DCHECK(task_runner_->RunsTasksInCurrentSequence());
perf_recorder_.Bind(std::move(perf_recorder), task_runner_);
}
void WebrtcVideoPerfReporter::StoreWebrtcVideoStats(
const StatsCollector::StatsKey& stats_key,
const StatsCollector::VideoStats& video_stats) {
DCHECK(task_runner_);
task_runner_->PostTask(
FROM_HERE,
base::BindOnce(
&WebrtcVideoPerfReporter::StoreWebrtcVideoStatsOnTaskRunner,
MakeUnwrappingCrossThreadWeakHandle(weak_handle_), stats_key,
video_stats));
}
void WebrtcVideoPerfReporter::StoreWebrtcVideoStatsOnTaskRunner(
const StatsCollector::StatsKey& stats_key,
const StatsCollector::VideoStats& video_stats) {
DCHECK(task_runner_);
DCHECK(task_runner_->RunsTasksInCurrentSequence());
if (!perf_recorder_.is_bound()) {
return;
}
auto mojo_features = media::mojom::blink::WebrtcPredictionFeatures::New(
stats_key.is_decode,
static_cast<media::mojom::blink::VideoCodecProfile>(
stats_key.codec_profile),
stats_key.pixel_size, stats_key.hw_accelerated);
auto mojo_video_stats = media::mojom::blink::WebrtcVideoStats::New(
video_stats.frame_count, video_stats.key_frame_count,
video_stats.p99_processing_time_ms);
perf_recorder_->UpdateRecord(std::move(mojo_features),
std::move(mojo_video_stats));
}
} // namespace blink
|
