| Index: mojo/public/cpp/bindings/lib/pipe_control_message_proxy.cc
|
| diff --git a/mojo/public/cpp/bindings/lib/pipe_control_message_proxy.cc b/mojo/public/cpp/bindings/lib/pipe_control_message_proxy.cc
|
| index 21a4d5ed7c963dcbd2d9eb341a2b5b350055eb33..492bc02d85a133eddd5be08aa8fa81bbea821277 100644
|
| --- a/mojo/public/cpp/bindings/lib/pipe_control_message_proxy.cc
|
| +++ b/mojo/public/cpp/bindings/lib/pipe_control_message_proxy.cc
|
| @@ -9,6 +9,7 @@
|
|
|
| #include "base/compiler_specific.h"
|
| #include "mojo/public/cpp/bindings/lib/message_builder.h"
|
| +#include "mojo/public/cpp/bindings/lib/serialization.h"
|
| #include "mojo/public/cpp/bindings/message.h"
|
| #include "mojo/public/interfaces/bindings/pipe_control_messages.mojom.h"
|
|
|
| @@ -17,16 +18,20 @@ namespace internal {
|
| namespace {
|
|
|
| void SendRunOrClosePipeMessage(MessageReceiver* receiver,
|
| - pipe_control::RunOrClosePipeInputPtr input) {
|
| + pipe_control::RunOrClosePipeInputPtr input,
|
| + SerializationContext* context) {
|
| pipe_control::RunOrClosePipeMessageParamsPtr params_ptr(
|
| pipe_control::RunOrClosePipeMessageParams::New());
|
| params_ptr->input = std::move(input);
|
|
|
| - size_t size = GetSerializedSize_(params_ptr, nullptr);
|
| + size_t size =
|
| + PrepareToSerialize<pipe_control::RunOrClosePipeMessageParamsPtr>(
|
| + params_ptr, context);
|
| MessageBuilder builder(pipe_control::kRunOrClosePipeMessageId, size);
|
|
|
| pipe_control::internal::RunOrClosePipeMessageParams_Data* params = nullptr;
|
| - Serialize_(std::move(params_ptr), builder.buffer(), ¶ms, nullptr);
|
| + Serialize<pipe_control::RunOrClosePipeMessageParamsPtr>(
|
| + params_ptr, builder.buffer(), ¶ms, context);
|
| params->EncodePointers();
|
| builder.message()->set_interface_id(kInvalidInterfaceId);
|
| bool ok = receiver->Accept(builder.message());
|
| @@ -49,7 +54,7 @@ void PipeControlMessageProxy::NotifyPeerEndpointClosed(InterfaceId id) {
|
| pipe_control::RunOrClosePipeInput::New());
|
| input->set_peer_associated_endpoint_closed_event(std::move(event));
|
|
|
| - SendRunOrClosePipeMessage(receiver_, std::move(input));
|
| + SendRunOrClosePipeMessage(receiver_, std::move(input), &context_);
|
| }
|
|
|
| void PipeControlMessageProxy::NotifyEndpointClosedBeforeSent(InterfaceId id) {
|
| @@ -61,7 +66,7 @@ void PipeControlMessageProxy::NotifyEndpointClosedBeforeSent(InterfaceId id) {
|
| pipe_control::RunOrClosePipeInput::New());
|
| input->set_associated_endpoint_closed_before_sent_event(std::move(event));
|
|
|
| - SendRunOrClosePipeMessage(receiver_, std::move(input));
|
| + SendRunOrClosePipeMessage(receiver_, std::move(input), &context_);
|
| }
|
|
|
| } // namespace internal
|
|
|