| Index: third_party/mojo/src/mojo/public/cpp/bindings/lib/message.cc
|
| diff --git a/third_party/mojo/src/mojo/public/cpp/bindings/lib/message.cc b/third_party/mojo/src/mojo/public/cpp/bindings/lib/message.cc
|
| deleted file mode 100644
|
| index 26884e403808628822acffd2db85c81be607eec5..0000000000000000000000000000000000000000
|
| --- a/third_party/mojo/src/mojo/public/cpp/bindings/lib/message.cc
|
| +++ /dev/null
|
| @@ -1,105 +0,0 @@
|
| -// Copyright 2013 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 "third_party/mojo/src/mojo/public/cpp/bindings/message.h"
|
| -
|
| -#include <stdlib.h>
|
| -
|
| -#include <algorithm>
|
| -
|
| -#include "third_party/mojo/src/mojo/public/cpp/environment/logging.h"
|
| -
|
| -namespace mojo {
|
| -
|
| -Message::Message() {
|
| - Initialize();
|
| -}
|
| -
|
| -Message::~Message() {
|
| - FreeDataAndCloseHandles();
|
| -}
|
| -
|
| -void Message::Reset() {
|
| - FreeDataAndCloseHandles();
|
| -
|
| - handles_.clear();
|
| - Initialize();
|
| -}
|
| -
|
| -void Message::AllocData(uint32_t num_bytes) {
|
| - MOJO_DCHECK(!data_);
|
| - data_num_bytes_ = num_bytes;
|
| - data_ = static_cast<internal::MessageData*>(calloc(num_bytes, 1));
|
| -}
|
| -
|
| -void Message::AllocUninitializedData(uint32_t num_bytes) {
|
| - MOJO_DCHECK(!data_);
|
| - data_num_bytes_ = num_bytes;
|
| - data_ = static_cast<internal::MessageData*>(malloc(num_bytes));
|
| -}
|
| -
|
| -void Message::MoveTo(Message* destination) {
|
| - MOJO_DCHECK(this != destination);
|
| -
|
| - destination->FreeDataAndCloseHandles();
|
| -
|
| - // No copy needed.
|
| - destination->data_num_bytes_ = data_num_bytes_;
|
| - destination->data_ = data_;
|
| - std::swap(destination->handles_, handles_);
|
| -
|
| - handles_.clear();
|
| - Initialize();
|
| -}
|
| -
|
| -void Message::Initialize() {
|
| - data_num_bytes_ = 0;
|
| - data_ = nullptr;
|
| -}
|
| -
|
| -void Message::FreeDataAndCloseHandles() {
|
| - free(data_);
|
| -
|
| - for (std::vector<Handle>::iterator it = handles_.begin();
|
| - it != handles_.end(); ++it) {
|
| - if (it->is_valid())
|
| - CloseRaw(*it);
|
| - }
|
| -}
|
| -
|
| -MojoResult ReadAndDispatchMessage(MessagePipeHandle handle,
|
| - MessageReceiver* receiver,
|
| - bool* receiver_result) {
|
| - MojoResult rv;
|
| -
|
| - uint32_t num_bytes = 0, num_handles = 0;
|
| - rv = ReadMessageRaw(handle,
|
| - nullptr,
|
| - &num_bytes,
|
| - nullptr,
|
| - &num_handles,
|
| - MOJO_READ_MESSAGE_FLAG_NONE);
|
| - if (rv != MOJO_RESULT_RESOURCE_EXHAUSTED)
|
| - return rv;
|
| -
|
| - Message message;
|
| - message.AllocUninitializedData(num_bytes);
|
| - message.mutable_handles()->resize(num_handles);
|
| -
|
| - rv = ReadMessageRaw(
|
| - handle,
|
| - message.mutable_data(),
|
| - &num_bytes,
|
| - message.mutable_handles()->empty()
|
| - ? nullptr
|
| - : reinterpret_cast<MojoHandle*>(&message.mutable_handles()->front()),
|
| - &num_handles,
|
| - MOJO_READ_MESSAGE_FLAG_NONE);
|
| - if (receiver && rv == MOJO_RESULT_OK)
|
| - *receiver_result = receiver->Accept(&message);
|
| -
|
| - return rv;
|
| -}
|
| -
|
| -} // namespace mojo
|
|
|