| Index: mojo/public/cpp/bindings/lib/control_message_proxy.cc
|
| diff --git a/mojo/public/cpp/bindings/lib/control_message_proxy.cc b/mojo/public/cpp/bindings/lib/control_message_proxy.cc
|
| index ed27c070fe07ab3382ff3113605b366d0d8908cc..6189e6973e792f691b9a94fb8cdc7ec329062273 100644
|
| --- a/mojo/public/cpp/bindings/lib/control_message_proxy.cc
|
| +++ b/mojo/public/cpp/bindings/lib/control_message_proxy.cc
|
| @@ -10,6 +10,7 @@
|
|
|
| #include "base/macros.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/interface_control_messages.mojom.h"
|
|
|
| @@ -38,7 +39,8 @@ bool RunResponseForwardToCallback::Accept(Message* message) {
|
| params->DecodePointers();
|
|
|
| RunResponseMessageParamsPtr params_ptr;
|
| - Deserialize_(params, ¶ms_ptr, nullptr);
|
| + SerializationContext context;
|
| + Deserialize<RunResponseMessageParamsPtr>(params, ¶ms_ptr, &context);
|
|
|
| callback_.Run(std::move(params_ptr->query_version_result));
|
| return true;
|
| @@ -46,17 +48,19 @@ bool RunResponseForwardToCallback::Accept(Message* message) {
|
|
|
| void SendRunMessage(MessageReceiverWithResponder* receiver,
|
| QueryVersionPtr query_version,
|
| - const RunCallback& callback) {
|
| + const RunCallback& callback,
|
| + SerializationContext* context) {
|
| RunMessageParamsPtr params_ptr(RunMessageParams::New());
|
| params_ptr->reserved0 = 16u;
|
| params_ptr->reserved1 = 0u;
|
| params_ptr->query_version = std::move(query_version);
|
|
|
| - size_t size = GetSerializedSize_(params_ptr, nullptr);
|
| + size_t size = PrepareToSerialize<RunMessageParamsPtr>(params_ptr, context);
|
| RequestMessageBuilder builder(kRunMessageId, size);
|
|
|
| RunMessageParams_Data* params = nullptr;
|
| - Serialize_(std::move(params_ptr), builder.buffer(), ¶ms, nullptr);
|
| + Serialize<RunMessageParamsPtr>(params_ptr, builder.buffer(), ¶ms,
|
| + context);
|
| params->EncodePointers();
|
| MessageReceiver* responder = new RunResponseForwardToCallback(callback);
|
| if (!receiver->AcceptWithResponder(builder.message(), responder))
|
| @@ -64,17 +68,20 @@ void SendRunMessage(MessageReceiverWithResponder* receiver,
|
| }
|
|
|
| void SendRunOrClosePipeMessage(MessageReceiverWithResponder* receiver,
|
| - RequireVersionPtr require_version) {
|
| + RequireVersionPtr require_version,
|
| + SerializationContext* context) {
|
| RunOrClosePipeMessageParamsPtr params_ptr(RunOrClosePipeMessageParams::New());
|
| params_ptr->reserved0 = 16u;
|
| params_ptr->reserved1 = 0u;
|
| params_ptr->require_version = std::move(require_version);
|
|
|
| - size_t size = GetSerializedSize_(params_ptr, nullptr);
|
| + size_t size =
|
| + PrepareToSerialize<RunOrClosePipeMessageParamsPtr>(params_ptr, context);
|
| MessageBuilder builder(kRunOrClosePipeMessageId, size);
|
|
|
| RunOrClosePipeMessageParams_Data* params = nullptr;
|
| - Serialize_(std::move(params_ptr), builder.buffer(), ¶ms, nullptr);
|
| + Serialize<RunOrClosePipeMessageParamsPtr>(params_ptr, builder.buffer(),
|
| + ¶ms, context);
|
| params->EncodePointers();
|
| bool ok = receiver->Accept(builder.message());
|
| ALLOW_UNUSED_LOCAL(ok);
|
| @@ -91,13 +98,13 @@ void ControlMessageProxy::QueryVersion(
|
| auto run_callback = [callback](QueryVersionResultPtr query_version_result) {
|
| callback.Run(query_version_result->version);
|
| };
|
| - SendRunMessage(receiver_, QueryVersion::New(), run_callback);
|
| + SendRunMessage(receiver_, QueryVersion::New(), run_callback, &context_);
|
| }
|
|
|
| void ControlMessageProxy::RequireVersion(uint32_t version) {
|
| RequireVersionPtr require_version(RequireVersion::New());
|
| require_version->version = version;
|
| - SendRunOrClosePipeMessage(receiver_, std::move(require_version));
|
| + SendRunOrClosePipeMessage(receiver_, std::move(require_version), &context_);
|
| }
|
|
|
| } // namespace internal
|
|
|