Index: components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/GCDClientSessionTestingHost.java |
diff --git a/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/GCDClientSessionTestingHost.java b/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/GCDClientSessionTestingHost.java |
deleted file mode 100644 |
index c3fd83a756881d39f0021a954ac4afcd239f23a5..0000000000000000000000000000000000000000 |
--- a/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/GCDClientSessionTestingHost.java |
+++ /dev/null |
@@ -1,101 +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 android.util.Log; |
- |
-import org.chromium.components.devtools_bridge.apiary.TestApiaryClientFactory; |
-import org.chromium.components.devtools_bridge.commands.Command; |
-import org.chromium.components.devtools_bridge.commands.CommandSender; |
- |
-import java.io.IOException; |
-import java.util.Random; |
- |
-/** |
- * Helper class which handles a client session in manual tests. Connects to a |
- * remote server with GCD. |
- */ |
-public class GCDClientSessionTestingHost { |
- private static final String TAG = "GCDClientSessionTestingHost"; |
- private static final Random sRandom = new Random(); |
- |
- private final TestApiaryClientFactory mClientFactory; |
- private final SessionDependencyFactory mFactory; |
- private final LocalSessionBridge.ThreadedExecutor mIOExecutor; |
- private final ClientSessionTestingHost mBase; |
- private final String mOAuthToken; |
- private final String mRemoteInstanceId; |
- |
- private volatile boolean mStarted; |
- |
- public GCDClientSessionTestingHost( |
- String oAuthToken, String socketName, String remoteInstanceId) throws IOException { |
- mClientFactory = new TestApiaryClientFactory(); |
- mFactory = SessionDependencyFactory.newInstance(); |
- mIOExecutor = new LocalSessionBridge.ThreadedExecutor(); |
- |
- String sessionId = Integer.toString(sRandom.nextInt()); |
- |
- mBase = new ClientSessionTestingHost( |
- mFactory, new ServerProxy(remoteInstanceId), mIOExecutor, sessionId, socketName); |
- |
- mOAuthToken = oAuthToken; |
- mRemoteInstanceId = remoteInstanceId; |
- } |
- |
- public boolean isStarted() { |
- return mStarted; |
- } |
- |
- public void start(final Runnable completionCallback) { |
- mIOExecutor.postOnSessionThread(0, new Runnable() { |
- @Override |
- public void run() { |
- try { |
- mBase.start(mClientFactory.newConfigClient().fetch()); |
- mStarted = true; |
- } catch (IOException e) { |
- Log.e(TAG, "Failed to start", e); |
- } finally { |
- completionCallback.run(); |
- } |
- } |
- |
- }); |
- } |
- |
- public void dispose() { |
- mBase.dispose(); |
- mIOExecutor.runSynchronously(new Runnable() { |
- @Override |
- public void run() { |
- // All previously scheduled operations have completed. |
- mClientFactory.close(); |
- } |
- }); |
- mIOExecutor.dispose(); |
- } |
- |
- private class ServerProxy extends CommandSender { |
- private final String mInstanceId; |
- |
- public ServerProxy(String instanceId) { |
- mInstanceId = instanceId; |
- } |
- |
- protected void send(Command command, Runnable completionCallback) { |
- assert mIOExecutor.isCalledOnSessionThread(); |
- |
- try { |
- mClientFactory.newTestGCDClient(mOAuthToken).send(mRemoteInstanceId, command); |
- } catch (IOException e) { |
- Log.e(TAG, "Exception when sending a command", e); |
- command.setFailure("IOException: " + e.getMessage()); |
- } finally { |
- completionCallback.run(); |
- } |
- } |
- } |
-} |