diff options
Diffstat (limited to 'java/test/controller/src')
| -rw-r--r-- | java/test/controller/src/main/java/test/common/ControllerServer.java | 260 | ||||
| -rw-r--r-- | java/test/controller/src/main/slice/Controller.ice | 33 |
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); +}; + +}; + +}; |