Index: mojo/public/cpp/bindings/lib/control_message_handler.cc |
diff --git a/mojo/public/cpp/bindings/lib/control_message_handler.cc b/mojo/public/cpp/bindings/lib/control_message_handler.cc |
deleted file mode 100644 |
index 9398d92b2ec80dc0c742fe22094e87bf14855034..0000000000000000000000000000000000000000 |
--- a/mojo/public/cpp/bindings/lib/control_message_handler.cc |
+++ /dev/null |
@@ -1,85 +0,0 @@ |
-// Copyright 2015 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "mojo/public/cpp/bindings/lib/control_message_handler.h" |
- |
-#include "mojo/public/cpp/bindings/lib/message_builder.h" |
-#include "mojo/public/cpp/environment/logging.h" |
-#include "mojo/public/interfaces/bindings/interface_control_messages.mojom.h" |
- |
-namespace mojo { |
-namespace internal { |
- |
-// static |
-bool ControlMessageHandler::IsControlMessage(const Message* message) { |
- return !!(message->header()->name & 0x80000000); |
-} |
- |
-ControlMessageHandler::ControlMessageHandler(uint32_t interface_version) |
- : interface_version_(interface_version) { |
-} |
- |
-ControlMessageHandler::~ControlMessageHandler() { |
-} |
- |
-bool ControlMessageHandler::Accept(Message* message) { |
- if (message->header()->name == kRunOrClosePipeMessageId) |
- return RunOrClosePipe(message); |
- |
- MOJO_DCHECK(false) << "Bad control message (no response): name = " |
- << message->header()->name; |
- return false; |
-} |
- |
-bool ControlMessageHandler::AcceptWithResponder( |
- Message* message, |
- MessageReceiverWithStatus* responder) { |
- if (message->header()->name == kRunMessageId) |
- return Run(message, responder); |
- |
- MOJO_DCHECK(false) << "Bad control message (with response): name = " |
- << message->header()->name; |
- return false; |
-} |
- |
-bool ControlMessageHandler::Run(Message* message, |
- MessageReceiverWithStatus* responder) { |
- RunResponseMessageParamsPtr response_params_ptr( |
- RunResponseMessageParams::New()); |
- response_params_ptr->reserved0 = 16u; |
- response_params_ptr->reserved1 = 0u; |
- response_params_ptr->query_version_result = QueryVersionResult::New(); |
- response_params_ptr->query_version_result->version = interface_version_; |
- |
- size_t size = GetSerializedSize_(*response_params_ptr); |
- ResponseMessageBuilder builder(kRunMessageId, size, message->request_id()); |
- |
- RunResponseMessageParams_Data* response_params = nullptr; |
- auto result = |
- Serialize_(response_params_ptr.get(), builder.buffer(), &response_params); |
- MOJO_DCHECK(result == ValidationError::NONE); |
- |
- response_params->EncodePointersAndHandles( |
- builder.message()->mutable_handles()); |
- bool ok = responder->Accept(builder.message()); |
- MOJO_ALLOW_UNUSED_LOCAL(ok); |
- delete responder; |
- |
- return true; |
-} |
- |
-bool ControlMessageHandler::RunOrClosePipe(Message* message) { |
- RunOrClosePipeMessageParams_Data* params = |
- reinterpret_cast<RunOrClosePipeMessageParams_Data*>( |
- message->mutable_payload()); |
- params->DecodePointersAndHandles(message->mutable_handles()); |
- |
- RunOrClosePipeMessageParamsPtr params_ptr(RunOrClosePipeMessageParams::New()); |
- Deserialize_(params, params_ptr.get()); |
- |
- return interface_version_ >= params_ptr->require_version->version; |
-} |
- |
-} // namespace internal |
-} // namespace mojo |