| Index: third_party/mojo/src/mojo/edk/system/endpoint_relayer.cc
|
| diff --git a/third_party/mojo/src/mojo/edk/system/endpoint_relayer.cc b/third_party/mojo/src/mojo/edk/system/endpoint_relayer.cc
|
| deleted file mode 100644
|
| index 382be15c67735cafc7d6de9b2953f55c04900286..0000000000000000000000000000000000000000
|
| --- a/third_party/mojo/src/mojo/edk/system/endpoint_relayer.cc
|
| +++ /dev/null
|
| @@ -1,84 +0,0 @@
|
| -// Copyright 2014 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/edk/system/endpoint_relayer.h"
|
| -
|
| -#include <utility>
|
| -
|
| -#include "base/logging.h"
|
| -#include "third_party/mojo/src/mojo/edk/system/channel_endpoint.h"
|
| -#include "third_party/mojo/src/mojo/edk/system/message_in_transit.h"
|
| -
|
| -namespace mojo {
|
| -namespace system {
|
| -
|
| -EndpointRelayer::EndpointRelayer() {
|
| -}
|
| -
|
| -// static
|
| -unsigned EndpointRelayer::GetPeerPort(unsigned port) {
|
| - DCHECK(port == 0 || port == 1);
|
| - return port ^ 1;
|
| -}
|
| -
|
| -void EndpointRelayer::Init(ChannelEndpoint* endpoint0,
|
| - ChannelEndpoint* endpoint1) {
|
| - DCHECK(endpoint0);
|
| - DCHECK(endpoint1);
|
| - DCHECK(!endpoints_[0]);
|
| - DCHECK(!endpoints_[1]);
|
| - endpoints_[0] = endpoint0;
|
| - endpoints_[1] = endpoint1;
|
| -}
|
| -
|
| -void EndpointRelayer::SetFilter(scoped_ptr<Filter> filter) {
|
| - MutexLocker locker(&mutex_);
|
| - filter_ = std::move(filter);
|
| -}
|
| -
|
| -bool EndpointRelayer::OnReadMessage(unsigned port, MessageInTransit* message) {
|
| - DCHECK(message);
|
| -
|
| - MutexLocker locker(&mutex_);
|
| -
|
| - // If we're no longer the client, then reject the message.
|
| - if (!endpoints_[port])
|
| - return false;
|
| -
|
| - unsigned peer_port = GetPeerPort(port);
|
| -
|
| - if (filter_ && message->type() == MessageInTransit::Type::ENDPOINT_CLIENT) {
|
| - if (filter_->OnReadMessage(endpoints_[port].get(),
|
| - endpoints_[peer_port].get(), message))
|
| - return true;
|
| - }
|
| -
|
| - // Otherwise, consume it even if the peer port is closed.
|
| - if (endpoints_[peer_port])
|
| - endpoints_[peer_port]->EnqueueMessage(make_scoped_ptr(message));
|
| - return true;
|
| -}
|
| -
|
| -void EndpointRelayer::OnDetachFromChannel(unsigned port) {
|
| - MutexLocker locker(&mutex_);
|
| -
|
| - if (endpoints_[port]) {
|
| - endpoints_[port]->DetachFromClient();
|
| - endpoints_[port] = nullptr;
|
| - }
|
| -
|
| - unsigned peer_port = GetPeerPort(port);
|
| - if (endpoints_[peer_port]) {
|
| - endpoints_[peer_port]->DetachFromClient();
|
| - endpoints_[peer_port] = nullptr;
|
| - }
|
| -}
|
| -
|
| -EndpointRelayer::~EndpointRelayer() {
|
| - DCHECK(!endpoints_[0]);
|
| - DCHECK(!endpoints_[1]);
|
| -}
|
| -
|
| -} // namespace system
|
| -} // namespace mojo
|
|
|