diff options
Diffstat (limited to '')
-rw-r--r-- | sca-java-1.x/tags/1.5-RC0/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java | 924 |
1 files changed, 0 insertions, 924 deletions
diff --git a/sca-java-1.x/tags/1.5-RC0/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java b/sca-java-1.x/tags/1.5-RC0/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java deleted file mode 100644 index 2073e4b154..0000000000 --- a/sca-java-1.x/tags/1.5-RC0/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java +++ /dev/null @@ -1,924 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.tuscany.sca.binding.erlang.testing; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.fail; - -import java.io.IOException; - -import org.apache.tuscany.sca.binding.erlang.impl.TypeMismatchException; -import org.apache.tuscany.sca.binding.erlang.impl.exceptions.ErlangException; -import org.apache.tuscany.sca.binding.erlang.testing.dynaignore.IgnorableRunner; -import org.apache.tuscany.sca.binding.erlang.testing.dynaignore.IgnoreTest; -import org.apache.tuscany.sca.host.embedded.SCADomain; -import org.junit.AfterClass; -import org.junit.Before; -import org.junit.BeforeClass; -import org.junit.Test; -import org.junit.runner.RunWith; - -import com.ericsson.otp.erlang.OtpAuthException; -import com.ericsson.otp.erlang.OtpConnection; -import com.ericsson.otp.erlang.OtpErlangAtom; -import com.ericsson.otp.erlang.OtpErlangBinary; -import com.ericsson.otp.erlang.OtpErlangBoolean; -import com.ericsson.otp.erlang.OtpErlangDouble; -import com.ericsson.otp.erlang.OtpErlangInt; -import com.ericsson.otp.erlang.OtpErlangList; -import com.ericsson.otp.erlang.OtpErlangLong; -import com.ericsson.otp.erlang.OtpErlangObject; -import com.ericsson.otp.erlang.OtpErlangString; -import com.ericsson.otp.erlang.OtpErlangTuple; -import com.ericsson.otp.erlang.OtpMbox; -import com.ericsson.otp.erlang.OtpNode; -import com.ericsson.otp.erlang.OtpPeer; -import com.ericsson.otp.erlang.OtpSelf; - -/** - * Test is annotated with test runner, which will ignore tests if epmd is not - * available - * - * @version $Rev$ $Date$ - */ -@RunWith(IgnorableRunner.class) -public class ReferenceServiceTestCase { - - private static final String EPMD_COMMAND = "epmd"; - - private static MboxInterface mboxReference; - private static MboxInterface timeoutMboxReference; - private static ServiceInterface moduleReference; - private static ServiceInterface cookieModuleReference; - private static ServiceInterface invalidCookieModuleReference; - private static ServiceInterface timeoutModuleReference; - private static OtpNode serNode; - private static OtpMbox serMbox; - private static OtpNode refNode; - private static OtpMbox refMbox; - private static Process epmdProcess; - - @BeforeClass - public static void init() throws IOException { - try { - epmdProcess = Runtime.getRuntime().exec(EPMD_COMMAND); - SCADomain domain = SCADomain - .newInstance("ErlangReference.composite"); - SCADomain.newInstance("ErlangService.composite"); - ReferenceTestComponentImpl component = domain.getService( - ReferenceTestComponentImpl.class, "ReferenceTest"); - - mboxReference = component.getMboxReference(); - timeoutMboxReference = component.getTimeoutMboxReference(); - moduleReference = component.getModuleReference(); - cookieModuleReference = component.getCookieModuleReference(); - invalidCookieModuleReference = component - .getInvalidCookieModuleReference(); - timeoutModuleReference = component.getTimeoutModuleReference(); - - serNode = new OtpNode("MboxServer"); - serMbox = serNode.createMbox("sendArgs"); - refNode = new OtpNode("MboxClient"); - refMbox = refNode.createMbox("connector_to_SCA_mbox"); - } catch (IOException e) { - System.out.println("Problem executing " + EPMD_COMMAND + ": " - + e.getLocalizedMessage() + ". Tests will be IGNORED."); - } - } - - @AfterClass - public static void clean() { - if (epmdProcess != null) { - epmdProcess.destroy(); - } - } - - @Before - public void before() { - if (epmdProcess == null) { - throw new IgnoreTest(); - } - } - - /** - * Tests passing strings - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testStrings() throws Exception { - String strArg = "Test message"; - String strResult = "OK"; - MboxListener mboxListener = new MboxListener(serMbox, strResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - String testResult = mboxReference.sendArgs(strArg); - assertEquals(strArg, ((OtpErlangString) mboxListener.getMsg()) - .stringValue()); - assertEquals(strResult, testResult); - } - - /** - * Tests passing booleans - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testBooleans() throws Exception { - boolean booleanArg = true; - boolean booleanResult = false; - MboxListener mboxListener = new MboxListener(serMbox, booleanResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - boolean testResult = mboxReference.sendArgs(booleanArg); - assertEquals(booleanArg, ((OtpErlangAtom) mboxListener.getMsg()) - .booleanValue()); - assertEquals(booleanResult, testResult); - } - - /** - * Tests passing floats - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testFloats() throws Exception { - float floatArg = 1.0f; - float floatResult = 2.0f; - MboxListener mboxListener = new MboxListener(serMbox, floatResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - float testResult = mboxReference.sendArgs(floatArg); - assertEquals(floatArg, ((OtpErlangDouble) mboxListener.getMsg()) - .doubleValue(), 0); - assertEquals(floatResult, testResult, 0); - } - - /** - * Tests passing doubles - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testDoubles() throws Exception { - double doubleArg = 1.0f; - double doubleResult = 2.0f; - MboxListener mboxListener = new MboxListener(serMbox, doubleResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - double testResult = mboxReference.sendArgs(doubleArg); - assertEquals(doubleArg, ((OtpErlangDouble) mboxListener.getMsg()) - .doubleValue(), 0); - assertEquals(doubleResult, testResult, 0); - } - - /** - * Tests passing long values - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testLongs() throws Exception { - long longArg = 1; - long longResult = 2; - MboxListener mboxListener = new MboxListener(serMbox, longResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - long testResult = mboxReference.sendArgs(longArg); - assertEquals(longArg, ((OtpErlangLong) mboxListener.getMsg()) - .longValue(), 0); - assertEquals(longResult, testResult, 0); - } - - /** - * Tests passing integers - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testInts() throws Exception { - int intArg = 1; - int intResult = 2; - MboxListener mboxListener = new MboxListener(serMbox, intResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - int testResult = mboxReference.sendArgs(intArg); - assertEquals(intArg, - ((OtpErlangLong) mboxListener.getMsg()).intValue(), 0); - assertEquals(intResult, testResult, 0); - } - - /** - * Tests passing chars - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testChars() throws Exception { - char charArg = 1; - char charResult = 2; - MboxListener mboxListener = new MboxListener(serMbox, charResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - char testResult = mboxReference.sendArgs(charArg); - assertEquals(charArg, ((OtpErlangLong) mboxListener.getMsg()) - .charValue(), 0); - assertEquals(charResult, testResult, 0); - } - - /** - * Tests passing shorts - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testShorts() throws Exception { - short shortArg = 1; - short shortResult = 2; - MboxListener mboxListener = new MboxListener(serMbox, shortResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - short testResult = mboxReference.sendArgs(shortArg); - assertEquals(shortArg, ((OtpErlangLong) mboxListener.getMsg()) - .shortValue(), 0); - assertEquals(shortResult, testResult, 0); - } - - /** - * Tests passing bytes - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testBytes() throws Exception { - byte byteArg = 1; - byte byteResult = 2; - MboxListener mboxListener = new MboxListener(serMbox, byteResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - byte testResult = mboxReference.sendArgs(byteArg); - assertEquals(byteArg, ((OtpErlangLong) mboxListener.getMsg()) - .byteValue(), 0); - assertEquals(byteResult, testResult, 0); - } - - /** - * Tests passing multiple arguments - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testMultipleArguments() throws Exception { - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - String testString = "TupleString"; - int testInt = 10; - mboxReference.sendArgs(testInt, testString); - // FIXME: - // without following sleep an exception occurs: - // com.ericsson.otp.erlang.OtpErlangDecodeException: Cannot read from - // input stream - Thread.sleep(100); - assertEquals(testInt, ((OtpErlangLong) ((OtpErlangTuple) mboxListener - .getMsg()).elementAt(0)).longValue()); - assertEquals(testString, - ((OtpErlangString) ((OtpErlangTuple) mboxListener.getMsg()) - .elementAt(1)).stringValue()); - } - - /** - * Tests passing tuples - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testTuples() throws Exception { - StructuredTuple tupleResult = new StructuredTuple(); - tupleResult.arg1.arg1 = 1; - tupleResult.arg1.arg2 = "Tuple inside tuple"; - tupleResult.arg2 = "Tuple!"; - tupleResult.arg3 = true; - MboxListener mboxListener = new MboxListener(serMbox, tupleResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - StructuredTuple testArg = new StructuredTuple(); - testArg.arg2 = "Arg2a"; - testArg.arg3 = true; - testArg.arg1.arg1 = 10; - testArg.arg1.arg2 = "Arg2b"; - StructuredTuple testResult = mboxReference.sendArgs(testArg); - assertEquals(tupleResult, testResult); - OtpErlangTuple received = (OtpErlangTuple) mboxListener.getMsg(); - assertEquals(testArg.arg1.arg1, - ((OtpErlangLong) ((OtpErlangTuple) received.elementAt(0)) - .elementAt(0)).longValue()); - assertEquals(testArg.arg1.arg2, - ((OtpErlangString) ((OtpErlangTuple) received.elementAt(0)) - .elementAt(1)).stringValue()); - assertEquals(testArg.arg2, ((OtpErlangString) received.elementAt(1)) - .stringValue()); - assertEquals(testArg.arg3, ((OtpErlangAtom) received.elementAt(2)) - .booleanValue()); - } - - /** - * Test passing Erlang binaries - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testBinaries() throws Exception { - byte[] testArg = { 0, 1 }; - MboxListener mboxListener = new MboxListener(serMbox, testArg); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - byte[] testResult = mboxReference.sendArgs(testArg); - assertEquals(testArg.length, testResult.length); - for (int i = 0; i < testArg.length; i++) { - assertEquals(testArg[i], testResult[i]); - } - OtpErlangBinary received = (OtpErlangBinary) mboxListener.getMsg(); - assertEquals(testArg.length, received.size()); - for (int i = 0; i < testArg.length; i++) { - assertEquals(testArg[i], received.binaryValue()[i]); - } - } - - /** - * Tests passing lists - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testLists() throws Exception { - String[] testArg = new String[] { "One", "Two", "Three" }; - MboxListener mboxListener = new MboxListener(serMbox, testArg); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - String[] testResult = mboxReference.sendArgs(testArg); - assertEquals(testArg.length, testResult.length); - for (int i = 0; i < testArg.length; i++) { - assertEquals(testArg[i], testResult[i]); - } - OtpErlangList received = (OtpErlangList) mboxListener.getMsg(); - assertEquals(testArg.length, received.arity()); - for (int i = 0; i < testArg.length; i++) { - assertEquals(testArg[i], ((OtpErlangString) received.elementAt(i)) - .stringValue()); - } - } - - /** - * Tests passing multidimensional lists - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testMultiDimLists() throws Exception { - String[][] testArg = new String[][] { { "One", "Two" }, - { "Three", "Four", "Five" }, { "Six" } }; - MboxListener mboxListener = new MboxListener(serMbox, testArg); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - String[][] testResult = mboxReference.sendArgs(testArg); - assertEquals(testArg.length, testResult.length); - for (int i = 0; i < testArg.length; i++) { - for (int j = 0; j < testArg[i].length; j++) { - assertEquals(testArg[i][j], testResult[i][j]); - } - } - OtpErlangList received = (OtpErlangList) mboxListener.getMsg(); - assertEquals(testArg.length, received.arity()); - for (int i = 0; i < testArg.length; i++) { - for (int j = 0; j < testArg[i].length; j++) { - assertEquals(testArg[i][j], - (((OtpErlangString) ((OtpErlangList) received - .elementAt(i)).elementAt(j)).stringValue())); - } - } - } - - /** - * Tests passing Erlang atoms. It provides cases for annotating result - * types, parameters and fields in java classes - tuples. - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testAtoms() throws Exception { - AtomTuple arg2 = new AtomTuple(); - arg2.field1 = "test"; - String arg1 = "First arg"; - String[] strResult = { "Hello", "World" }; - MboxListener mboxListener = new MboxListener(serMbox, strResult); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - String[] testResult = mboxReference.sendArgs(arg1, arg2); - assertEquals(strResult[0], testResult[0]); - assertEquals(strResult[1], testResult[1]); - - assertEquals(arg1, ((OtpErlangAtom) ((OtpErlangTuple) mboxListener - .getMsg()).elementAt(0)).atomValue()); - - assertEquals( - arg2.field1, - ((OtpErlangAtom) ((OtpErlangTuple) ((OtpErlangTuple) mboxListener - .getMsg()).elementAt(1)).elementAt(0)).atomValue()); - - // test multi dimensional arrays - String[][] arg = { { "this", "is" }, { "a" }, { "test" } }; - mboxListener = new MboxListener(serMbox, arg); - mboxThread = new Thread(mboxListener); - mboxThread.start(); - String[][] multiDimRes = mboxReference.sendArgs(arg, 1); - for (int i = 0; i < arg.length; i++) { - for (int j = 0; j < arg[i].length; j++) { - assertEquals(arg[i][j], multiDimRes[i][j]); - assertEquals( - arg[i][j], - ((OtpErlangAtom) ((OtpErlangList) ((OtpErlangList) ((OtpErlangTuple) mboxListener - .getMsg()).elementAt(0)).elementAt(i)) - .elementAt(j)).atomValue()); - } - } - - } - - /** - * Tests Erlang Atom types on service side - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testServiceAtoms() throws Exception { - String[] args = { "Say", "Atoms" }; - OtpErlangObject[] toList = new OtpErlangObject[2]; - toList[0] = new OtpErlangString(args[0]); - toList[1] = new OtpErlangString(args[1]); - OtpErlangList list = new OtpErlangList(toList); - OtpErlangObject[] toTuple = new OtpErlangObject[2]; - toTuple[0] = refMbox.self(); - toTuple[1] = list; - refMbox.send("sayAtoms", "RPCServerMbox", new OtpErlangTuple(toTuple)); - OtpErlangObject result = refMbox.receiveMsg().getMsg(); - assertEquals(args.length, ((OtpErlangList) result).arity()); - for (int i = 0; i < args.length; i++) { - assertEquals(args[i], ((OtpErlangAtom) ((OtpErlangList) result) - .elementAt(i)).atomValue()); - } - } - - /** - * Tests mismatched interface - * - * @throws Exception - */ - @Test(timeout = 1000) - public void typeMismatch() throws Exception { - try { - StructuredTuple arg = new StructuredTuple(); - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - String[] arg = new String[] { "test" }; - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - long arg = 1; - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - int arg = 1; - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - short arg = 1; - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - char arg = 1; - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - byte arg = 1; - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - double arg = 1; - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - float arg = 1; - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - String arg = "1"; - MboxListener mboxListener = new MboxListener(serMbox, true); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - - try { - boolean arg = true; - MboxListener mboxListener = new MboxListener(serMbox, 1); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - mboxReference.sendArgs(arg); - } catch (Exception e) { - assertEquals(TypeMismatchException.class, e.getClass()); - System.out.println(e.getMessage()); - } - } - - /** - * Basic RPC test, without arguments - * - * @throws Exception - */ - @Test(timeout = 10000000) - public void testRPC() throws Exception { - String[] result = moduleReference.sayHellos(); - assertEquals(2, result.length); - assertEquals("1", result[0]); - assertEquals("2", result[1]); - } - - /** - * Tests RPC with arguments - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testRPCWithArgs() throws Exception { - String arg1 = "One"; - String arg2 = "Two"; - String testResult = moduleReference.sayHello(arg1, arg2); - assertEquals("Hello " + arg1 + " " + arg2, testResult); - } - - /** - * Tests RPC with structured arguments - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testRPCWithComplexArgs() throws Exception { - StructuredTuple arg = new StructuredTuple(); - arg.arg1.arg2 = "Not empty"; - arg.arg2 = "Not empty"; - StructuredTuple testResult = moduleReference.passComplexArgs(arg, - new String[] { "some", "array" }); - assertEquals(arg, testResult); - } - - /** - * Tests RPC with no result - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testRPCWithVoidResult() throws Exception { - moduleReference.doNothing(); - } - - /** - * Tests handling requests pointing to unknown functions - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testUnknownFunction() throws Exception { - - // following functions differs by parameters - - try { - moduleReference.sayHello(); - } catch (Exception e) { - assertEquals(ErlangException.class, e.getClass()); - } - - try { - moduleReference.sayHello("1"); - } catch (Exception e) { - assertEquals(ErlangException.class, e.getClass()); - } - - try { - moduleReference.sayHello(1, 2); - } catch (Exception e) { - assertEquals(ErlangException.class, e.getClass()); - } - - // for following ones name not exists - - moduleReference.notExist(); - - try { - moduleReference.notExistWithException(); - } catch (Exception e) { - assertEquals(ErlangException.class, e.getClass()); - } - } - - /** - * Tests mbox with retrieving and answering with basic arguments - * - * @throws Exception - */ - @Test(timeout = 2000) - public void testMbox() throws Exception { - OtpErlangObject[] args = new OtpErlangObject[2]; - args[0] = new OtpErlangString("world"); - args[1] = new OtpErlangString("!"); - OtpErlangTuple tuple = new OtpErlangTuple(args); - OtpErlangObject[] argsWithSender = new OtpErlangObject[2]; - argsWithSender[0] = refMbox.self(); - argsWithSender[1] = tuple; - refMbox.send("sayHello", "RPCServerMbox", new OtpErlangTuple( - argsWithSender)); - OtpErlangString result = (OtpErlangString) refMbox.receiveMsg() - .getMsg(); - assertEquals("Hello world !", result.stringValue()); - } - - /** - * Tests receiving reply without sending self PID - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testMsgWithoutPid() throws Exception { - OtpErlangObject[] args = new OtpErlangObject[2]; - args[0] = new OtpErlangString("world"); - args[1] = new OtpErlangString("!"); - refMbox.send("sayHello", "RPCServerMbox", new OtpErlangTuple(args)); - OtpErlangString result = (OtpErlangString) refMbox.receiveMsg() - .getMsg(); - assertEquals("Hello world !", result.stringValue()); - } - - /** - * Tests service mbox receiving complex message - * - * @throws Exception - */ - @Test(timeout = 2000) - public void testMboxWithComplexArgs() throws Exception { - int arg1 = 1; - String arg2 = "arg2"; - String arg3 = "arg3"; - boolean arg4 = true; - - OtpErlangObject[] smallTupleContent = new OtpErlangObject[2]; - smallTupleContent[0] = new OtpErlangInt(arg1); - smallTupleContent[1] = new OtpErlangString(arg2); - OtpErlangTuple smallTuple = new OtpErlangTuple(smallTupleContent); - OtpErlangObject[] structuredTupleContent = new OtpErlangObject[3]; - structuredTupleContent[0] = smallTuple; - structuredTupleContent[1] = new OtpErlangString(arg3); - structuredTupleContent[2] = new OtpErlangBoolean(arg4); - OtpErlangTuple structuredTuple = new OtpErlangTuple( - structuredTupleContent); - OtpErlangObject[] secondArg = new OtpErlangObject[2]; - secondArg[0] = new OtpErlangString("in"); - secondArg[1] = new OtpErlangString("array"); - OtpErlangList list = new OtpErlangList(secondArg); - OtpErlangObject[] argsContent = new OtpErlangObject[2]; - argsContent[0] = structuredTuple; - argsContent[1] = list; - OtpErlangTuple args = new OtpErlangTuple(argsContent); - OtpErlangObject[] withSender = new OtpErlangObject[2]; - withSender[0] = refMbox.self(); - withSender[1] = args; - refMbox.send("passComplexArgs", "RPCServerMbox", new OtpErlangTuple( - withSender)); - OtpErlangObject result = refMbox.receiveMsg().getMsg(); - assertEquals(arg1, - ((OtpErlangLong) ((OtpErlangTuple) ((OtpErlangTuple) result) - .elementAt(0)).elementAt(0)).intValue()); - assertEquals(arg2, - ((OtpErlangString) ((OtpErlangTuple) ((OtpErlangTuple) result) - .elementAt(0)).elementAt(1)).stringValue()); - assertEquals(arg3, ((OtpErlangString) ((OtpErlangTuple) result) - .elementAt(1)).stringValue()); - assertEquals(arg4, ((OtpErlangAtom) ((OtpErlangTuple) result) - .elementAt(2)).booleanValue()); - } - - /** - * Tests timeout feature for reference binding messaging - * - * @throws Exception - */ - @Test(timeout = 4000) - public void testMboxReferenceTimeouts() throws Exception { - long timeBiggerThanTimeout = 1000; - String stringResult = "result"; - - // doing test for response time bigger than declared timeout (500) - MboxListener mboxListener = new MboxListener(serMbox, stringResult, - timeBiggerThanTimeout); - Thread mboxThread = new Thread(mboxListener); - mboxThread.start(); - try { - // timeout exception expected - timeoutMboxReference.sendArgs(""); - fail("Exception expected"); - } catch (Exception e) { - assertEquals(ErlangException.class, e.getClass()); - assertEquals(e.getCause().getClass(), InterruptedException.class); - } - - // doing test for response time smaller than declared timeout (500) - mboxListener = new MboxListener(serMbox, stringResult, 0); - mboxThread = new Thread(mboxListener); - mboxThread.start(); - // expecting no timeout exception - String testResult = timeoutMboxReference.sendArgs(""); - assertEquals(stringResult, testResult); - - // doing test for response time which will cause timeout. This time - // there is no declared exception in users operation so we expect no - // exception and null result - mboxListener = new MboxListener(serMbox, new byte[1], - timeBiggerThanTimeout); - mboxThread = new Thread(mboxListener); - mboxThread.start(); - // expecting no timeout exception - byte[] result = timeoutMboxReference.sendArgs(new byte[1]); - assertEquals(null, result); - } - - /** - * Tests timeout feature for reference binding RPC - * - * @throws Exception - */ - @Test(timeout = 4000) - public void testRpcReferenceTimeouts() throws Exception { - - // doing test for response time which will cause timeout. Method does - // not - // declare exception so only null value will be returned - String result1 = timeoutModuleReference.sayHello("hello", "world"); - assertEquals(null, result1); - - // doing test for response time which will cause timeout. Method declare - // exception, so expecting one - try { - timeoutModuleReference.sayHellos(); - fail("Exception expected"); - } catch (Exception e) { - assertEquals(ErlangException.class, e.getClass()); - } - - // doing test for response time shorter than timeout - timeoutModuleReference.doNothing(); - } - - /** - * Tests timeout feature for service side bindings - * - * @throws Exception - */ - @Test(timeout = 4000) - public void testServiceTimeouts() throws Exception { - OtpSelf self = new OtpSelf("tmp_connector_" - + System.currentTimeMillis()); - OtpPeer peer = new OtpPeer("RPCServerTimeout"); - OtpConnection connection = self.connect(peer); - // delay message sending after connecting - Thread.sleep(1000); - // service binding timeout set to 500 so after that time it will give up - // and close connection - try { - connection.send("rex", new OtpErlangString("test")); - fail("Exception expected"); - } catch (Exception e) { - assertEquals(IOException.class, e.getClass()); - } - - connection = self.connect(peer); - // sending message immediately and encountering no connection close - connection.send("rex", new OtpErlangString("test")); - - } - - /** - * Tests cookie feature for both reference and service bindings RPC - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testReferenceCookies() throws Exception { - // testing wrong cookie - try { - invalidCookieModuleReference.sayHellos(); - fail("Exception expected"); - } catch (Exception e) { - assertEquals(ErlangException.class, e.getClass()); - assertEquals(OtpAuthException.class, e.getCause().getClass()); - } - - // testing correct cookie - cookieModuleReference.sayHellos(); - } - - /** - * Tests fix which allow to send message with no user specified content (in - * fact always will be some content - senders PID at the content beginning). - * - * @throws Exception - */ - @Test(timeout = 1000) - public void testMboxNoArgs() throws Exception { - mboxReference.sendArgs(); - // no exception should occur - } - -} |