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
154
155
156
157
158
159
160
161
|
// 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.
#ifndef THIRD_PARTY_BLINK_RENDERER_MODULES_MEDIASTREAM_TRANSFERRED_MEDIA_STREAM_TRACK_H_
#define THIRD_PARTY_BLINK_RENDERER_MODULES_MEDIASTREAM_TRANSFERRED_MEDIA_STREAM_TRACK_H_
#include "build/build_config.h"
#include "third_party/blink/renderer/bindings/core/v8/active_script_wrappable.h"
#include "third_party/blink/renderer/bindings/core/v8/script_promise.h"
#include "third_party/blink/renderer/bindings/modules/v8/v8_capture_handle.h"
#include "third_party/blink/renderer/core/dom/events/native_event_listener.h"
#include "third_party/blink/renderer/modules/event_target_modules.h"
#include "third_party/blink/renderer/modules/mediastream/media_stream_track.h"
#include "third_party/blink/renderer/modules/modules_export.h"
#include "third_party/blink/renderer/platform/heap/collection_support/heap_deque.h"
#include "third_party/blink/renderer/platform/heap/collection_support/heap_hash_set.h"
#include "third_party/blink/renderer/platform/heap/garbage_collected.h"
#include "third_party/blink/renderer/platform/mediastream/media_stream_descriptor.h"
#include "third_party/blink/renderer/platform/mediastream/media_stream_source.h"
#include "third_party/blink/renderer/platform/mediastream/transferred_media_stream_component.h"
#include "third_party/blink/renderer/platform/scheduler/public/frame_scheduler.h"
#include "third_party/blink/renderer/platform/wtf/deque.h"
#include "third_party/blink/renderer/platform/wtf/forward.h"
#include "third_party/blink/renderer/platform/wtf/text/wtf_string.h"
namespace blink {
class MediaTrackCapabilities;
class MediaTrackConstraints;
class MediaTrackSettings;
class ScriptState;
// A MediaStreamTrack implementation synchronously created when receiving a
// transferred MediaStreamTrack, when the full instance is being asynchronously
// created. Once the asynchronous setup has finished, proxies all calls to the
// full instance.
class MODULES_EXPORT TransferredMediaStreamTrack : public MediaStreamTrack {
public:
TransferredMediaStreamTrack(ExecutionContext* execution_context,
const TransferredValues& data);
// MediaStreamTrack.idl
String kind() const override;
String id() const override;
String label() const override;
bool enabled() const override;
void setEnabled(bool) override;
bool muted() const override;
String ContentHint() const override;
void SetContentHint(const String&) override;
V8MediaStreamTrackState readyState() const override;
MediaStreamTrack* clone(ExecutionContext*) override;
void stopTrack(ExecutionContext*) override;
MediaTrackCapabilities* getCapabilities() const override;
MediaTrackConstraints* getConstraints() const override;
MediaTrackSettings* getSettings() const override;
V8UnionMediaStreamTrackAudioStatsOrMediaStreamTrackVideoStats* stats()
override;
CaptureHandle* getCaptureHandle() const override;
ScriptPromise<IDLUndefined> applyConstraints(
ScriptState*,
const MediaTrackConstraints*) override;
bool HasImplementation() const { return !!track_; }
// TODO(1288839): access to track_ is a baby-step toward removing
// TransferredMediaStreamTrack.
MediaStreamTrack* track() const { return track_.Get(); }
void SetImplementation(MediaStreamTrack* track);
void SetComponentImplementation(MediaStreamComponent* component);
void SetInitialConstraints(const MediaConstraints&) override;
void SetConstraints(const MediaConstraints&) override;
DEFINE_ATTRIBUTE_EVENT_LISTENER(mute, kMute)
DEFINE_ATTRIBUTE_EVENT_LISTENER(unmute, kUnmute)
DEFINE_ATTRIBUTE_EVENT_LISTENER(ended, kEnded)
DEFINE_ATTRIBUTE_EVENT_LISTENER(capturehandlechange, kCapturehandlechange)
MediaStreamSource::ReadyState GetReadyState() override;
MediaStreamComponent* Component() const override;
bool Ended() const override;
void RegisterMediaStream(MediaStream*) override;
void UnregisterMediaStream(MediaStream*) override;
void RegisterSink(SpeechRecognitionMediaStreamAudioSink*) override;
// EventTarget
const AtomicString& InterfaceName() const override;
ExecutionContext* GetExecutionContext() const override;
void AddedEventListener(const AtomicString&,
RegisteredEventListener&) override;
// ScriptWrappable
bool HasPendingActivity() const override;
std::unique_ptr<AudioSourceProvider> CreateWebAudioSource(
int context_sample_rate,
base::TimeDelta platform_buffer_duration) override;
ImageCapture* GetImageCapture() override;
std::optional<const MediaStreamDevice> device() const override;
void BeingTransferred(const base::UnguessableToken& transfer_id) override;
bool TransferAllowed(String& message) const override;
void AddObserver(Observer*) override;
void Trace(Visitor*) const override;
private:
// Enumerates function names which can change the state of MediaStreamTrack.
enum SetterFunction {
APPLY_CONSTRAINTS,
SET_CONTENT_HINT,
SET_ENABLED,
CLONE
};
void applyConstraints(ScriptPromiseResolver<IDLUndefined>*,
const MediaTrackConstraints*) override;
// Helper class to register as an event listener on the underlying
// MediaStreamTrack and re-dispatch any fired events on the wrapping
// TransferredMediaStreamTrack.
class EventPropagator : public NativeEventListener {
public:
EventPropagator(MediaStreamTrack* underlying_track,
TransferredMediaStreamTrack* transferred_track);
void Invoke(ExecutionContext*, Event* event) override;
void Trace(Visitor*) const override;
private:
Member<TransferredMediaStreamTrack> transferred_track_;
};
struct ConstraintsPair : GarbageCollected<ConstraintsPair> {
ConstraintsPair(ScriptPromiseResolver<IDLUndefined>* resolver,
const MediaTrackConstraints* constraints);
void Trace(Visitor*) const;
const Member<ScriptPromiseResolver<IDLUndefined>> resolver;
const Member<const MediaTrackConstraints> constraints;
};
Member<TransferredMediaStreamComponent> transferred_component_;
Member<MediaStreamTrack> track_;
Vector<SetterFunction> setter_call_order_;
WTF::Deque<String> content_hint_list_;
HeapDeque<Member<ConstraintsPair>> constraints_list_;
WTF::Deque<bool> enabled_state_list_;
HeapDeque<Member<TransferredMediaStreamTrack>> clone_list_;
WeakMember<ExecutionContext> execution_context_;
TransferredValues data_;
Member<EventPropagator> event_propagator_;
HeapHashSet<WeakMember<MediaStreamTrack::Observer>> observers_;
};
} // namespace blink
#endif // THIRD_PARTY_BLINK_RENDERER_MODULES_MEDIASTREAM_TRANSFERRED_MEDIA_STREAM_TRACK_H_
|
