| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "mojo/public/cpp/bindings/lib/control_message_proxy.h" | 5 #include "mojo/public/cpp/bindings/lib/control_message_proxy.h" |
| 6 | 6 |
| 7 #include "mojo/public/cpp/bindings/lib/message_builder.h" | 7 #include "mojo/public/cpp/bindings/lib/message_builder.h" |
| 8 #include "mojo/public/cpp/bindings/message.h" | 8 #include "mojo/public/cpp/bindings/message.h" |
| 9 #include "mojo/public/cpp/system/macros.h" | 9 #include "mojo/public/cpp/system/macros.h" |
| 10 #include "mojo/public/interfaces/bindings/interface_control_messages.mojom.h" | 10 #include "mojo/public/interfaces/bindings/interface_control_messages.mojom.h" |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 45 const RunCallback& callback) { | 45 const RunCallback& callback) { |
| 46 RunMessageParamsPtr params_ptr(RunMessageParams::New()); | 46 RunMessageParamsPtr params_ptr(RunMessageParams::New()); |
| 47 params_ptr->reserved0 = 16u; | 47 params_ptr->reserved0 = 16u; |
| 48 params_ptr->reserved1 = 0u; | 48 params_ptr->reserved1 = 0u; |
| 49 params_ptr->query_version = query_version.Pass(); | 49 params_ptr->query_version = query_version.Pass(); |
| 50 | 50 |
| 51 size_t size = GetSerializedSize_(*params_ptr); | 51 size_t size = GetSerializedSize_(*params_ptr); |
| 52 RequestMessageBuilder builder(kRunMessageId, size); | 52 RequestMessageBuilder builder(kRunMessageId, size); |
| 53 | 53 |
| 54 RunMessageParams_Data* params = nullptr; | 54 RunMessageParams_Data* params = nullptr; |
| 55 Serialize_(params_ptr.get(), builder.buffer(), ¶ms); | 55 auto result = Serialize_(params_ptr.get(), builder.buffer(), ¶ms); |
| 56 MOJO_DCHECK(result == VALIDATION_ERROR_NONE); |
| 57 |
| 56 params->EncodePointersAndHandles(builder.message()->mutable_handles()); | 58 params->EncodePointersAndHandles(builder.message()->mutable_handles()); |
| 57 MessageReceiver* responder = new RunResponseForwardToCallback(callback); | 59 MessageReceiver* responder = new RunResponseForwardToCallback(callback); |
| 58 if (!receiver->AcceptWithResponder(builder.message(), responder)) | 60 if (!receiver->AcceptWithResponder(builder.message(), responder)) |
| 59 delete responder; | 61 delete responder; |
| 60 } | 62 } |
| 61 | 63 |
| 62 void SendRunOrClosePipeMessage(MessageReceiverWithResponder* receiver, | 64 void SendRunOrClosePipeMessage(MessageReceiverWithResponder* receiver, |
| 63 RequireVersionPtr require_version) { | 65 RequireVersionPtr require_version) { |
| 64 RunOrClosePipeMessageParamsPtr params_ptr(RunOrClosePipeMessageParams::New()); | 66 RunOrClosePipeMessageParamsPtr params_ptr(RunOrClosePipeMessageParams::New()); |
| 65 params_ptr->reserved0 = 16u; | 67 params_ptr->reserved0 = 16u; |
| 66 params_ptr->reserved1 = 0u; | 68 params_ptr->reserved1 = 0u; |
| 67 params_ptr->require_version = require_version.Pass(); | 69 params_ptr->require_version = require_version.Pass(); |
| 68 | 70 |
| 69 size_t size = GetSerializedSize_(*params_ptr); | 71 size_t size = GetSerializedSize_(*params_ptr); |
| 70 MessageBuilder builder(kRunOrClosePipeMessageId, size); | 72 MessageBuilder builder(kRunOrClosePipeMessageId, size); |
| 71 | 73 |
| 72 RunOrClosePipeMessageParams_Data* params = nullptr; | 74 RunOrClosePipeMessageParams_Data* params = nullptr; |
| 73 Serialize_(params_ptr.get(), builder.buffer(), ¶ms); | 75 auto result = Serialize_(params_ptr.get(), builder.buffer(), ¶ms); |
| 76 MOJO_DCHECK(result == VALIDATION_ERROR_NONE); |
| 77 |
| 74 params->EncodePointersAndHandles(builder.message()->mutable_handles()); | 78 params->EncodePointersAndHandles(builder.message()->mutable_handles()); |
| 75 bool ok = receiver->Accept(builder.message()); | 79 bool ok = receiver->Accept(builder.message()); |
| 76 MOJO_ALLOW_UNUSED_LOCAL(ok); | 80 MOJO_ALLOW_UNUSED_LOCAL(ok); |
| 77 } | 81 } |
| 78 | 82 |
| 79 } // namespace | 83 } // namespace |
| 80 | 84 |
| 81 ControlMessageProxy::ControlMessageProxy(MessageReceiverWithResponder* receiver) | 85 ControlMessageProxy::ControlMessageProxy(MessageReceiverWithResponder* receiver) |
| 82 : receiver_(receiver) { | 86 : receiver_(receiver) { |
| 83 } | 87 } |
| 84 | 88 |
| 85 void ControlMessageProxy::QueryVersion( | 89 void ControlMessageProxy::QueryVersion( |
| 86 const Callback<void(uint32_t)>& callback) { | 90 const Callback<void(uint32_t)>& callback) { |
| 87 auto run_callback = [callback](QueryVersionResultPtr query_version_result) { | 91 auto run_callback = [callback](QueryVersionResultPtr query_version_result) { |
| 88 callback.Run(query_version_result->version); | 92 callback.Run(query_version_result->version); |
| 89 }; | 93 }; |
| 90 SendRunMessage(receiver_, QueryVersion::New(), run_callback); | 94 SendRunMessage(receiver_, QueryVersion::New(), run_callback); |
| 91 } | 95 } |
| 92 | 96 |
| 93 void ControlMessageProxy::RequireVersion(uint32_t version) { | 97 void ControlMessageProxy::RequireVersion(uint32_t version) { |
| 94 RequireVersionPtr require_version(RequireVersion::New()); | 98 RequireVersionPtr require_version(RequireVersion::New()); |
| 95 require_version->version = version; | 99 require_version->version = version; |
| 96 SendRunOrClosePipeMessage(receiver_, require_version.Pass()); | 100 SendRunOrClosePipeMessage(receiver_, require_version.Pass()); |
| 97 } | 101 } |
| 98 | 102 |
| 99 } // namespace internal | 103 } // namespace internal |
| 100 } // namespace mojo | 104 } // namespace mojo |
| OLD | NEW |