Index: mojo/edk/system/endpoint_relayer.cc |
diff --git a/mojo/edk/system/endpoint_relayer.cc b/mojo/edk/system/endpoint_relayer.cc |
deleted file mode 100644 |
index 52faefa4c6e783aaea5f95afb1290e7779f0b3e6..0000000000000000000000000000000000000000 |
--- a/mojo/edk/system/endpoint_relayer.cc |
+++ /dev/null |
@@ -1,70 +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 "mojo/edk/system/endpoint_relayer.h" |
- |
-#include "base/logging.h" |
-#include "mojo/edk/system/channel_endpoint.h" |
-#include "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; |
-} |
- |
-bool EndpointRelayer::OnReadMessage(unsigned port, MessageInTransit* message) { |
- DCHECK(message); |
- |
- base::AutoLock locker(lock_); |
- |
- // If we're no longer the client, then reject the message. |
- if (!endpoints_[port]) |
- return false; |
- |
- // Otherwise, consume it even if the peer port is closed. |
- unsigned peer_port = GetPeerPort(port); |
- if (endpoints_[peer_port]) |
- endpoints_[peer_port]->EnqueueMessage(make_scoped_ptr(message)); |
- return true; |
-} |
- |
-void EndpointRelayer::OnDetachFromChannel(unsigned port) { |
- base::AutoLock locker(lock_); |
- |
- 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 |