| 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_handler.h" | 5 #include "mojo/public/cpp/bindings/lib/control_message_handler.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 73 | 73 |
| 74 if (message->header()->name == interface_control::kRunOrClosePipeMessageId) | 74 if (message->header()->name == interface_control::kRunOrClosePipeMessageId) |
| 75 return RunOrClosePipe(message); | 75 return RunOrClosePipe(message); |
| 76 | 76 |
| 77 NOTREACHED(); | 77 NOTREACHED(); |
| 78 return false; | 78 return false; |
| 79 } | 79 } |
| 80 | 80 |
| 81 bool ControlMessageHandler::AcceptWithResponder( | 81 bool ControlMessageHandler::AcceptWithResponder( |
| 82 Message* message, | 82 Message* message, |
| 83 MessageReceiverWithStatus* responder) { | 83 std::unique_ptr<MessageReceiverWithStatus> responder) { |
| 84 if (!ValidateControlRequestWithResponse(message)) | 84 if (!ValidateControlRequestWithResponse(message)) |
| 85 return false; | 85 return false; |
| 86 | 86 |
| 87 if (message->header()->name == interface_control::kRunMessageId) | 87 if (message->header()->name == interface_control::kRunMessageId) |
| 88 return Run(message, responder); | 88 return Run(message, std::move(responder)); |
| 89 | 89 |
| 90 NOTREACHED(); | 90 NOTREACHED(); |
| 91 return false; | 91 return false; |
| 92 } | 92 } |
| 93 | 93 |
| 94 bool ControlMessageHandler::Run(Message* message, | 94 bool ControlMessageHandler::Run( |
| 95 MessageReceiverWithStatus* responder) { | 95 Message* message, |
| 96 std::unique_ptr<MessageReceiverWithStatus> responder) { |
| 96 interface_control::internal::RunMessageParams_Data* params = | 97 interface_control::internal::RunMessageParams_Data* params = |
| 97 reinterpret_cast<interface_control::internal::RunMessageParams_Data*>( | 98 reinterpret_cast<interface_control::internal::RunMessageParams_Data*>( |
| 98 message->mutable_payload()); | 99 message->mutable_payload()); |
| 99 interface_control::RunMessageParamsPtr params_ptr; | 100 interface_control::RunMessageParamsPtr params_ptr; |
| 100 Deserialize<interface_control::RunMessageParamsDataView>(params, ¶ms_ptr, | 101 Deserialize<interface_control::RunMessageParamsDataView>(params, ¶ms_ptr, |
| 101 &context_); | 102 &context_); |
| 102 auto& input = *params_ptr->input; | 103 auto& input = *params_ptr->input; |
| 103 interface_control::RunOutputPtr output = interface_control::RunOutput::New(); | 104 interface_control::RunOutputPtr output = interface_control::RunOutput::New(); |
| 104 if (input.is_query_version()) { | 105 if (input.is_query_version()) { |
| 105 output->set_query_version_result( | 106 output->set_query_version_result( |
| (...skipping 13 matching lines...) Expand all Loading... |
| 119 MessageBuilder builder(interface_control::kRunMessageId, | 120 MessageBuilder builder(interface_control::kRunMessageId, |
| 120 Message::kFlagIsResponse, size, 0); | 121 Message::kFlagIsResponse, size, 0); |
| 121 builder.message()->set_request_id(message->request_id()); | 122 builder.message()->set_request_id(message->request_id()); |
| 122 | 123 |
| 123 interface_control::internal::RunResponseMessageParams_Data* response_params = | 124 interface_control::internal::RunResponseMessageParams_Data* response_params = |
| 124 nullptr; | 125 nullptr; |
| 125 Serialize<interface_control::RunResponseMessageParamsDataView>( | 126 Serialize<interface_control::RunResponseMessageParamsDataView>( |
| 126 response_params_ptr, builder.buffer(), &response_params, &context_); | 127 response_params_ptr, builder.buffer(), &response_params, &context_); |
| 127 bool ok = responder->Accept(builder.message()); | 128 bool ok = responder->Accept(builder.message()); |
| 128 ALLOW_UNUSED_LOCAL(ok); | 129 ALLOW_UNUSED_LOCAL(ok); |
| 129 delete responder; | |
| 130 | 130 |
| 131 return true; | 131 return true; |
| 132 } | 132 } |
| 133 | 133 |
| 134 bool ControlMessageHandler::RunOrClosePipe(Message* message) { | 134 bool ControlMessageHandler::RunOrClosePipe(Message* message) { |
| 135 interface_control::internal::RunOrClosePipeMessageParams_Data* params = | 135 interface_control::internal::RunOrClosePipeMessageParams_Data* params = |
| 136 reinterpret_cast< | 136 reinterpret_cast< |
| 137 interface_control::internal::RunOrClosePipeMessageParams_Data*>( | 137 interface_control::internal::RunOrClosePipeMessageParams_Data*>( |
| 138 message->mutable_payload()); | 138 message->mutable_payload()); |
| 139 interface_control::RunOrClosePipeMessageParamsPtr params_ptr; | 139 interface_control::RunOrClosePipeMessageParamsPtr params_ptr; |
| 140 Deserialize<interface_control::RunOrClosePipeMessageParamsDataView>( | 140 Deserialize<interface_control::RunOrClosePipeMessageParamsDataView>( |
| 141 params, ¶ms_ptr, &context_); | 141 params, ¶ms_ptr, &context_); |
| 142 auto& input = *params_ptr->input; | 142 auto& input = *params_ptr->input; |
| 143 if (input.is_require_version()) | 143 if (input.is_require_version()) |
| 144 return interface_version_ >= input.get_require_version()->version; | 144 return interface_version_ >= input.get_require_version()->version; |
| 145 | 145 |
| 146 return false; | 146 return false; |
| 147 } | 147 } |
| 148 | 148 |
| 149 } // namespace internal | 149 } // namespace internal |
| 150 } // namespace mojo | 150 } // namespace mojo |
| OLD | NEW |