summaryrefslogtreecommitdiff
path: root/android/controller/src/main/java/com/zeroc/testcontroller/ControllerApp.java
diff options
context:
space:
mode:
Diffstat (limited to 'android/controller/src/main/java/com/zeroc/testcontroller/ControllerApp.java')
-rw-r--r--android/controller/src/main/java/com/zeroc/testcontroller/ControllerApp.java542
1 files changed, 0 insertions, 542 deletions
diff --git a/android/controller/src/main/java/com/zeroc/testcontroller/ControllerApp.java b/android/controller/src/main/java/com/zeroc/testcontroller/ControllerApp.java
deleted file mode 100644
index 3c43d86416b..00000000000
--- a/android/controller/src/main/java/com/zeroc/testcontroller/ControllerApp.java
+++ /dev/null
@@ -1,542 +0,0 @@
-// **********************************************************************
-//
-// Copyright (c) 2003-2017 ZeroC, Inc. All rights reserved.
-//
-// This copy of Ice is licensed to you under the terms described in the
-// ICE_LICENSE file included in this distribution.
-//
-// **********************************************************************
-
-package com.zeroc.testcontroller;
-
-import java.io.*;
-import java.util.*;
-
-import com.zeroc.Ice.Logger;
-import com.zeroc.Ice.Communicator;
-import com.zeroc.IceInternal.Time;
-
-import android.os.Build;
-import android.util.Log;
-import android.app.Application;
-
-import Test.Common.ProcessControllerRegistryPrx;
-import Test.Common.ProcessControllerPrx;
-import test.Util.Application.CommunicatorListener;
-
-public class ControllerApp extends Application
-{
- private final String TAG = "ControllerApp";
- private ControllerHelper _helper;
- private ControllerActivity _controller;
- private String _ipv4Address;
- private String _ipv6Address;
-
- static private class TestSuiteBundle
- {
- @SuppressWarnings("unchecked")
- TestSuiteBundle(String name, ClassLoader loader) throws ClassNotFoundException
- {
- _loader = loader;
- _class = (Class<? extends test.Util.Application>)_loader.loadClass(name);
- }
-
- test.Util.Application newInstance()
- throws IllegalAccessException, InstantiationException
- {
- if(_class == null)
- {
- return null;
- }
- return _class.newInstance();
- }
-
- ClassLoader getClassLoader()
- {
- return _loader;
- }
-
- private String _name;
- private ClassLoader _loader;
- private Class<? extends test.Util.Application> _class;
- }
-
- class AndroidLogger implements Logger
- {
- private final String _prefix;
-
- AndroidLogger(String prefix)
- {
- _prefix = prefix;
- }
-
- @Override
- public void print(String message)
- {
- Log.d(TAG, message);
- }
-
- @Override
- public void trace(String category, String message)
- {
- Log.v(category, message);
- }
-
- @Override
- public void warning(String message)
- {
- Log.w(TAG, message);
- }
-
- @Override
- public void error(String message)
- {
- Log.e(TAG, message);
- }
-
- @Override
- public String getPrefix()
- {
- return _prefix;
- }
-
- @Override
- public Logger cloneWithPrefix(String s)
- {
- return new AndroidLogger(s);
- }
- }
-
- @Override
- public void onCreate()
- {
- super.onCreate();
- com.zeroc.Ice.Util.setProcessLogger(new AndroidLogger(""));
- }
-
- synchronized public void setIpv4Address(String address)
- {
- _ipv4Address = address;
- }
-
- synchronized public void setIpv6Address(String address)
- {
- int i = address.indexOf("%");
- _ipv6Address = i == -1 ? address : address.substring(i);
- }
-
- public List<String> getAddresses(boolean ipv6)
- {
- List<String> addresses = new java.util.ArrayList<String>();
- try
- {
- java.util.Enumeration<java.net.NetworkInterface> ifaces = java.net.NetworkInterface.getNetworkInterfaces();
- while(ifaces.hasMoreElements())
- {
- java.net.NetworkInterface iface = ifaces.nextElement();
- java.util.Enumeration<java.net.InetAddress> addrs = iface.getInetAddresses();
- while (addrs.hasMoreElements())
- {
- java.net.InetAddress addr = addrs.nextElement();
- if((ipv6 && addr instanceof java.net.Inet6Address) ||
- (!ipv6 && !(addr instanceof java.net.Inet6Address)))
- {
- addresses.add(addr.getHostAddress());
- }
- }
- }
- }
- catch(java.net.SocketException ex)
- {
- }
- return addresses;
- }
-
- public synchronized void startController(ControllerActivity controller)
- {
- if(_helper == null)
- {
- _controller = controller;
- _helper = new ControllerHelper();
- }
- else
- {
- _controller = controller;
- }
- }
-
- public synchronized void println(final String data)
- {
- _controller.runOnUiThread(new Runnable()
- {
- @Override
- public void run()
- {
- synchronized(ControllerApp.this)
- {
- _controller.println(data);
- }
- }
- });
- }
-
- public static boolean isEmulator()
- {
- return Build.FINGERPRINT.startsWith("generic") ||
- Build.FINGERPRINT.startsWith("unknown") ||
- Build.MODEL.contains("google_sdk") ||
- Build.MODEL.contains("Emulator") ||
- Build.MODEL.contains("Android SDK built for x86") ||
- Build.MANUFACTURER.contains("Genymotion") ||
- (Build.BRAND.startsWith("generic") && Build.DEVICE.startsWith("generic")) ||
- Build.PRODUCT.equals("google_sdk");
- }
-
- class ControllerHelper
- {
- public ControllerHelper()
- {
- com.zeroc.Ice.InitializationData initData = new com.zeroc.Ice.InitializationData();
- initData.properties = com.zeroc.Ice.Util.createProperties();
- initData.properties.setProperty("Ice.ThreadPool.Server.SizeMax", "10");
- initData.properties.setProperty("ControllerAdapter.Endpoints", "tcp");
- initData.properties.setProperty("Ice.Trace.Network", "3");
- initData.properties.setProperty("Ice.Trace.Protocol", "1");
- initData.properties.setProperty("ControllerAdapter.AdapterId", java.util.UUID.randomUUID().toString());
- initData.properties.setProperty("Ice.Override.ConnectTimeout", "1000");
- if(!isEmulator())
- {
- initData.properties.setProperty("Ice.Plugin.IceDiscovery", "IceDiscovery.PluginFactory");
- initData.properties.setProperty("IceDiscovery.DomainId", "TestController");
- }
- _communicator = com.zeroc.Ice.Util.initialize(initData);
- com.zeroc.Ice.ObjectAdapter adapter = _communicator.createObjectAdapter("ControllerAdapter");
- ProcessControllerPrx processController = ProcessControllerPrx.uncheckedCast(
- adapter.add(new ProcessControllerI(),
- com.zeroc.Ice.Util.stringToIdentity("Android/ProcessController")));
- adapter.activate();
- if(isEmulator())
- {
- ProcessControllerRegistryPrx registry = ProcessControllerRegistryPrx.uncheckedCast(
- _communicator.stringToProxy("Util/ProcessControllerRegistry:tcp -h 10.0.2.2 -p 15001"));
- registerProcessController(adapter, registry, processController);
- }
- println("Android/ProcessController");
- }
-
- public void
- registerProcessController(final com.zeroc.Ice.ObjectAdapter adapter,
- final ProcessControllerRegistryPrx registry,
- final ProcessControllerPrx processController)
- {
- registry.ice_pingAsync().whenCompleteAsync(
- (r1, e1) ->
- {
- if(e1 != null)
- {
- handleException(e1, adapter, registry, processController);
- }
- else
- {
- com.zeroc.Ice.Connection connection = registry.ice_getConnection();
- connection.setAdapter(adapter);
- connection.setACM(OptionalInt.of(5),
- Optional.of(com.zeroc.Ice.ACMClose.CloseOff),
- Optional.of(com.zeroc.Ice.ACMHeartbeat.HeartbeatAlways));
- connection.setCloseCallback(
- con ->
- {
- println("connection with process controller registry closed");
- while (true) {
- try
- {
- Thread.sleep(500);
- break;
- }
- catch(InterruptedException e)
- {
- }
- }
- registerProcessController(adapter, registry, processController);
- });
-
- registry.setProcessControllerAsync(processController).whenCompleteAsync(
- (r2, e2) ->
- {
- if(e2 != null)
- {
- handleException(e2, adapter, registry, processController);
- }
- });
- }
- });
- }
-
- public void handleException(Throwable ex,
- final com.zeroc.Ice.ObjectAdapter adapter,
- final ProcessControllerRegistryPrx registry,
- final ProcessControllerPrx processController)
- {
- if(ex instanceof com.zeroc.Ice.ConnectFailedException || ex instanceof com.zeroc.Ice.TimeoutException)
- {
- while(true)
- {
- try
- {
- Thread.sleep(500);
- break;
- }
- catch(InterruptedException e)
- {
- }
- }
- registerProcessController(adapter, registry, processController);
- }
- else
- {
- println(ex.toString());
- }
- }
-
- public void destroy()
- {
- _communicator.destroy();
- }
-
- private ProcessControllerRegistryPrx _registry;
- private com.zeroc.Ice.Communicator _communicator;
- }
-
- class MainHelperI extends Thread implements test.Util.Application.ServerReadyListener
- {
- public MainHelperI(TestSuiteBundle bundle, String[] args, String exe)
- {
- _bundle = bundle;
- _args = args;
- }
-
- public void run()
- {
- try
- {
- _app = _bundle.newInstance();
- _app.setClassLoader(_bundle.getClassLoader());
- _app.setCommunicatorListener(new CommunicatorListener()
- {
- public void communicatorInitialized(Communicator communicator)
- {
- if(communicator.getProperties().getProperty("Ice.Plugin.IceSSL").equals("com.zeroc.IceSSL.PluginFactory"))
- {
- com.zeroc.IceSSL.Plugin plugin = (com.zeroc.IceSSL.Plugin)communicator.getPluginManager().getPlugin("IceSSL");
- String keystore = communicator.getProperties().getProperty("IceSSL.Keystore");
- communicator.getProperties().setProperty("IceSSL.Keystore", "");
- java.io.InputStream certs = getResources().openRawResource(
- keystore.equals("client.bks") ? R.raw.client : R.raw.server);
- plugin.setKeystoreStream(certs);
- plugin.setTruststoreStream(certs);
- communicator.getPluginManager().initializePlugins();
- }
- }
- });
- _app.setWriter(new Writer()
- {
- @Override
- public void close() throws IOException
- {
- }
-
- @Override
- public void flush() throws IOException
- {
- }
-
- @Override
- public void write(char[] buf, int offset, int count)
- throws IOException
- {
- _out.append(buf, offset, count);
- }
- });
- _app.setServerReadyListener(this);
-
- int status = _app.main(_exe, _args);
- synchronized(this)
- {
- _status = status;
- _completed = true;
- notifyAll();
- }
- }
- catch(Exception ex)
- {
- _out.append(ex.toString());
- synchronized(this)
- {
- _status = -1;
- _completed = true;
- notifyAll();
- }
- }
- }
-
- public void shutdown()
- {
- if(_app != null)
- {
- _app.stop();
- }
- }
-
- public String getOutput()
- {
- return _out.toString();
- }
-
- synchronized private void completed(int status)
- {
- _completed = true;
- _status = status;
- notifyAll();
- }
-
- synchronized public void serverReady()
- {
- _ready = true;
- notifyAll();
- }
-
- synchronized private void waitReady(int timeout)
- throws Test.Common.ProcessFailedException
- {
- long now = Time.currentMonotonicTimeMillis();
- while(!_ready && !_completed)
- {
- try
- {
- wait(timeout * 1000);
- if(Time.currentMonotonicTimeMillis() - now > timeout * 1000)
- {
- throw new Test.Common.ProcessFailedException("timed out waiting for the process to be ready");
- }
- }
- catch(java.lang.InterruptedException ex)
- {
- }
- }
-
- if(_completed && _status != 0)
- {
- throw new Test.Common.ProcessFailedException(_out.toString());
- }
- }
-
- synchronized private int waitSuccess(int timeout)
- throws Test.Common.ProcessFailedException
- {
- long now = Time.currentMonotonicTimeMillis();
- while(!_completed)
- {
- try
- {
- wait(timeout * 1000);
- if(Time.currentMonotonicTimeMillis() - now > timeout * 1000)
- {
- throw new Test.Common.ProcessFailedException("timed out waiting for the process to be ready");
- }
- }
- catch(java.lang.InterruptedException ex)
- {
- }
- }
- return _status;
- }
-
- private TestSuiteBundle _bundle;
- private String[] _args;
- private String _exe;
- private test.Util.Application _app;
- private boolean _ready = false;
- private boolean _completed = false;
- private int _status = 0;
- private final StringBuffer _out = new StringBuffer();
- }
-
- class ProcessControllerI implements Test.Common.ProcessController
- {
- public Test.Common.ProcessPrx start(final String testsuite, final String exe, String[] args,
- com.zeroc.Ice.Current current)
- throws Test.Common.ProcessFailedException
- {
- println("starting " + testsuite + " " + exe + "... ");
- String className = "test." + testsuite.replace("/", ".") + "." + exe.substring(0, 1).toUpperCase() + exe.substring(1);
- String dexFile = "test_" + testsuite.replace("/", "_") + ".dex";
- try
- {
- TestSuiteBundle bundle = new TestSuiteBundle(className, getClassLoader());
- MainHelperI mainHelper = new MainHelperI(bundle, args, exe);
- mainHelper.start();
- return Test.Common.ProcessPrx.uncheckedCast(current.adapter.addWithUUID(new ProcessI(mainHelper)));
- }
- catch(ClassNotFoundException ex)
- {
- throw new Test.Common.ProcessFailedException(
- "testsuite `" + testsuite + "' exe ` " + exe + "' start failed:\n" + ex.toString());
- }
- }
-
- public String getHost(String protocol, boolean ipv6, com.zeroc.Ice.Current current)
- {
- if(isEmulator())
- {
- return "127.0.0.1";
- }
- else
- {
- synchronized(ControllerApp.this)
- {
- return ipv6 ? _ipv6Address : _ipv4Address;
- }
- }
- }
- }
-
- class ProcessI implements Test.Common.Process
- {
- public ProcessI(MainHelperI helper)
- {
- _helper = helper;
- }
-
- public void waitReady(int timeout, com.zeroc.Ice.Current current)
- throws Test.Common.ProcessFailedException
- {
- _helper.waitReady(timeout);
- }
-
- public int waitSuccess(int timeout, com.zeroc.Ice.Current current)
- throws Test.Common.ProcessFailedException
- {
- return _helper.waitSuccess(timeout);
- }
-
- public String terminate(com.zeroc.Ice.Current current)
- {
- _helper.shutdown();
- current.adapter.remove(current.id);
- while(true)
- {
- try
- {
- _helper.join();
- break;
- }
- catch(InterruptedException ex)
- {
- }
- }
- return _helper.getOutput();
- }
-
- private MainHelperI _helper;
- }
-}
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-04 04:50:24 +0000