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
|
// Copyright 2015 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef REMOTING_PROTOCOL_WEBRTC_VIDEO_RENDERER_ADAPTER_H_
#define REMOTING_PROTOCOL_WEBRTC_VIDEO_RENDERER_ADAPTER_H_
#include <list>
#include <memory>
#include "base/functional/callback.h"
#include "base/memory/raw_ptr.h"
#include "base/memory/scoped_refptr.h"
#include "base/memory/weak_ptr.h"
#include "base/time/time.h"
#include "remoting/protocol/client_video_stats_dispatcher.h"
#include "remoting/protocol/video_stats_stub.h"
#include "third_party/webrtc/api/media_stream_interface.h"
#include "third_party/webrtc/api/video/video_sink_interface.h"
namespace base {
class SingleThreadTaskRunner;
} // namespace base
namespace webrtc {
class DesktopFrame;
class VideoFrameBuffer;
} // namespace webrtc
namespace remoting::protocol {
class MessagePipe;
class VideoRenderer;
struct ClientFrameStats;
struct HostFrameStats;
class WebrtcVideoRendererAdapter
: public webrtc::VideoSinkInterface<webrtc::VideoFrame>,
public VideoStatsStub,
public ClientVideoStatsDispatcher::EventHandler {
public:
WebrtcVideoRendererAdapter(const std::string& label,
VideoRenderer* video_renderer);
WebrtcVideoRendererAdapter(const WebrtcVideoRendererAdapter&) = delete;
WebrtcVideoRendererAdapter& operator=(const WebrtcVideoRendererAdapter&) =
delete;
~WebrtcVideoRendererAdapter() override;
std::string label() const { return label_; }
void SetMediaStream(
webrtc::scoped_refptr<webrtc::MediaStreamInterface> media_stream);
void SetVideoStatsChannel(std::unique_ptr<MessagePipe> message_pipe);
// webrtc::VideoSinkInterface implementation.
void OnFrame(const webrtc::VideoFrame& frame) override;
private:
// VideoStatsStub interface.
void OnVideoFrameStats(uint32_t frame_id,
const HostFrameStats& frame_stats) override;
// ClientVideoStatsDispatcher::EventHandler interface.
void OnChannelInitialized(ChannelDispatcherBase* channel_dispatcher) override;
void OnChannelClosed(ChannelDispatcherBase* channel_dispatcher) override;
void HandleFrameOnMainThread(uint32_t frame_id,
base::TimeTicks time_received,
scoped_refptr<webrtc::VideoFrameBuffer> frame);
void DrawFrame(uint32_t frame_id,
std::unique_ptr<ClientFrameStats> stats,
std::unique_ptr<webrtc::DesktopFrame> frame);
void FrameRendered(uint32_t frame_id,
std::unique_ptr<ClientFrameStats> stats);
std::string label_;
webrtc::scoped_refptr<webrtc::MediaStreamInterface> media_stream_;
raw_ptr<VideoRenderer> video_renderer_;
std::unique_ptr<ClientVideoStatsDispatcher> video_stats_dispatcher_;
scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
std::list<std::pair<uint32_t, ClientFrameStats>> client_stats_queue_;
std::list<std::pair<uint32_t, HostFrameStats>> host_stats_queue_;
base::WeakPtrFactory<WebrtcVideoRendererAdapter> weak_factory_{this};
};
} // namespace remoting::protocol
#endif // REMOTING_PROTOCOL_WEBRTC_VIDEO_RENDERER_ADAPTER_H_
|
