aboutsummaryrefslogtreecommitdiff
path: root/cast/streaming/receiver_session.cc
diff options
context:
space:
mode:
authorJordan Bayles <jophba@chromium.org>2021-06-10 08:11:22 -0700
committerOpenscreen LUCI CQ <openscreen-scoped@luci-project-accounts.iam.gserviceaccount.com>2021-06-10 17:26:53 +0000
commit1a4e533d57c2b879704759cdffb2a00f71266346 (patch)
tree8e98f4417665fae38e86f3cd9e120e2e09204910 /cast/streaming/receiver_session.cc
parent94090603e69d7c63f3383038b0689bde6f968459 (diff)
downloadopenscreen-1a4e533d57c2b879704759cdffb2a00f71266346.tar.gz
[Cast Streaming] Messager -> Messenger
Messager, while being proper English, is archaic and generally not in use. This patch updates SessionMessager and its related types to be named SessionMessenger. Change-Id: I8d9caa685f86fa5863db56b4514a4d16ed5f1a33 Reviewed-on: https://chromium-review.googlesource.com/c/openscreen/+/2950433 Reviewed-by: Ryan Keane <rwkeane@google.com> Commit-Queue: Jordan Bayles <jophba@chromium.org>
Diffstat (limited to 'cast/streaming/receiver_session.cc')
-rw-r--r--cast/streaming/receiver_session.cc28
1 files changed, 14 insertions, 14 deletions
diff --git a/cast/streaming/receiver_session.cc b/cast/streaming/receiver_session.cc
index a9203734..c2a06d01 100644
--- a/cast/streaming/receiver_session.cc
+++ b/cast/streaming/receiver_session.cc
@@ -104,23 +104,23 @@ ReceiverSession::ReceiverSession(Client* const client,
environment_(environment),
preferences_(std::move(preferences)),
session_id_(MakeUniqueSessionId("streaming_receiver")),
- messager_(message_port,
- session_id_,
- [this](Error error) {
- OSP_DLOG_WARN << "Got a session messager error: " << error;
- client_->OnError(this, error);
- }),
+ messenger_(message_port,
+ session_id_,
+ [this](Error error) {
+ OSP_DLOG_WARN << "Got a session messenger error: " << error;
+ client_->OnError(this, error);
+ }),
packet_router_(environment_) {
OSP_DCHECK(client_);
OSP_DCHECK(environment_);
- messager_.SetHandler(
+ messenger_.SetHandler(
SenderMessage::Type::kOffer,
[this](SenderMessage message) { OnOffer(std::move(message)); });
- messager_.SetHandler(SenderMessage::Type::kGetCapabilities,
- [this](SenderMessage message) {
- OnCapabilitiesRequest(std::move(message));
- });
+ messenger_.SetHandler(SenderMessage::Type::kGetCapabilities,
+ [this](SenderMessage message) {
+ OnCapabilitiesRequest(std::move(message));
+ });
environment_->SetSocketSubscriber(this);
}
@@ -237,7 +237,7 @@ void ReceiverSession::OnCapabilitiesRequest(SenderMessage message) {
"Remoting is not supported"};
}
- const Error result = messager_.SendMessage(std::move(response));
+ const Error result = messenger_.SendMessage(std::move(response));
if (!result.ok()) {
client_->OnError(this, std::move(result));
}
@@ -256,7 +256,7 @@ void ReceiverSession::InitializeSession(const SessionProperties& properties) {
// Only spawn receivers if we know we have a valid answer message.
ConfiguredReceivers receivers = SpawnReceivers(properties);
client_->OnNegotiated(this, std::move(receivers));
- const Error result = messager_.SendMessage(ReceiverMessage{
+ const Error result = messenger_.SendMessage(ReceiverMessage{
ReceiverMessage::Type::kAnswer, properties.sequence_number,
true /* valid */, std::move(answer)});
if (!result.ok()) {
@@ -403,7 +403,7 @@ void ReceiverSession::SendErrorAnswerReply(int sequence_number,
const char* message) {
const Error error(Error::Code::kParseError, message);
OSP_DLOG_WARN << message;
- const Error result = messager_.SendMessage(ReceiverMessage{
+ const Error result = messenger_.SendMessage(ReceiverMessage{
ReceiverMessage::Type::kAnswer, sequence_number, false /* valid */,
ReceiverError{static_cast<int>(Error::Code::kParseError), message}});
if (!result.ok()) {