blob: 65593da51242c2c96688ea47a587dbffd582a843 (
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
|
// 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/peerconnection/rtc_encoded_video_frame.h"
#include <utility>
#include "third_party/blink/renderer/core/typed_arrays/dom_array_buffer.h"
#include "third_party/blink/renderer/modules/peerconnection/rtc_encoded_video_frame_delegate.h"
#include "third_party/blink/renderer/platform/wtf/text/string_builder.h"
#include "third_party/webrtc/api/frame_transformer_interface.h"
namespace blink {
RTCEncodedVideoFrame::RTCEncodedVideoFrame(
std::unique_ptr<webrtc::TransformableVideoFrameInterface> webrtc_frame)
: delegate_(base::MakeRefCounted<RTCEncodedVideoFrameDelegate>(
std::move(webrtc_frame))) {}
RTCEncodedVideoFrame::RTCEncodedVideoFrame(
scoped_refptr<RTCEncodedVideoFrameDelegate> delegate)
: delegate_(std::move(delegate)) {}
String RTCEncodedVideoFrame::type() const {
return delegate_->Type();
}
uint64_t RTCEncodedVideoFrame::timestamp() const {
return delegate_->Timestamp();
}
DOMArrayBuffer* RTCEncodedVideoFrame::data() const {
if (!frame_data_)
frame_data_ = delegate_->CreateDataBuffer();
return frame_data_;
}
DOMArrayBuffer* RTCEncodedVideoFrame::additionalData() const {
if (!additional_data_)
additional_data_ = delegate_->CreateAdditionalDataBuffer();
return additional_data_;
}
uint32_t RTCEncodedVideoFrame::synchronizationSource() const {
return delegate_->Ssrc();
}
void RTCEncodedVideoFrame::setData(DOMArrayBuffer* data) {
frame_data_ = data;
}
String RTCEncodedVideoFrame::toString() const {
if (!delegate_)
return "empty";
StringBuilder sb;
sb.Append("RTCEncodedVideoFrame{timestamp: ");
sb.AppendNumber(timestamp());
sb.Append("us, size: ");
sb.AppendNumber(data()->ByteLengthAsSizeT());
sb.Append(" bytes, type: ");
sb.Append(type());
sb.Append("}");
return sb.ToString();
}
void RTCEncodedVideoFrame::SyncDelegate() const {
delegate_->SetData(frame_data_);
}
scoped_refptr<RTCEncodedVideoFrameDelegate> RTCEncodedVideoFrame::Delegate()
const {
SyncDelegate();
return delegate_;
}
std::unique_ptr<webrtc::TransformableVideoFrameInterface>
RTCEncodedVideoFrame::PassWebRtcFrame() {
SyncDelegate();
return delegate_->PassWebRtcFrame();
}
void RTCEncodedVideoFrame::Trace(Visitor* visitor) {
ScriptWrappable::Trace(visitor);
visitor->Trace(frame_data_);
visitor->Trace(additional_data_);
}
} // namespace blink
|
