diff options
Diffstat (limited to 'java/test/Ice/binding/AllTests.java')
| -rw-r--r-- | java/test/Ice/binding/AllTests.java | 1340 |
1 files changed, 670 insertions, 670 deletions
diff --git a/java/test/Ice/binding/AllTests.java b/java/test/Ice/binding/AllTests.java index 3feb1c2eb9c..c1422f1f2ba 100644 --- a/java/test/Ice/binding/AllTests.java +++ b/java/test/Ice/binding/AllTests.java @@ -22,700 +22,700 @@ public class AllTests static class GetAdapterNameCB extends AMI_TestIntf_getAdapterName { - synchronized public void - ice_response(String adapterName) - { - _name = adapterName; - notify(); - } - - public void - ice_exception(Ice.LocalException ex) + synchronized public void + ice_response(String adapterName) { - test(false); - } + _name = adapterName; + notify(); + } + + public void + ice_exception(Ice.LocalException ex) + { + test(false); + } - public void - ice_exception(Ice.UserException ex) + public void + ice_exception(Ice.UserException ex) { - test(false); - } + test(false); + } - synchronized public String - getResult() + synchronized public String + getResult() { - while(_name == null) - { - try - { - wait(); - } - catch(java.lang.InterruptedException ex) - { - } - } - return _name; - } - - private String _name = null; + 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(); + 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 = ((RemoteObjectAdapterPrx)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()]))); + java.util.List endpoints = new java.util.ArrayList(); + TestIntfPrx test = null; + java.util.Iterator p = adapters.iterator(); + while(p.hasNext()) + { + test = ((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)p.next()); - } + java.util.Iterator p = adapters.iterator(); + while(p.hasNext()) + { + communicator.deactivateObjectAdapter((RemoteObjectAdapterPrx)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()) - { - ((RemoteObjectAdapterPrx)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()) - { - ((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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 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()) - { - ((RemoteObjectAdapterPrx)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()) - { - ((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); - for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter32"); i++); - test(i == nRetry); - com.deactivateObjectAdapter((RemoteObjectAdapterPrx)adapters.get(1)); - for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter33"); i++); - test(i == nRetry); - com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); - - names.add("Adapter52"); - names.add("Adapter53"); - while(!names.isEmpty()) - { - names.remove(test.getAdapterName()); - } - - com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); - - names.add("AdapterAMI52"); - names.add("AdapterAMI53"); - while(!names.isEmpty()) - { - names.remove(getAdapterNameWithAMI(test)); - } - - com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); - for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter62"); i++); - test(i == nRetry); - com.deactivateObjectAdapter((RemoteObjectAdapterPrx)adapters.get(1)); - for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter63"); i++); - test(i == nRetry); - com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); - for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI62"); i++); - test(i == nRetry); - com.deactivateObjectAdapter((RemoteObjectAdapterPrx)adapters.get(1)); - for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI63"); i++); - test(i == nRetry); - com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); - try - { - testSecure.ice_ping(); - test(false); - } - catch(Ice.ConnectionRefusedException ex) - { - } - - deactivate(com, adapters); - } - System.out.println("ok"); - } - - com.shutdown(); - + 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()) + { + ((RemoteObjectAdapterPrx)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()) + { + ((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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 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()) + { + ((RemoteObjectAdapterPrx)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()) + { + ((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); + for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter32"); i++); + test(i == nRetry); + com.deactivateObjectAdapter((RemoteObjectAdapterPrx)adapters.get(1)); + for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter33"); i++); + test(i == nRetry); + com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); + + names.add("Adapter52"); + names.add("Adapter53"); + while(!names.isEmpty()) + { + names.remove(test.getAdapterName()); + } + + com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); + + names.add("AdapterAMI52"); + names.add("AdapterAMI53"); + while(!names.isEmpty()) + { + names.remove(getAdapterNameWithAMI(test)); + } + + com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); + for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter62"); i++); + test(i == nRetry); + com.deactivateObjectAdapter((RemoteObjectAdapterPrx)adapters.get(1)); + for(i = 0; i < nRetry && test.getAdapterName().equals("Adapter63"); i++); + test(i == nRetry); + com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); + for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI62"); i++); + test(i == nRetry); + com.deactivateObjectAdapter((RemoteObjectAdapterPrx)adapters.get(1)); + for(i = 0; i < nRetry && getAdapterNameWithAMI(test).equals("AdapterAMI63"); i++); + test(i == nRetry); + com.deactivateObjectAdapter((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)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((RemoteObjectAdapterPrx)adapters.get(0)); + try + { + testSecure.ice_ping(); + test(false); + } + catch(Ice.ConnectionRefusedException ex) + { + } + + deactivate(com, adapters); + } + System.out.println("ok"); + } + + com.shutdown(); + } } |