| Index: mojo/public/cpp/bindings/lib/synchronous_connector.cc
|
| diff --git a/mojo/public/cpp/bindings/lib/synchronous_connector.cc b/mojo/public/cpp/bindings/lib/synchronous_connector.cc
|
| deleted file mode 100644
|
| index 42582af924c5cc8626beb56ab09341f08bae235c..0000000000000000000000000000000000000000
|
| --- a/mojo/public/cpp/bindings/lib/synchronous_connector.cc
|
| +++ /dev/null
|
| @@ -1,77 +0,0 @@
|
| -// Copyright 2016 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/synchronous_connector.h"
|
| -
|
| -#include <mojo/system/handle.h>
|
| -#include <mojo/system/time.h>
|
| -
|
| -#include <utility>
|
| -
|
| -#include "mojo/public/cpp/bindings/message.h"
|
| -#include "mojo/public/cpp/environment/logging.h"
|
| -#include "mojo/public/cpp/system/message_pipe.h"
|
| -#include "mojo/public/cpp/system/wait.h"
|
| -
|
| -namespace mojo {
|
| -namespace internal {
|
| -
|
| -SynchronousConnector::SynchronousConnector(ScopedMessagePipeHandle handle)
|
| - : handle_(std::move(handle)) {}
|
| -
|
| -SynchronousConnector::~SynchronousConnector() {}
|
| -
|
| -bool SynchronousConnector::Write(Message* msg_to_send) {
|
| - MOJO_DCHECK(handle_.is_valid());
|
| - MOJO_DCHECK(msg_to_send);
|
| -
|
| - auto result = WriteMessageRaw(
|
| - handle_.get(), msg_to_send->data(), msg_to_send->data_num_bytes(),
|
| - msg_to_send->mutable_handles()->empty()
|
| - ? nullptr
|
| - : reinterpret_cast<const MojoHandle*>(
|
| - msg_to_send->mutable_handles()->data()),
|
| - static_cast<uint32_t>(msg_to_send->mutable_handles()->size()),
|
| - MOJO_WRITE_MESSAGE_FLAG_NONE);
|
| -
|
| - switch (result) {
|
| - case MOJO_RESULT_OK:
|
| - break;
|
| -
|
| - case MOJO_RESULT_INVALID_ARGUMENT:
|
| - case MOJO_RESULT_RESOURCE_EXHAUSTED:
|
| - case MOJO_RESULT_FAILED_PRECONDITION:
|
| - case MOJO_RESULT_UNIMPLEMENTED:
|
| - case MOJO_RESULT_BUSY:
|
| - default:
|
| - MOJO_LOG(WARNING) << "WriteMessageRaw unsuccessful. error = " << result;
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool SynchronousConnector::BlockingRead(Message* received_msg) {
|
| - MOJO_DCHECK(handle_.is_valid());
|
| - MOJO_DCHECK(received_msg);
|
| -
|
| - MojoResult rv = Wait(handle_.get(), MOJO_HANDLE_SIGNAL_READABLE,
|
| - MOJO_DEADLINE_INDEFINITE, nullptr);
|
| -
|
| - if (rv != MOJO_RESULT_OK) {
|
| - MOJO_LOG(WARNING) << "Failed waiting for a response. error = " << rv;
|
| - return false;
|
| - }
|
| -
|
| - rv = ReadMessage(handle_.get(), received_msg);
|
| - if (rv != MOJO_RESULT_OK) {
|
| - MOJO_LOG(WARNING) << "Failed reading the response message. error = " << rv;
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| -}
|
| -
|
| -} // namespace internal
|
| -} // namespace mojo
|
|
|