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
|
// Copyright 2020 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 "third_party/blink/renderer/modules/mediastream/pushable_media_stream_video_source.h"
#include "third_party/blink/public/mojom/mediastream/media_stream.mojom-blink.h"
#include "third_party/blink/renderer/modules/mediastream/media_stream_video_track_signal_observer.h"
#include "third_party/blink/renderer/platform/scheduler/public/post_cross_thread_task.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_functional.h"
namespace blink {
PushableMediaStreamVideoSource::PushableMediaStreamVideoSource(
const base::WeakPtr<MediaStreamVideoSource>& upstream_source)
: upstream_source_(upstream_source) {}
void PushableMediaStreamVideoSource::PushFrame(
scoped_refptr<media::VideoFrame> video_frame,
base::TimeTicks estimated_capture_time) {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
if (!running_)
return;
// Note that although use of the IO thread is rare in blink, it's required
// by any implementation of MediaStreamVideoSource, which is made clear by
// the documentation of MediaStreamVideoSource::StartSourceImpl which reads
// "An implementation must call |frame_callback| on the IO thread."
// Also see the DCHECK at VideoTrackAdapter::DeliverFrameOnIO
// and the other of implementations of MediaStreamVideoSource at
// MediaStreamRemoteVideoSource::StartSourceImpl,
// CastReceiverSession::StartVideo,
// CanvasCaptureHandler::SendFrame,
// and HtmlVideoElementCapturerSource::sendNewFrame.
PostCrossThreadTask(
*io_task_runner(), FROM_HERE,
CrossThreadBindOnce(deliver_frame_cb_, std::move(video_frame),
std::vector<scoped_refptr<media::VideoFrame>>(),
estimated_capture_time));
}
void PushableMediaStreamVideoSource::RequestRefreshFrame() {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
if (upstream_source_)
upstream_source_->RequestRefreshFrame();
if (signal_observer_)
signal_observer_->RequestFrame();
}
void PushableMediaStreamVideoSource::OnFrameDropped(
media::VideoCaptureFrameDropReason reason) {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
if (upstream_source_)
upstream_source_->OnFrameDropped(reason);
}
VideoCaptureFeedbackCB PushableMediaStreamVideoSource::GetFeedbackCallback()
const {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
if (upstream_source_) {
return WTF::BindRepeating(
[](const base::WeakPtr<MediaStreamVideoSource>& source,
const media::VideoFrameFeedback& feedback) {
if (!source)
return;
PushableMediaStreamVideoSource* pushable_source =
static_cast<PushableMediaStreamVideoSource*>(source.get());
pushable_source->GetInternalFeedbackCallback().Run(feedback);
},
GetWeakPtr());
}
return VideoCaptureFeedbackCB();
}
void PushableMediaStreamVideoSource::StartSourceImpl(
VideoCaptureDeliverFrameCB frame_callback,
EncodedVideoFrameCB encoded_frame_callback) {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
DCHECK(frame_callback);
running_ = true;
deliver_frame_cb_ = frame_callback;
OnStartDone(mojom::blink::MediaStreamRequestResult::OK);
}
void PushableMediaStreamVideoSource::StopSourceImpl() {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
running_ = false;
}
base::WeakPtr<MediaStreamVideoSource>
PushableMediaStreamVideoSource::GetWeakPtr() const {
return weak_factory_.GetWeakPtr();
}
VideoCaptureFeedbackCB
PushableMediaStreamVideoSource::GetInternalFeedbackCallback() const {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
if (!upstream_source_)
return VideoCaptureFeedbackCB();
return upstream_source_->GetFeedbackCallback();
}
void PushableMediaStreamVideoSource::SetSignalObserver(
MediaStreamVideoTrackSignalObserver* observer) {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
signal_observer_ = observer;
}
} // namespace blink
|
