blob: 1566f0a7ab865c0970f9b51cdec1608aa611b767 (
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
92
93
94
95
|
// Copyright 2021 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 "cast/standalone_sender/remoting_sender.h"
#include <utility>
#include "cast/streaming/message_fields.h"
namespace openscreen {
namespace cast {
namespace {
VideoDecoderConfig::Codec ToProtoCodec(VideoCodec value) {
switch (value) {
case VideoCodec::kHevc:
return VideoDecoderConfig_Codec_kCodecHEVC;
case VideoCodec::kH264:
return VideoDecoderConfig_Codec_kCodecH264;
case VideoCodec::kVp8:
return VideoDecoderConfig_Codec_kCodecVP8;
case VideoCodec::kVp9:
return VideoDecoderConfig_Codec_kCodecVP9;
default:
return VideoDecoderConfig_Codec_kUnknownVideoCodec;
}
}
AudioDecoderConfig::Codec ToProtoCodec(AudioCodec value) {
switch (value) {
case AudioCodec::kAac:
return AudioDecoderConfig_Codec_kCodecAAC;
case AudioCodec::kOpus:
return AudioDecoderConfig_Codec_kCodecOpus;
default:
return AudioDecoderConfig_Codec_kUnknownAudioCodec;
}
}
} // namespace
RemotingSender::RemotingSender(RpcMessenger* messenger,
AudioCodec audio_codec,
VideoCodec video_codec,
ReadyCallback ready_cb)
: messenger_(messenger),
audio_codec_(audio_codec),
video_codec_(video_codec),
ready_cb_(std::move(ready_cb)) {
messenger_->RegisterMessageReceiverCallback(
RpcMessenger::kAcquireRendererHandle,
[this](std::unique_ptr<RpcMessage> message) {
OSP_DCHECK(message);
this->OnInitializeMessage(*message);
});
}
RemotingSender::~RemotingSender() {
messenger_->UnregisterMessageReceiverCallback(
RpcMessenger::kAcquireRendererHandle);
}
void RemotingSender::OnInitializeMessage(const RpcMessage& message) {
receiver_handle_ = message.integer_value();
RpcMessage callback_message;
callback_message.set_handle(receiver_handle_);
callback_message.set_proc(RpcMessage::RPC_DS_INITIALIZE_CALLBACK);
auto* callback_body =
callback_message.mutable_demuxerstream_initializecb_rpc();
// In Chrome, separate calls are used for the audio and video configs, but
// for simplicity's sake we combine them here.
callback_body->mutable_audio_decoder_config()->set_codec(
ToProtoCodec(audio_codec_));
callback_body->mutable_video_decoder_config()->set_codec(
ToProtoCodec(video_codec_));
OSP_DLOG_INFO << "Initializing receiver handle " << receiver_handle_
<< " with audio codec " << CodecToString(audio_codec_)
<< " and video codec " << CodecToString(video_codec_);
messenger_->SendMessageToRemote(callback_message);
if (ready_cb_) {
ready_cb_();
} else {
OSP_DLOG_INFO << "Received a ready message, but no ready callback.";
}
}
} // namespace cast
} // namespace openscreen
|
