// ********************************************************************** // // Copyright (c) 2003-2009 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. // // ********************************************************************** import Test.*; public class AllTests { private static void test(boolean b) { if(!b) { throw new RuntimeException(); } } static class NoOpGetAdapterNameCB extends AMI_TestIntf_getAdapterName { public void ice_response(String name) { } public void ice_exception(Ice.LocalException ex) { } public void ice_exception(Ice.UserException ex) { } }; static class GetAdapterNameCB extends AMI_TestIntf_getAdapterName { synchronized public void ice_response(String adapterName) { _name = adapterName; notify(); } public void ice_exception(Ice.LocalException ex) { test(false); } public void ice_exception(Ice.UserException ex) { test(false); } synchronized public String getResult() { while(_name == null) { try { wait(); } catch(java.lang.InterruptedException ex) { } } return _name; } private String _name = null; } private static String getAdapterNameWithAMI(TestIntfPrx test) { GetAdapterNameCB cb = new GetAdapterNameCB(); test.getAdapterName_async(cb); return cb.getResult(); } private static TestIntfPrx createTestIntfPrx(java.util.List adapters) { java.util.List endpoints = new java.util.ArrayList(); TestIntfPrx test = null; java.util.Iterator p = adapters.iterator(); while(p.hasNext()) { test = p.next().getTestIntf(); Ice.Endpoint[] edpts = test.ice_getEndpoints(); endpoints.addAll(java.util.Arrays.asList(edpts)); } return TestIntfPrxHelper.uncheckedCast( test.ice_endpoints((Ice.Endpoint[])endpoints.toArray(new Ice.Endpoint[endpoints.size()]))); } private static void deactivate(RemoteCommunicatorPrx communicator, java.util.List adapters) { java.util.Iterator p = adapters.iterator(); while(p.hasNext()) { communicator.deactivateObjectAdapter(p.next()); } } public static void allTests(Ice.Communicator communicator) { String ref = "communicator:default -p 12010 -t 10000"; RemoteCommunicatorPrx com = RemoteCommunicatorPrxHelper.uncheckedCast(communicator.stringToProxy(ref)); System.out.print("testing binding with single endpoint... "); System.out.flush(); { RemoteObjectAdapterPrx adapter = com.createObjectAdapter("Adapter", "default"); TestIntfPrx test1 = adapter.getTestIntf(); TestIntfPrx test2 = adapter.getTestIntf(); test(test1.ice_getConnection() == test2.ice_getConnection()); test1.ice_ping(); test2.ice_ping(); com.deactivateObjectAdapter(adapter); TestIntfPrx test3 = TestIntfPrxHelper.uncheckedCast(test1); test(test3.ice_getConnection() == test1.ice_getConnection()); test(test3.ice_getConnection() == test2.ice_getConnection()); try { test3.ice_ping(); test(false); } catch(Ice.ConnectionRefusedException ex) { } } System.out.println("ok"); System.out.print("testing binding with multiple endpoints... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("Adapter11", "default")); adapters.add(com.createObjectAdapter("Adapter12", "default")); adapters.add(com.createObjectAdapter("Adapter13", "default")); // // Ensure that when a connection is opened it's reused for new // proxies and that all endpoints are eventually tried. // java.util.Set names = new java.util.HashSet(); names.add("Adapter11"); names.add("Adapter12"); names.add("Adapter13"); while(!names.isEmpty()) { java.util.List adpts = new java.util.ArrayList(adapters); TestIntfPrx test1 = createTestIntfPrx(adpts); java.util.Collections.shuffle(adpts); TestIntfPrx test2 = createTestIntfPrx(adpts); java.util.Collections.shuffle(adpts); TestIntfPrx test3 = createTestIntfPrx(adpts); test(test1.ice_getConnection() == test2.ice_getConnection()); test(test2.ice_getConnection() == test3.ice_getConnection()); names.remove(test1.getAdapterName()); test1.ice_getConnection().close(false); } // // Ensure that the proxy correctly caches the connection (we // always send the request over the same connection.) // { java.util.Iterator p = adapters.iterator(); while(p.hasNext()) { p.next().getTestIntf().ice_ping(); } TestIntfPrx test = createTestIntfPrx(adapters); String name = test.getAdapterName(); final int nRetry = 10; int i; for(i = 0; i < nRetry && test.getAdapterName().equals(name); i++); test(i == nRetry); p = adapters.iterator(); while(p.hasNext()) { p.next().getTestIntf().ice_getConnection().close(false); } } // // Deactivate an adapter and ensure that we can still // establish the connection to the remaining adapters. // com.deactivateObjectAdapter(adapters.get(0)); names.add("Adapter12"); names.add("Adapter13"); while(!names.isEmpty()) { java.util.List adpts = new java.util.ArrayList(adapters); TestIntfPrx test1 = createTestIntfPrx(adpts); java.util.Collections.shuffle(adpts); TestIntfPrx test2 = createTestIntfPrx(adpts); java.util.Collections.shuffle(adpts); TestIntfPrx test3 = createTestIntfPrx(adpts); test(test1.ice_getConnection() == test2.ice_getConnection()); test(test2.ice_getConnection() == test3.ice_getConnection()); names.remove(test1.getAdapterName()); test1.ice_getConnection().close(false); } // // Deactivate an adapter and ensure that we can still // establish the connection to the remaining adapter. // com.deactivateObjectAdapter(adapters.get(2)); TestIntfPrx test = createTestIntfPrx(adapters); test(test.getAdapterName().equals("Adapter12")); deactivate(com, adapters); } System.out.println("ok"); System.out.print("testing binding with multiple random endpoints... "); System.out.flush(); { java.util.Random rand = new java.util.Random(); RemoteObjectAdapterPrx[] adapters = new RemoteObjectAdapterPrx[5]; adapters[0] = com.createObjectAdapter("AdapterRandom11", "default"); adapters[1] = com.createObjectAdapter("AdapterRandom12", "default"); adapters[2] = com.createObjectAdapter("AdapterRandom13", "default"); adapters[3] = com.createObjectAdapter("AdapterRandom14", "default"); adapters[4] = com.createObjectAdapter("AdapterRandom15", "default"); int count; if(System.getProperty("os.name").startsWith("Windows")) { count = 20; } else { count = 60; } int adapterCount = adapters.length; while(--count > 0) { TestIntfPrx[] proxies; if(System.getProperty("os.name").startsWith("Windows")) { if(count == 10) { com.deactivateObjectAdapter(adapters[4]); --adapterCount; } proxies = new TestIntfPrx[10]; } else { if(count < 60 && count % 10 == 0) { com.deactivateObjectAdapter(adapters[count / 10 - 1]); --adapterCount; } proxies = new TestIntfPrx[40]; } int i; for(i = 0; i < proxies.length; ++i) { RemoteObjectAdapterPrx[] adpts = new RemoteObjectAdapterPrx[rand.nextInt(adapters.length)]; if(adpts.length == 0) { adpts = new RemoteObjectAdapterPrx[1]; } for(int j = 0; j < adpts.length; ++j) { adpts[j] = adapters[rand.nextInt(adapters.length)]; } proxies[i] = createTestIntfPrx(java.util.Arrays.asList((adpts))); } for(i = 0; i < proxies.length; i++) { proxies[i].getAdapterName_async(new NoOpGetAdapterNameCB()); } for(i = 0; i < proxies.length; i++) { try { proxies[i].ice_ping(); } catch(Ice.LocalException ex) { } } java.util.Set connections = new java.util.HashSet(); for(i = 0; i < proxies.length; i++) { if(proxies[i].ice_getCachedConnection() != null) { connections.add(proxies[i].ice_getCachedConnection()); } } test(connections.size() <= adapterCount); for(RemoteObjectAdapterPrx a : adapters) { try { a.getTestIntf().ice_getConnection().close(false); } catch(Ice.LocalException ex) { // Expected if adapter is down. } } } } System.out.println("ok"); System.out.print("testing binding with multiple endpoints and AMI... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("AdapterAMI11", "default")); adapters.add(com.createObjectAdapter("AdapterAMI12", "default")); adapters.add(com.createObjectAdapter("AdapterAMI13", "default")); // // Ensure that when a connection is opened it's reused for new // proxies and that all endpoints are eventually tried. // java.util.Set names = new java.util.HashSet(); names.add("AdapterAMI11"); names.add("AdapterAMI12"); names.add("AdapterAMI13"); while(!names.isEmpty()) { java.util.List adpts = new java.util.ArrayList(adapters); TestIntfPrx test1 = createTestIntfPrx(adpts); java.util.Collections.shuffle(adpts); TestIntfPrx test2 = createTestIntfPrx(adpts); java.util.Collections.shuffle(adpts); TestIntfPrx test3 = createTestIntfPrx(adpts); test(test1.ice_getConnection() == test2.ice_getConnection()); test(test2.ice_getConnection() == test3.ice_getConnection()); names.remove(getAdapterNameWithAMI(test1)); test1.ice_getConnection().close(false); } // // Ensure that the proxy correctly caches the connection (we // always send the request over the same connection.) // { java.util.Iterator p = adapters.iterator(); while(p.hasNext()) { p.next().getTestIntf().ice_ping(); } TestIntfPrx test = createTestIntfPrx(adapters); String name = getAdapterNameWithAMI(test); final int nRetry = 10; int i; for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals(name); i++); test(i == nRetry); p = adapters.iterator(); while(p.hasNext()) { p.next().getTestIntf().ice_getConnection().close(false); } } // // Deactivate an adapter and ensure that we can still // establish the connection to the remaining adapters. // com.deactivateObjectAdapter(adapters.get(0)); names.add("AdapterAMI12"); names.add("AdapterAMI13"); while(!names.isEmpty()) { java.util.List adpts = new java.util.ArrayList(adapters); TestIntfPrx test1 = createTestIntfPrx(adpts); java.util.Collections.shuffle(adpts); TestIntfPrx test2 = createTestIntfPrx(adpts); java.util.Collections.shuffle(adpts); TestIntfPrx test3 = createTestIntfPrx(adpts); test(test1.ice_getConnection() == test2.ice_getConnection()); test(test2.ice_getConnection() == test3.ice_getConnection()); names.remove(getAdapterNameWithAMI(test1)); test1.ice_getConnection().close(false); } // // Deactivate an adapter and ensure that we can still // establish the connection to the remaining adapter. // com.deactivateObjectAdapter(adapters.get(2)); TestIntfPrx test = createTestIntfPrx(adapters); test(getAdapterNameWithAMI(test).equals("AdapterAMI12")); deactivate(com, adapters); } System.out.println("ok"); System.out.print("testing random endpoint selection... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("Adapter21", "default")); adapters.add(com.createObjectAdapter("Adapter22", "default")); adapters.add(com.createObjectAdapter("Adapter23", "default")); TestIntfPrx test = createTestIntfPrx(adapters); test(test.ice_getEndpointSelection() == Ice.EndpointSelectionType.Random); java.util.Set names = new java.util.HashSet(); names.add("Adapter21"); names.add("Adapter22"); names.add("Adapter23"); while(!names.isEmpty()) { names.remove(test.getAdapterName()); test.ice_getConnection().close(false); } test = TestIntfPrxHelper.uncheckedCast(test.ice_endpointSelection(Ice.EndpointSelectionType.Random)); test(test.ice_getEndpointSelection() == Ice.EndpointSelectionType.Random); names.add("Adapter21"); names.add("Adapter22"); names.add("Adapter23"); while(!names.isEmpty()) { names.remove(test.getAdapterName()); test.ice_getConnection().close(false); } deactivate(com, adapters); } System.out.println("ok"); System.out.print("testing ordered endpoint selection... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("Adapter31", "default")); adapters.add(com.createObjectAdapter("Adapter32", "default")); adapters.add(com.createObjectAdapter("Adapter33", "default")); TestIntfPrx test = createTestIntfPrx(adapters); test = TestIntfPrxHelper.uncheckedCast(test.ice_endpointSelection(Ice.EndpointSelectionType.Ordered)); test(test.ice_getEndpointSelection() == Ice.EndpointSelectionType.Ordered); int nRetry = 5; int i; // // Ensure that endpoints are tried in order by deactiving the adapters // one after the other. // for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter31"); i++); test(i == nRetry); com.deactivateObjectAdapter(adapters.get(0)); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter32"); i++); test(i == nRetry); com.deactivateObjectAdapter(adapters.get(1)); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter33"); i++); test(i == nRetry); com.deactivateObjectAdapter(adapters.get(2)); try { test.getAdapterName(); } catch(Ice.ConnectionRefusedException ex) { } Ice.Endpoint[] endpoints = test.ice_getEndpoints(); adapters.clear(); // // Now, re-activate the adapters with the same endpoints in the opposite // order. // adapters.add(com.createObjectAdapter("Adapter36", endpoints[2].toString())); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter36"); i++); test(i == nRetry); test.ice_getConnection().close(false); adapters.add(com.createObjectAdapter("Adapter35", endpoints[1].toString())); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter35"); i++); test(i == nRetry); test.ice_getConnection().close(false); adapters.add(com.createObjectAdapter("Adapter34", endpoints[0].toString())); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter34"); i++); test(i == nRetry); deactivate(com, adapters); } System.out.println("ok"); System.out.print("testing per request binding with single endpoint... "); System.out.flush(); { RemoteObjectAdapterPrx adapter = com.createObjectAdapter("Adapter41", "default"); TestIntfPrx test1 = TestIntfPrxHelper.uncheckedCast(adapter.getTestIntf().ice_connectionCached(false)); TestIntfPrx test2 = TestIntfPrxHelper.uncheckedCast(adapter.getTestIntf().ice_connectionCached(false)); test(!test1.ice_isConnectionCached()); test(!test2.ice_isConnectionCached()); test(test1.ice_getConnection() == test2.ice_getConnection()); test1.ice_ping(); com.deactivateObjectAdapter(adapter); TestIntfPrx test3 = TestIntfPrxHelper.uncheckedCast(test1); try { test(test3.ice_getConnection() == test1.ice_getConnection()); test(false); } catch(Ice.ConnectionRefusedException ex) { } } System.out.println("ok"); System.out.print("testing per request binding with multiple endpoints... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("Adapter51", "default")); adapters.add(com.createObjectAdapter("Adapter52", "default")); adapters.add(com.createObjectAdapter("Adapter53", "default")); TestIntfPrx test = TestIntfPrxHelper.uncheckedCast(createTestIntfPrx(adapters).ice_connectionCached(false)); test(!test.ice_isConnectionCached()); java.util.Set names = new java.util.HashSet(); names.add("Adapter51"); names.add("Adapter52"); names.add("Adapter53"); while(!names.isEmpty()) { names.remove(test.getAdapterName()); } com.deactivateObjectAdapter(adapters.get(0)); names.add("Adapter52"); names.add("Adapter53"); while(!names.isEmpty()) { names.remove(test.getAdapterName()); } com.deactivateObjectAdapter(adapters.get(2)); test(test.getAdapterName().equals("Adapter52")); deactivate(com, adapters); } System.out.println("ok"); System.out.print("testing per request binding with multiple endpoints and AMI... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("AdapterAMI51", "default")); adapters.add(com.createObjectAdapter("AdapterAMI52", "default")); adapters.add(com.createObjectAdapter("AdapterAMI53", "default")); TestIntfPrx test = TestIntfPrxHelper.uncheckedCast(createTestIntfPrx(adapters).ice_connectionCached(false)); test(!test.ice_isConnectionCached()); java.util.Set names = new java.util.HashSet(); names.add("AdapterAMI51"); names.add("AdapterAMI52"); names.add("AdapterAMI53"); while(!names.isEmpty()) { names.remove(getAdapterNameWithAMI(test)); } com.deactivateObjectAdapter(adapters.get(0)); names.add("AdapterAMI52"); names.add("AdapterAMI53"); while(!names.isEmpty()) { names.remove(getAdapterNameWithAMI(test)); } com.deactivateObjectAdapter(adapters.get(2)); test(getAdapterNameWithAMI(test).equals("AdapterAMI52")); deactivate(com, adapters); } System.out.println("ok"); System.out.print("testing per request binding and ordered endpoint selection... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("Adapter61", "default")); adapters.add(com.createObjectAdapter("Adapter62", "default")); adapters.add(com.createObjectAdapter("Adapter63", "default")); TestIntfPrx test = createTestIntfPrx(adapters); test = TestIntfPrxHelper.uncheckedCast(test.ice_endpointSelection(Ice.EndpointSelectionType.Ordered)); test(test.ice_getEndpointSelection() == Ice.EndpointSelectionType.Ordered); test = TestIntfPrxHelper.uncheckedCast(test.ice_connectionCached(false)); test(!test.ice_isConnectionCached()); int nRetry = 5; int i; // // Ensure that endpoints are tried in order by deactiving the adapters // one after the other. // for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter61"); i++); test(i == nRetry); com.deactivateObjectAdapter(adapters.get(0)); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter62"); i++); test(i == nRetry); com.deactivateObjectAdapter(adapters.get(1)); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter63"); i++); test(i == nRetry); com.deactivateObjectAdapter(adapters.get(2)); try { test.getAdapterName(); } catch(Ice.ConnectionRefusedException ex) { } Ice.Endpoint[] endpoints = test.ice_getEndpoints(); adapters.clear(); // // Now, re-activate the adapters with the same endpoints in the opposite // order. // adapters.add(com.createObjectAdapter("Adapter66", endpoints[2].toString())); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter66"); i++); test(i == nRetry); adapters.add(com.createObjectAdapter("Adapter65", endpoints[1].toString())); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter65"); i++); test(i == nRetry); adapters.add(com.createObjectAdapter("Adapter64", endpoints[0].toString())); for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter64"); i++); test(i == nRetry); deactivate(com, adapters); } System.out.println("ok"); System.out.print("testing per request binding and ordered endpoint selection and AMI... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("AdapterAMI61", "default")); adapters.add(com.createObjectAdapter("AdapterAMI62", "default")); adapters.add(com.createObjectAdapter("AdapterAMI63", "default")); TestIntfPrx test = createTestIntfPrx(adapters); test = TestIntfPrxHelper.uncheckedCast(test.ice_endpointSelection(Ice.EndpointSelectionType.Ordered)); test(test.ice_getEndpointSelection() == Ice.EndpointSelectionType.Ordered); test = TestIntfPrxHelper.uncheckedCast(test.ice_connectionCached(false)); test(!test.ice_isConnectionCached()); int nRetry = 5; int i; // // Ensure that endpoints are tried in order by deactiving the adapters // one after the other. // for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI61"); i++); test(i == nRetry); com.deactivateObjectAdapter(adapters.get(0)); for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI62"); i++); test(i == nRetry); com.deactivateObjectAdapter(adapters.get(1)); for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI63"); i++); test(i == nRetry); com.deactivateObjectAdapter(adapters.get(2)); try { test.getAdapterName(); } catch(Ice.ConnectionRefusedException ex) { } Ice.Endpoint[] endpoints = test.ice_getEndpoints(); adapters.clear(); // // Now, re-activate the adapters with the same endpoints in the opposite // order. // adapters.add(com.createObjectAdapter("AdapterAMI66", endpoints[2].toString())); for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI66"); i++); test(i == nRetry); adapters.add(com.createObjectAdapter("AdapterAMI65", endpoints[1].toString())); for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI65"); i++); test(i == nRetry); adapters.add(com.createObjectAdapter("AdapterAMI64", endpoints[0].toString())); for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI64"); i++); test(i == nRetry); deactivate(com, adapters); } System.out.println("ok"); System.out.print("testing endpoint mode filtering... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("Adapter71", "default")); adapters.add(com.createObjectAdapter("Adapter72", "udp")); TestIntfPrx test = createTestIntfPrx(adapters); test(test.getAdapterName().equals("Adapter71")); TestIntfPrx testUDP = TestIntfPrxHelper.uncheckedCast(test.ice_datagram()); test(test.ice_getConnection() != testUDP.ice_getConnection()); try { testUDP.getAdapterName(); } catch(Ice.TwowayOnlyException ex) { } } System.out.println("ok"); if(communicator.getProperties().getProperty("Ice.Plugin.IceSSL").length() > 0) { System.out.print("testing unsecure vs. secure endpoints... "); System.out.flush(); { java.util.List adapters = new java.util.ArrayList(); adapters.add(com.createObjectAdapter("Adapter81", "ssl")); adapters.add(com.createObjectAdapter("Adapter82", "tcp")); TestIntfPrx test = createTestIntfPrx(adapters); int i; for(i = 0; i < 5; i++) { test(test.getAdapterName().equals("Adapter82")); test.ice_getConnection().close(false); } TestIntfPrx testSecure = TestIntfPrxHelper.uncheckedCast(test.ice_secure(true)); test(testSecure.ice_isSecure()); testSecure = TestIntfPrxHelper.uncheckedCast(test.ice_secure(false)); test(!testSecure.ice_isSecure()); testSecure = TestIntfPrxHelper.uncheckedCast(test.ice_secure(true)); test(testSecure.ice_isSecure()); test(test.ice_getConnection() != testSecure.ice_getConnection()); com.deactivateObjectAdapter(adapters.get(1)); for(i = 0; i < 5; i++) { test(test.getAdapterName().equals("Adapter81")); test.ice_getConnection().close(false); } com.createObjectAdapter("Adapter83", (test.ice_getEndpoints()[1]).toString()); // Reactive tcp OA. for(i = 0; i < 5; i++) { test(test.getAdapterName().equals("Adapter83")); test.ice_getConnection().close(false); } com.deactivateObjectAdapter(adapters.get(0)); try { testSecure.ice_ping(); test(false); } catch(Ice.ConnectionRefusedException ex) { } deactivate(com, adapters); } System.out.println("ok"); } com.shutdown(); } }