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

Unified Diff: components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/SignalingReceiverProxy.java

Issue 1142463003: Remove devtools_bridge component (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 7 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
Index: components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/SignalingReceiverProxy.java
diff --git a/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/SignalingReceiverProxy.java b/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/SignalingReceiverProxy.java
deleted file mode 100644
index f57637b05ed092d5fce84a564dd9f47204055e1b..0000000000000000000000000000000000000000
--- a/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/SignalingReceiverProxy.java
+++ /dev/null
@@ -1,137 +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.
-
-package org.chromium.components.devtools_bridge;
-
-import org.chromium.components.devtools_bridge.commands.Command;
-import org.chromium.components.devtools_bridge.commands.CommandReceiver;
-import org.chromium.components.devtools_bridge.commands.CommandSender;
-
-import java.util.List;
-
-/**
- * Helper proxy that binds client and server sessions living on different executors.
- */
-final class SignalingReceiverProxy extends CommandSender {
- private final CommandReceiver mReceiver;
- private final SessionBase.Executor mServerExecutor;
- private final SessionBase.Executor mClientExecutor;
- private final int mDelayMs;
-
- public SignalingReceiverProxy(
- SessionBase.Executor serverExecutor,
- SessionBase.Executor clientExecutor,
- SignalingReceiver server,
- int delayMs) {
- mServerExecutor = serverExecutor;
- mClientExecutor = clientExecutor;
- mReceiver = new CommandReceiver(server);
- mDelayMs = delayMs;
- }
-
- public SignalingReceiverProxy(
- SessionBase.Executor serverExecutor,
- SessionBase.Executor clientExecutor,
- SessionBase.ServerSessionInterface serverSession,
- String sessionId,
- int delayMs) {
- this(serverExecutor, clientExecutor,
- new SignalingReceiverAdaptor(serverSession, sessionId),
- delayMs);
- }
-
- public SessionBase.Executor serverExecutor() {
- return mServerExecutor;
- }
-
- public SessionBase.Executor clientExecutor() {
- return mClientExecutor;
- }
-
- @Override
- protected void send(final Command command, final Runnable completionCallback) {
- assert mClientExecutor.isCalledOnSessionThread();
-
- mServerExecutor.postOnSessionThread(mDelayMs, new Runnable() {
- @Override
- public void run() {
- mReceiver.receive(command, new Runnable() {
- @Override
- public void run() {
- assert mServerExecutor.isCalledOnSessionThread();
- mClientExecutor.postOnSessionThread(mDelayMs, completionCallback);
- }
- });
- }
- });
- }
-
- public SessionBase.ServerSessionInterface asServerSession(String sessionId) {
- return new ServerSessionAdapter(this, sessionId);
- }
-
- private static final class ServerSessionAdapter implements SessionBase.ServerSessionInterface {
- private final SignalingReceiver mAdaptee;
- private final String mSessionId;
-
- public ServerSessionAdapter(SignalingReceiver adaptee, String sessionId) {
- mAdaptee = adaptee;
- mSessionId = sessionId;
- }
-
- @Override
- public void startSession(
- RTCConfiguration config, String offer, SessionBase.NegotiationCallback callback) {
- mAdaptee.startSession(mSessionId, config, offer, callback);
- }
-
- @Override
- public void renegotiate(String offer, SessionBase.NegotiationCallback callback) {
- mAdaptee.renegotiate(mSessionId, offer, callback);
- }
-
- @Override
- public void iceExchange(
- List<String> clientCandidates, SessionBase.IceExchangeCallback callback) {
- mAdaptee.iceExchange(mSessionId, clientCandidates, callback);
- }
- }
-
- private static final class SignalingReceiverAdaptor implements SignalingReceiver {
- private final SessionBase.ServerSessionInterface mAdaptee;
- private final String mSessionId;
-
- public SignalingReceiverAdaptor(
- SessionBase.ServerSessionInterface adaptee, String sessionId) {
- mAdaptee = adaptee;
- mSessionId = sessionId;
- }
-
- @Override
- public void startSession(
- String sessionId, RTCConfiguration config, String offer,
- SessionBase.NegotiationCallback callback) {
- if (mSessionId.equals(sessionId)) {
- mAdaptee.startSession(config, offer, callback);
- }
- }
-
- @Override
- public void renegotiate(
- String sessionId, String offer, SessionBase.NegotiationCallback callback) {
- if (mSessionId.equals(sessionId)) {
- mAdaptee.renegotiate(offer, callback);
- }
- }
-
- @Override
- public void iceExchange(
- String sessionId, List<String> clientCandidates,
- SessionBase.IceExchangeCallback callback) {
- if (mSessionId.equals(sessionId)) {
- mAdaptee.iceExchange(clientCandidates, callback);
- }
- }
- }
-}

Powered by Google App Engine
This is Rietveld 408576698