diff options
author | Jordan Bayles <jophba@chromium.org> | 2021-06-10 08:11:22 -0700 |
---|---|---|
committer | Openscreen LUCI CQ <openscreen-scoped@luci-project-accounts.iam.gserviceaccount.com> | 2021-06-10 17:26:53 +0000 |
commit | 1a4e533d57c2b879704759cdffb2a00f71266346 (patch) | |
tree | 8e98f4417665fae38e86f3cd9e120e2e09204910 /cast/streaming/receiver_session.cc | |
parent | 94090603e69d7c63f3383038b0689bde6f968459 (diff) | |
download | openscreen-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.cc | 28 |
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()) { |