Port test controller server to Java

2 files changed, 293 insertions, 0 deletions

diff --git a/java/test/controller/src/main/java/test/common/ControllerServer.java b/java/test/controller/src/main/java/test/common/ControllerServer.java
new file mode 100644
index 00000000000..11ca470af65
--- /dev/null
+++ b/java/test/controller/src/main/java/test/common/ControllerServer.java
@@ -0,0 +1,260 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2015 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 test.common;
+
+import test.common._ControllerDisp;
+import test.common._ServerDisp;
+import test.common.ServerPrx;
+
+import java.io.File;
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+
+import java.util.regex.Pattern;
+
+public class ControllerServer extends Ice.Application
+{
+    class ServerI extends _ServerDisp
+    {
+        public ServerI(Process process, String name)
+        {
+            _process = process;
+            _name = name;
+            _started = 0;
+
+            class Reader extends Thread
+            {
+                Reader(java.io.InputStream is)
+                {
+                    _is = is;
+                }
+                
+                public void run()
+                {
+                    try
+                    {
+                        final BufferedReader reader = new BufferedReader(new InputStreamReader(_is));
+                        
+                        String line = null;
+                        while((line = reader.readLine()) != null)
+                        {
+                            if(line.matches(Pattern.quote("starting server... ok")) ||
+                               line.matches(Pattern.quote("starting serveramd... ok")) ||
+                               line.matches("starting test.*" + Pattern.quote("Server... ok")))
+                            {
+                                synchronized(ServerI.this)
+                                {
+                                    _started++;
+                                    ServerI.this.notifyAll();
+                                }
+                            }
+                            System.out.println(line);
+                        }
+                    }
+                    catch(java.io.IOException ex)
+                    {
+                    }
+                }
+                
+                private java.io.InputStream _is;
+            }
+            new Reader(_process.getInputStream()).start();
+        }
+        
+        public synchronized void terminate(Ice.Current current)
+        {
+            try
+            {
+                _process.exitValue();
+                return;
+            }
+            catch(IllegalThreadStateException ex)
+            {
+                //
+                // process is still running.
+                //
+                System.out.print("terminating " + _name + "... ");
+                System.out.flush();
+                _process.destroy();
+                
+                current.adapter.remove(current.id);
+                System.out.println("ok");
+            }
+        }
+        
+        public void waitTestSuccess(Ice.Current current)
+        {
+            Process p = null;
+            synchronized(this)
+            {
+                p = _process;
+            }
+            if(p != null)
+            {
+                while(true)
+                {
+                    try
+                    {
+                        p.waitFor();
+                        break;
+                    }
+                    catch(InterruptedException ex)
+                    {
+                    }
+                }
+            }
+        }
+        
+        public synchronized void waitForServer(Ice.Current current)
+        {
+            while(true)
+            {
+                try
+                {
+                    if(_started > 0)
+                    {
+                        _started--;
+                        break;
+                    }
+                    wait();
+                }
+                catch(InterruptedException ex)
+                {
+                    continue;
+                }
+            }
+        }
+        
+        private Process _process;
+        private String _name;
+        private int _started;
+    }
+    
+    public class ControllerI extends _ControllerDisp
+    {
+        @Override
+        public ServerPrx runServer(String lang, final String name, String protocol, String host, 
+                                   boolean winrt, String[] options, Ice.Current current)
+        {
+            if(_server != null)
+            {
+                try
+                {
+                    _server.terminate();
+                }
+                catch(Ice.LocalException ex)
+                {
+                }
+            }
+            
+            String script = name.equals("Ice/echo") ?
+                (lang.equals("java") ? "java/test/src/main/java/" : "cpp/") + "test/Ice/echo/run.py" :
+                "allTests.py";
+                
+            java.util.List<String> args = new java.util.ArrayList<String>();
+            args.add("python");
+            args.add(script);
+            args.add("--server");
+            if(!name.equals("Ice/echo"))
+            {
+                args.add("--filter");
+                args.add("^" + lang + "/test/" + name + "$");
+            }
+            args.add("--protocol");
+            args.add(protocol);
+            args.add("--host");
+            args.add(host);
+            
+            if(winrt)
+            {
+                args.add("--winrt");
+            }
+            
+            for(String option : options)
+            {
+                args.add("--arg");
+                args.add(option);
+            }
+            
+            try
+            {
+                System.out.print("starting " + name + "... ");
+                System.out.flush();
+                
+                final Process process = new ProcessBuilder(args)
+                    .directory(_toplevel)
+                    .redirectErrorStream(true)
+                    .start();
+                _server = ServerPrxHelper.uncheckedCast(current.adapter.addWithUUID(new ServerI(process, name)));
+            }
+            catch(java.io.IOException ex)
+            {
+                throw new RuntimeException("failed to start server `" + name + "'", ex);
+            }
+            return _server;
+        }
+        
+        private ServerPrx _server;
+    }
+    
+    @Override
+    public int
+    run(String[] args)
+    {
+        Ice.ObjectAdapter adapter = communicator().createObjectAdapter("ControllerAdapter");
+        adapter.add(new ControllerI(), communicator().stringToIdentity("controller"));
+        adapter.activate();
+        communicator().waitForShutdown();
+        return 0;
+    }
+    
+    public ControllerServer(File toplevel)
+    {
+        _toplevel = toplevel;
+    }
+    
+    public static void
+    main(String[] args)
+    {
+        try
+        {
+            File toplevel = new File(
+                new File(ControllerServer.class.getProtectionDomain().getCodeSource().getLocation().toURI()).getParent(),
+                "../../../../../");
+                
+            ControllerServer app = new ControllerServer(toplevel);
+
+            Ice.InitializationData initData = new Ice.InitializationData();
+            initData.properties = Ice.Util.createProperties(args);
+            initData.properties.setProperty("Ice.Plugin.IceSSL", "IceSSL.PluginFactory");
+            initData.properties.setProperty("IceSSL.DefaultDir", new File(toplevel, "certs").getCanonicalPath());
+            initData.properties.setProperty("IceSSL.Keystore", "server.jks");
+            initData.properties.setProperty("IceSSL.Password", "password");
+            initData.properties.setProperty("IceSSL.VerifyPeer", "0");
+            initData.properties.setProperty("Ice.ThreadPool.Server.SizeMax", "10");
+            initData.properties.setProperty("ControllerAdapter.Endpoints", "ws -p 12009:wss -p 12008");
+            
+            int status = app.main("ControllerServer", args, initData);
+            System.exit(status);
+        }
+        catch(java.net.URISyntaxException ex)
+        {
+            ex.printStackTrace();
+            System.exit(1);
+        }
+        catch(java.io.IOException ex)
+        {
+            ex.printStackTrace();
+            System.exit(1);
+        }
+    }
+    
+    private final File _toplevel;
+}
diff --git a/java/test/controller/src/main/slice/Controller.ice b/java/test/controller/src/main/slice/Controller.ice
new file mode 100644
index 00000000000..5f89858a42d
--- /dev/null
+++ b/java/test/controller/src/main/slice/Controller.ice
@@ -0,0 +1,33 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2015 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.
+//
+// **********************************************************************
+
+module test
+{
+
+module common
+{
+
+interface Server
+{
+    void waitTestSuccess();
+    void waitForServer();
+    void terminate();
+};
+
+sequence<string> StringSeq;
+
+interface Controller
+{
+    Server* runServer(string lang, string name, string protocol, string host, bool winrt, 
+                      StringSeq options);
+};
+
+};
+
+};