Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(880)

Unified Diff: mojo/edk/system/endpoint_relayer.cc

Issue 814543006: Move //mojo/{public, edk} underneath //third_party (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebase Created 5 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « mojo/edk/system/endpoint_relayer.h ('k') | mojo/edk/system/handle_signals_state.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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
« no previous file with comments | « mojo/edk/system/endpoint_relayer.h ('k') | mojo/edk/system/handle_signals_state.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698