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
|
// Copyright 2013 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 "chrome/renderer/media/cast_session_delegate.h"
#include "base/logging.h"
#include "base/message_loop/message_loop_proxy.h"
#include "content/public/renderer/render_thread.h"
#include "media/cast/cast_environment.h"
#include "media/cast/cast_sender.h"
using media::cast::AudioSenderConfig;
using media::cast::CastEnvironment;
using media::cast::CastSender;
using media::cast::VideoSenderConfig;
CastSessionDelegate::CastSessionDelegate()
: audio_encode_thread_("CastAudioEncodeThread"),
video_encode_thread_("CastVideoEncodeThread"),
audio_configured_(false),
video_configured_(false),
io_message_loop_proxy_(
content::RenderThread::Get()->GetIOMessageLoopProxy()) {
}
CastSessionDelegate::~CastSessionDelegate() {
DCHECK(io_message_loop_proxy_->BelongsToCurrentThread());
}
void CastSessionDelegate::StartAudio(const AudioSenderConfig& config) {
DCHECK(io_message_loop_proxy_->BelongsToCurrentThread());
audio_configured_ = true;
audio_config_ = config;
MaybeStartSending();
}
void CastSessionDelegate::StartVideo(const VideoSenderConfig& config) {
DCHECK(io_message_loop_proxy_->BelongsToCurrentThread());
video_configured_ = true;
video_config_ = config;
MaybeStartSending();
}
void CastSessionDelegate::StartSending() {
DCHECK(io_message_loop_proxy_->BelongsToCurrentThread());
if (cast_environment_)
return;
audio_encode_thread_.Start();
video_encode_thread_.Start();
// CastSender uses the renderer's IO thread as the main thread. This reduces
// thread hopping for incoming video frames and outgoing network packets.
// There's no need to decode so no thread assigned for decoding.
cast_environment_ = new CastEnvironment(
&clock_,
base::MessageLoopProxy::current(),
audio_encode_thread_.message_loop_proxy(),
NULL,
video_encode_thread_.message_loop_proxy(),
NULL);
// TODO(hclam): A couple things need to be done here:
// 1. Connect media::cast::PacketSender to net::Socket interface.
// 2. Implement VideoEncoderController to configure hardware encoder.
cast_sender_.reset(CastSender::CreateCastSender(
cast_environment_,
audio_config_,
video_config_,
NULL,
NULL));
}
void CastSessionDelegate::MaybeStartSending() {
if (!audio_configured_ || !video_configured_)
return;
StartSending();
}
|
