From fdfa3d0df9dc79314411bf455cc71c5677925e1b Mon Sep 17 00:00:00 2001 From: wjaniszewski Date: Sun, 15 Mar 2009 11:19:14 +0000 Subject: Enabled exposing SCA components as Erlang message boxes. git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@754654 13f79535-47bb-0310-9956-ffa450edef68 --- .../erlang/impl/ErlangBindingProviderFactory.java | 6 +- .../sca/binding/erlang/impl/ErlangInvoker.java | 8 +- .../sca/binding/erlang/impl/ErlangNode.java | 100 ++++++-- .../sca/binding/erlang/impl/ErlangNodeElement.java | 50 ++++ .../impl/ErlangReferenceBindingProvider.java | 85 +++---- .../erlang/impl/ErlangServiceBindingProvider.java | 83 +++---- .../sca/binding/erlang/impl/MessageHelper.java | 78 ++++-- .../sca/binding/erlang/impl/RpcExecutor.java | 176 -------------- .../sca/binding/erlang/impl/ServiceExecutor.java | 262 +++++++++++++++++++++ .../binding/erlang/impl/TypeMismatchException.java | 46 ++-- .../erlang/impl/exceptions/ErlangException.java | 26 +- .../erlang/impl/types/BooleanTypeHelper.java | 24 +- .../binding/erlang/impl/types/ByteTypeHelper.java | 16 +- .../binding/erlang/impl/types/CharTypeHelper.java | 16 +- .../erlang/impl/types/DoubleTypeHelper.java | 16 +- .../binding/erlang/impl/types/FloatTypeHelper.java | 16 +- .../binding/erlang/impl/types/IntTypeHelper.java | 16 +- .../binding/erlang/impl/types/ListTypeHelper.java | 55 +++-- .../binding/erlang/impl/types/LongTypeHelper.java | 16 +- .../binding/erlang/impl/types/ShortTypeHelper.java | 16 +- .../erlang/impl/types/StringTypeHelper.java | 16 +- .../binding/erlang/impl/types/TupleTypeHelper.java | 76 +++--- .../sca/binding/erlang/impl/types/TypeHelper.java | 7 +- .../erlang/impl/types/TypeHelpersProxy.java | 72 +++++- .../sca/binding/erlang/testing/MboxInterface.java | 54 +++-- .../sca/binding/erlang/testing/MboxListener.java | 4 +- .../binding/erlang/testing/ModuleInterface.java | 28 ++- .../erlang/testing/ReferenceServiceTestCase.java | 139 ++++++++--- .../erlang/testing/ReferenceTestComponent.java | 22 ++ .../erlang/testing/ReferenceTestComponentImpl.java | 82 ++++--- .../binding/erlang/testing/ServiceInterface.java | 54 +++-- .../erlang/testing/ServiceTestComponent.java | 36 ++- .../erlang/testing/ServiceTestComponentImpl.java | 47 +++- .../testing/ServiceTestComponentImplClone.java | 47 +++- .../sca/binding/erlang/testing/SmallTuple.java | 19 +- .../binding/erlang/testing/StructuredTuple.java | 22 +- .../erlang/testing/dynaignore/IgnorableRunner.java | 3 + .../erlang/testing/dynaignore/IgnoreTest.java | 3 + .../src/test/resources/ErlangService.composite | 4 + 39 files changed, 1254 insertions(+), 592 deletions(-) create mode 100644 sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangNodeElement.java delete mode 100644 sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/RpcExecutor.java create mode 100644 sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ServiceExecutor.java (limited to 'sandbox/wjaniszewski') diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProviderFactory.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProviderFactory.java index f823be2d8f..f4114132c1 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProviderFactory.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProviderFactory.java @@ -32,7 +32,7 @@ import org.apache.tuscany.sca.runtime.RuntimeComponentReference; import org.apache.tuscany.sca.runtime.RuntimeComponentService; /** - * @version $Rev: $ $Date: $ + * @version $Rev$ $Date$ */ public class ErlangBindingProviderFactory implements BindingProviderFactory { @@ -40,9 +40,9 @@ public class ErlangBindingProviderFactory implements private Map nodes = new HashMap(); public ErlangBindingProviderFactory(ExtensionPointRegistry registry) { - + } - + /** * @see org.apache.tuscany.sca.provider.BindingProviderFactory#createReferenceBindingProvider(org.apache.tuscany.sca.runtime.RuntimeComponent, * org.apache.tuscany.sca.runtime.RuntimeComponentReference, diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangInvoker.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangInvoker.java index fd9e89bc2d..9ed3713db4 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangInvoker.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangInvoker.java @@ -37,7 +37,7 @@ import com.ericsson.otp.erlang.OtpPeer; import com.ericsson.otp.erlang.OtpSelf; /** - * @version $Rev: $ $Date: $ + * @version $Rev$ $Date$ */ public class ErlangInvoker implements Invoker { @@ -59,6 +59,7 @@ public class ErlangInvoker implements Invoker { tmpMbox.send(msg.getOperation().getName(), binding.getNode(), msgPayload); if (msg.getOperation().getOutputType() != null) { + // TODO: add timeouts, timeout declaration method? OtpMsg resultMsg = tmpMbox.receiveMsg(); OtpErlangObject result = resultMsg.getMsg(); msg.setBody(TypeHelpersProxy.toJava(result, msg.getOperation() @@ -92,14 +93,15 @@ public class ErlangInvoker implements Invoker { OtpErlangTuple message = MessageHelper.rpcMessage(self.pid(), self .createRef(), binding.getModule(), msg.getOperation() .getName(), params); - connection.send("rex", message); + connection.send(MessageHelper.RPC_MBOX, message); OtpErlangObject result = connection.receiveRPC(); if (MessageHelper.isfunctionUndefMessage(result)) { // TODO: externalize message? Exception e = new ErlangException( "No such function in referenced Erlang node."); if (msg.getOperation().getFaultTypes().size() == 0) { - // TODO: no way to throw exception, log it (temporary as System.out) + // TODO: no way to throw exception, log it (temporary as + // System.out) // TODO: do we really want not to throw any exception? System.out.println("PROBLEM: " + e.getMessage()); // in this case we don't throw occured problem, so we need diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangNode.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangNode.java index a5cfbe6d90..78ffdfaa49 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangNode.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangNode.java @@ -1,25 +1,52 @@ +/* + * 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.impl; +import java.util.ArrayList; import java.util.HashMap; +import java.util.List; import java.util.Map; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import org.apache.tuscany.sca.binding.erlang.ErlangBinding; import org.apache.tuscany.sca.binding.erlang.impl.exceptions.ErlangException; +import org.apache.tuscany.sca.interfacedef.Operation; import org.apache.tuscany.sca.runtime.RuntimeComponentService; import com.ericsson.otp.erlang.OtpConnection; import com.ericsson.otp.erlang.OtpSelf; +/** + * @version $Rev$ $Date$ + */ public class ErlangNode implements Runnable { - private Map services = new HashMap(); - private Map bindings = new HashMap(); + private Map erlangModules = new HashMap(); + private ErlangNodeElement erlangMbox; + private boolean mboxNode; private String name; private OtpSelf self; private ExecutorService executors; private boolean stopRequested; + private Map> groupedOperations; public ErlangNode(String name) throws Exception { this.name = name; @@ -42,8 +69,8 @@ public class ErlangNode implements Runnable { while (!stopRequested) { try { OtpConnection connection = self.accept(); - executors.execute(new RpcExecutor(services, bindings, - connection)); + executors.execute(new ServiceExecutor(connection, + groupedOperations, erlangModules, erlangMbox)); } catch (Exception e) { // TODO: handle exception e.printStackTrace(); @@ -51,30 +78,59 @@ public class ErlangNode implements Runnable { } } - public void registerModule(ErlangBinding binding, + public void registerBinding(ErlangBinding binding, RuntimeComponentService service) throws ErlangException { - if (services.containsKey(binding.getModule())) { - // TODO: externalize message - // TODO: really want to throw exception? Log only? - throw new ErlangException("Module " + binding.getModule() - + " already defined under " + name - + " node. Duplicate module won't be started"); + if (binding.isMbox()) { + if (mboxNode) { + // TODO: externalize message + // TODO: really want to throw exception? Log only? + throw new ErlangException("Node " + binding.getNode() + + " already defined as mbox node"); + } else { + List operations = service.getInterfaceContract() + .getInterface().getOperations(); + groupedOperations = new HashMap>(); + for (Operation operation : operations) { + List operationsGroup = groupedOperations + .get(operation.getName()); + if (operationsGroup == null) { + operationsGroup = new ArrayList(); + groupedOperations.put(operation.getName(), + operationsGroup); + } + operationsGroup.add(operation); + } + mboxNode = true; + erlangMbox = new ErlangNodeElement(); + erlangMbox.setService(service); + erlangMbox.setBinding(binding); + } } else { - if (services.size() == 0) { - // TODO: should ErlangNode manage its thread? - Thread selfThread = new Thread(this); - selfThread.start(); + if (erlangModules.containsKey(binding.getModule())) { + // TODO: externalize message + // TODO: really want to throw exception? Log only? + throw new ErlangException("Module " + binding.getModule() + + " already defined under " + name + + " node. Duplicate module won't be started"); + } else { + if (erlangModules.size() == 0) { + // TODO: should ErlangNode manage its thread? + Thread selfThread = new Thread(this); + selfThread.start(); + } + ErlangNodeElement module = new ErlangNodeElement(); + module.setService(service); + module.setBinding(binding); + erlangModules.put(binding.getModule(), module); } - services.put(binding.getModule(), service); - bindings.put(binding.getModule(), binding); } } - public void unregisterModule(ErlangBinding binding) throws ErlangException { - if (services.containsKey(binding.getModule())) { - services.remove(binding.getModule()); - bindings.remove(binding.getModule()); - if (services.size() == 0) { + public void unregisterBinding(ErlangBinding binding) throws ErlangException { + if (erlangModules.containsKey(binding.getModule())) { + erlangModules.remove(binding.getModule()); + erlangModules.remove(binding.getModule()); + if (erlangModules.size() == 0) { stop(); } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangNodeElement.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangNodeElement.java new file mode 100644 index 0000000000..f945a841ec --- /dev/null +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangNodeElement.java @@ -0,0 +1,50 @@ +/* + * 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.impl; + +import org.apache.tuscany.sca.binding.erlang.ErlangBinding; +import org.apache.tuscany.sca.runtime.RuntimeComponentService; + +/** + * Holds information (RuntimeComponentService, ErlangBindin) for element (program module, mbox) binded on node. + * @version $Rev$ $Date$ + */ +public class ErlangNodeElement { + + private ErlangBinding binding; + private RuntimeComponentService service; + + public void setBinding(ErlangBinding binding) { + this.binding = binding; + } + + public ErlangBinding getBinding() { + return binding; + } + + public void setService(RuntimeComponentService service) { + this.service = service; + } + + public RuntimeComponentService getService() { + return service; + } + +} diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangReferenceBindingProvider.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangReferenceBindingProvider.java index 0ce9d33238..b96a4524e1 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangReferenceBindingProvider.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangReferenceBindingProvider.java @@ -30,55 +30,58 @@ import org.apache.tuscany.sca.provider.ReferenceBindingProvider; import org.apache.tuscany.sca.runtime.RuntimeComponentReference; /** - * @version $Rev: $ $Date: $ + * @version $Rev$ $Date$ */ public class ErlangReferenceBindingProvider implements ReferenceBindingProvider { - private static final Logger logger = Logger.getLogger(ErlangReferenceBindingProvider.class.getName()); - private RuntimeComponentReference reference; - private ErlangBinding binding; + private static final Logger logger = Logger + .getLogger(ErlangReferenceBindingProvider.class.getName()); + private RuntimeComponentReference reference; + private ErlangBinding binding; - public ErlangReferenceBindingProvider(ErlangBinding binding, RuntimeComponentReference reference) { - this.reference = reference; - this.binding = binding; - } + public ErlangReferenceBindingProvider(ErlangBinding binding, + RuntimeComponentReference reference) { + this.reference = reference; + this.binding = binding; + } - /** - * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#createInvoker(org.apache.tuscany.sca.interfacedef.Operation) - */ - public Invoker createInvoker(Operation operation) { - try { - return new ErlangInvoker(binding); - } catch (Exception e) { - logger.log(Level.WARNING, "Exception during creating Erlang invoker", e); - } - return null; - } + /** + * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#createInvoker(org.apache.tuscany.sca.interfacedef.Operation) + */ + public Invoker createInvoker(Operation operation) { + try { + return new ErlangInvoker(binding); + } catch (Exception e) { + logger.log(Level.WARNING, + "Exception during creating Erlang invoker", e); + } + return null; + } - /** - * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#getBindingInterfaceContract() - */ - public InterfaceContract getBindingInterfaceContract() { - return reference.getInterfaceContract(); - } + /** + * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#getBindingInterfaceContract() + */ + public InterfaceContract getBindingInterfaceContract() { + return reference.getInterfaceContract(); + } - /** - * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#start() - */ - public void start() { - } + /** + * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#start() + */ + public void start() { + } - /** - * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#stop() - */ - public void stop() { - } + /** + * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#stop() + */ + public void stop() { + } - /** - * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#supportsOneWayInvocation() - */ - public boolean supportsOneWayInvocation() { - return false; - } + /** + * @see org.apache.tuscany.sca.provider.ReferenceBindingProvider#supportsOneWayInvocation() + */ + public boolean supportsOneWayInvocation() { + return false; + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java index 651067f4e7..38b9b197d6 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java @@ -26,56 +26,57 @@ import org.apache.tuscany.sca.runtime.RuntimeComponentService; import org.osoa.sca.ServiceRuntimeException; /** - * @version $Rev: 685180 $ $Date: 2008-08-12 16:17:26 +0100 (Tue, 12 Aug 2008) $ + * @version $Rev$ $Date$ */ public class ErlangServiceBindingProvider implements ServiceBindingProvider { - private RuntimeComponentService service; - private ErlangNode node; - private ErlangBinding binding; + private RuntimeComponentService service; + private ErlangNode node; + private ErlangBinding binding; - public ErlangServiceBindingProvider(ErlangNode node, ErlangBinding binding, RuntimeComponentService service) { - this.service = service; - this.binding = binding; - this.node = node; - } + public ErlangServiceBindingProvider(ErlangNode node, ErlangBinding binding, + RuntimeComponentService service) { + this.service = service; + this.binding = binding; + this.node = node; + } - /** - * @see org.apache.tuscany.sca.provider.ServiceBindingProvider#getBindingInterfaceContract() - */ - public InterfaceContract getBindingInterfaceContract() { - return service.getInterfaceContract(); - } + /** + * @see org.apache.tuscany.sca.provider.ServiceBindingProvider#getBindingInterfaceContract() + */ + public InterfaceContract getBindingInterfaceContract() { + return service.getInterfaceContract(); + } - /** - * @see org.apache.tuscany.sca.provider.ServiceBindingProvider#start() - */ - public void start() { - try { - node.registerModule(binding, service); - } catch (Exception e) { - throw new ServiceRuntimeException(e); - } + /** + * @see org.apache.tuscany.sca.provider.ServiceBindingProvider#start() + */ + public void start() { + try { + node.registerBinding(binding, service); + } catch (Exception e) { + throw new ServiceRuntimeException(e); + } - } + } - /** - * @see org.apache.tuscany.sca.provider.ServiceBindingProvider#stop() - */ - public void stop() { - try { - node.unregisterModule(binding); - } catch (Exception e) { - throw new ServiceRuntimeException(e); - } + /** + * @see org.apache.tuscany.sca.provider.ServiceBindingProvider#stop() + */ + public void stop() { + try { + node.unregisterBinding(binding); + } catch (Exception e) { + throw new ServiceRuntimeException(e); + } - } + } - /** - * @see org.apache.tuscany.sca.provider.ServiceBindingProvider#supportsOneWayInvocation() - */ - public boolean supportsOneWayInvocation() { - return false; - } + /** + * @see org.apache.tuscany.sca.provider.ServiceBindingProvider#supportsOneWayInvocation() + */ + public boolean supportsOneWayInvocation() { + return false; + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/MessageHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/MessageHelper.java index 55134782d5..ee7957406b 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/MessageHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/MessageHelper.java @@ -1,3 +1,22 @@ +/* + * 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.impl; import com.ericsson.otp.erlang.OtpErlangAtom; @@ -7,34 +26,48 @@ import com.ericsson.otp.erlang.OtpErlangPid; import com.ericsson.otp.erlang.OtpErlangRef; import com.ericsson.otp.erlang.OtpErlangTuple; +/** + * @version $Rev$ $Date$ + */ public class MessageHelper { - private static String ATOM_BADRPC = "badrpc"; - private static String ATOM_EXIT = "EXIT"; - private static String ATOM_UNDEF = "undef"; + /** + * Mbox name used for Remote Procedure Calls + */ + public static String RPC_MBOX = "rex"; + + public static final OtpErlangAtom ATOM_OK = new OtpErlangAtom("ok"); + public static final OtpErlangAtom ATOM_ERROR = new OtpErlangAtom("error"); + public static final OtpErlangAtom ATOM_BADRPC = new OtpErlangAtom("badrpc"); + private static final OtpErlangAtom ATOM_EXIT = new OtpErlangAtom("EXIT"); + private static final OtpErlangAtom ATOM_UNDEF = new OtpErlangAtom("undef"); + private static final OtpErlangAtom ATOM_CALL = new OtpErlangAtom("call"); + private static final OtpErlangAtom ATOM_GEN_CALL = new OtpErlangAtom( + "$gen_call"); - public static OtpErlangObject functionUndefMessage(String module, String function, OtpErlangList args, String tuscanyMsg) { + public static OtpErlangObject functionUndefMessage(String module, + String function, OtpErlangList args, String tuscanyMsg) { OtpErlangObject[] args4 = new OtpErlangObject[3]; args4[0] = new OtpErlangAtom(module); args4[1] = new OtpErlangAtom(function); args4[2] = args; - + OtpErlangObject[] args3 = new OtpErlangObject[2]; args3[0] = new OtpErlangTuple(args4); args3[1] = new OtpErlangAtom(tuscanyMsg); - + OtpErlangObject[] args2 = new OtpErlangObject[2]; - args2[0] = new OtpErlangAtom(ATOM_UNDEF); + args2[0] = ATOM_UNDEF; args2[1] = new OtpErlangList(args3); - + OtpErlangObject[] args1 = new OtpErlangObject[2]; - args1[0] = new OtpErlangAtom(ATOM_EXIT); + args1[0] = ATOM_EXIT; args1[1] = new OtpErlangTuple(args2); - - OtpErlangTuple result = new OtpErlangTuple(args1); + + OtpErlangTuple result = new OtpErlangTuple(args1); return result; } - + public static boolean isfunctionUndefMessage(OtpErlangObject msg) { if (msg.getClass().equals(OtpErlangTuple.class)) { OtpErlangTuple tupleMsg = (OtpErlangTuple) msg; @@ -44,7 +77,7 @@ public class MessageHelper { && tupleMsg.elementAt(1).getClass().equals( OtpErlangTuple.class) && ((OtpErlangAtom) tupleMsg.elementAt(0)).atomValue() - .equals(ATOM_BADRPC)) { + .equals(ATOM_BADRPC.atomValue())) { OtpErlangTuple badrpcTuple = (OtpErlangTuple) tupleMsg .elementAt(1); if (badrpcTuple.arity() == 2 @@ -53,14 +86,14 @@ public class MessageHelper { && badrpcTuple.elementAt(1).getClass().equals( OtpErlangTuple.class) && ((OtpErlangAtom) badrpcTuple.elementAt(0)) - .atomValue().equals(ATOM_EXIT)) { + .atomValue().equals(ATOM_EXIT.atomValue())) { OtpErlangTuple exitTuple = (OtpErlangTuple) badrpcTuple .elementAt(1); if (exitTuple.arity() == 2 && exitTuple.elementAt(0).getClass().equals( OtpErlangAtom.class) && ((OtpErlangAtom) exitTuple.elementAt(0)) - .atomValue().equals(ATOM_UNDEF)) { + .atomValue().equals(ATOM_UNDEF.atomValue())) { return true; } } @@ -69,24 +102,25 @@ public class MessageHelper { } return false; } - - public static OtpErlangTuple rpcMessage(OtpErlangPid senderPid, OtpErlangRef ref, String module, String function, OtpErlangList args) { + + public static OtpErlangTuple rpcMessage(OtpErlangPid senderPid, + OtpErlangRef ref, String module, String function, OtpErlangList args) { OtpErlangObject[] args3 = new OtpErlangObject[5]; - args3[0] = new OtpErlangAtom("call"); + args3[0] = ATOM_CALL; args3[1] = new OtpErlangAtom(module); args3[2] = new OtpErlangAtom(function); args3[3] = args; args3[4] = senderPid; - + OtpErlangObject[] args2 = new OtpErlangObject[2]; args2[0] = senderPid; args2[1] = ref; - + OtpErlangObject[] args1 = new OtpErlangObject[3]; - args1[0] = new OtpErlangAtom("$gen_call"); + args1[0] = ATOM_GEN_CALL; args1[1] = new OtpErlangTuple(args2); args1[2] = new OtpErlangTuple(args3); - + OtpErlangTuple result = new OtpErlangTuple(args1); return result; } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/RpcExecutor.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/RpcExecutor.java deleted file mode 100644 index 03e83cec61..0000000000 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/RpcExecutor.java +++ /dev/null @@ -1,176 +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.impl; - -import java.io.IOException; -import java.lang.reflect.InvocationTargetException; -import java.util.List; -import java.util.Map; - -import org.apache.tuscany.sca.binding.erlang.ErlangBinding; -import org.apache.tuscany.sca.binding.erlang.impl.types.TypeHelpersProxy; -import org.apache.tuscany.sca.interfacedef.DataType; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.runtime.RuntimeComponentService; - -import com.ericsson.otp.erlang.OtpConnection; -import com.ericsson.otp.erlang.OtpErlangAtom; -import com.ericsson.otp.erlang.OtpErlangList; -import com.ericsson.otp.erlang.OtpErlangObject; -import com.ericsson.otp.erlang.OtpErlangPid; -import com.ericsson.otp.erlang.OtpErlangRef; -import com.ericsson.otp.erlang.OtpErlangString; -import com.ericsson.otp.erlang.OtpErlangTuple; - -public class RpcExecutor implements Runnable { - - private Map services; - private Map bindings; - private OtpConnection connection; - - private static final OtpErlangAtom OK = new OtpErlangAtom("ok"); - private static final OtpErlangAtom ERROR = new OtpErlangAtom("error"); - private static final OtpErlangAtom BADRPC = new OtpErlangAtom("badrpc"); - - public RpcExecutor(Map services, Map bindings, - OtpConnection connection) { - this.bindings = bindings; - this.services = services; - this.connection = connection; - } - - private void sendMessage(OtpConnection connection, OtpErlangPid pid, - OtpErlangRef ref, OtpErlangAtom head, OtpErlangObject message) - throws IOException { - OtpErlangTuple tResult = new OtpErlangTuple(new OtpErlangObject[] { - head, message }); - OtpErlangObject msg = null; - msg = new OtpErlangTuple(new OtpErlangObject[] { ref, tResult }); - connection.send(pid, msg); - } - - public void run() { - OtpErlangTuple request = null; - OtpErlangPid senderPid = null; - OtpErlangRef senderRef = null; - try { - OtpErlangTuple call = (OtpErlangTuple) connection.receive(); - OtpErlangTuple from = (OtpErlangTuple) call.elementAt(1); - request = (OtpErlangTuple) call.elementAt(2); - senderPid = (OtpErlangPid) from.elementAt(0); - senderRef = (OtpErlangRef) from.elementAt(1); - String module = ((OtpErlangAtom) request.elementAt(1)).atomValue(); - String function = ((OtpErlangAtom) request.elementAt(2)) - .atomValue(); - OtpErlangObject args = request.elementAt(3); - OtpErlangList argsList = null; - if (args instanceof OtpErlangList) { - argsList = (OtpErlangList) args; - } else { - argsList = new OtpErlangList(args); - } - if (!services.containsKey(module)) { - // TODO: externalize message? - OtpErlangObject errorMsg = MessageHelper.functionUndefMessage( - module, function, argsList, - "Module not found in SCA component."); - sendMessage(connection, senderPid, senderRef, BADRPC, errorMsg); - } else { - RuntimeComponentService service = services.get(module); - ErlangBinding binding = bindings.get(module); - List operations = service.getInterfaceContract() - .getInterface().getOperations(); - Operation operation = null; - for (Operation o : operations) { - if (o.getName().equals(function)) { - operation = o; - break; - } - } - if (operation != null) { - List iTypes = operation.getInputType() - .getLogical(); - Class[] forClasses = new Class[iTypes.size()]; - for (int i = 0; i < iTypes.size(); i++) { - forClasses[i] = iTypes.get(i).getPhysical(); - } - try { - Object result = service.getRuntimeWire(binding).invoke( - operation, - TypeHelpersProxy.toJavaFromList(argsList, - forClasses)); - OtpErlangObject response = null; - if (operation.getOutputType() != null - && operation.getOutputType().getPhysical() - .isArray()) { - response = TypeHelpersProxy.toErlangAsList(result); - } else if (operation.getOutputType() == null) { - Object[] arrArg = new Object[] {}; - response = TypeHelpersProxy.toErlang(arrArg); - } else { - Object[] arrArg = new Object[] { result }; - response = TypeHelpersProxy.toErlang(arrArg); - } - sendMessage(connection, senderPid, senderRef, OK, - response); - } catch (Exception e) { - if ((e.getClass().equals( - InvocationTargetException.class) && e - .getCause().getClass().equals( - IllegalArgumentException.class)) - || e.getClass().equals( - TypeMismatchException.class)) { - // TODO: externalize message? - OtpErlangObject errorMsg = MessageHelper - .functionUndefMessage(module, function, - argsList, - "Operation name found in SCA component, but parameters types didn't match."); - sendMessage(connection, senderPid, senderRef, - BADRPC, errorMsg); - } else { - throw e; - } - } - } else { - // TODO: externalize message? - OtpErlangObject errorMsg = MessageHelper - .functionUndefMessage(module, function, argsList, - "Operation name not found in SCA component."); - sendMessage(connection, senderPid, senderRef, BADRPC, - errorMsg); - } - } - } catch (Exception e) { - // TODO: distinguish and describe errors! - try { - e.printStackTrace(); - sendMessage(connection, senderPid, senderRef, ERROR, - new OtpErlangString( - "Unhandled error while processing request: " - + e.getClass().getCanonicalName() - + ", message: " + e.getMessage())); - } catch (IOException e1) { - // error while sending error message. Can't do anything now - } - } finally { - connection.close(); - } - } -} diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ServiceExecutor.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ServiceExecutor.java new file mode 100644 index 0000000000..63c58cb696 --- /dev/null +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ServiceExecutor.java @@ -0,0 +1,262 @@ +/* + * 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.impl; + +import java.io.IOException; +import java.lang.reflect.InvocationTargetException; +import java.util.List; +import java.util.Map; + +import org.apache.tuscany.sca.binding.erlang.ErlangBinding; +import org.apache.tuscany.sca.binding.erlang.impl.types.TypeHelpersProxy; +import org.apache.tuscany.sca.interfacedef.DataType; +import org.apache.tuscany.sca.interfacedef.Operation; +import org.apache.tuscany.sca.runtime.RuntimeComponentService; + +import com.ericsson.otp.erlang.OtpConnection; +import com.ericsson.otp.erlang.OtpErlangAtom; +import com.ericsson.otp.erlang.OtpErlangList; +import com.ericsson.otp.erlang.OtpErlangObject; +import com.ericsson.otp.erlang.OtpErlangPid; +import com.ericsson.otp.erlang.OtpErlangRef; +import com.ericsson.otp.erlang.OtpErlangString; +import com.ericsson.otp.erlang.OtpErlangTuple; +import com.ericsson.otp.erlang.OtpMbox; +import com.ericsson.otp.erlang.OtpMsg; +import com.ericsson.otp.erlang.OtpNode; + +/** + * @version $Rev$ $Date$ + */ +public class ServiceExecutor implements Runnable { + + private static final long RECEIVE_TIMEOUT = 60000; + + private Map erlangModules; + private ErlangNodeElement erlangMbox; + private OtpConnection connection; + private Map> groupedOperations; + + public ServiceExecutor(OtpConnection connection, + Map> groupedOperations, + Map erlangModules, + ErlangNodeElement erlangMbox) { + this.erlangModules = erlangModules; + this.connection = connection; + this.groupedOperations = groupedOperations; + this.erlangMbox = erlangMbox; + } + + private void sendMessage(OtpConnection connection, OtpErlangPid pid, + OtpErlangRef ref, OtpErlangAtom head, OtpErlangObject message) + throws IOException { + OtpErlangTuple tResult = new OtpErlangTuple(new OtpErlangObject[] { + head, message }); + OtpErlangObject msg = null; + msg = new OtpErlangTuple(new OtpErlangObject[] { ref, tResult }); + connection.send(pid, msg); + } + + private void handleRpc(OtpMsg msg) { + OtpErlangTuple request = null; + OtpErlangPid senderPid = null; + OtpErlangRef senderRef = null; + try { + OtpErlangTuple call = (OtpErlangTuple) msg.getMsg(); + OtpErlangTuple from = (OtpErlangTuple) call.elementAt(1); + request = (OtpErlangTuple) call.elementAt(2); + senderPid = (OtpErlangPid) from.elementAt(0); + senderRef = (OtpErlangRef) from.elementAt(1); + String module = ((OtpErlangAtom) request.elementAt(1)).atomValue(); + String function = ((OtpErlangAtom) request.elementAt(2)) + .atomValue(); + OtpErlangObject args = request.elementAt(3); + OtpErlangList argsList = null; + // normalize input + if (args instanceof OtpErlangList) { + argsList = (OtpErlangList) args; + } else { + argsList = new OtpErlangList(args); + } + if (!erlangModules.containsKey(module)) { + // TODO: externalize message? + OtpErlangObject errorMsg = MessageHelper.functionUndefMessage( + module, function, argsList, + "Module not found in SCA component."); + sendMessage(connection, senderPid, senderRef, + MessageHelper.ATOM_BADRPC, errorMsg); + } else { + RuntimeComponentService service = erlangModules.get(module) + .getService(); + ErlangBinding binding = erlangModules.get(module).getBinding(); + List operations = service.getInterfaceContract() + .getInterface().getOperations(); + Operation operation = null; + for (Operation o : operations) { + if (o.getName().equals(function)) { + operation = o; + break; + } + } + if (operation != null) { + List iTypes = operation.getInputType() + .getLogical(); + Class[] forClasses = new Class[iTypes.size()]; + for (int i = 0; i < iTypes.size(); i++) { + forClasses[i] = iTypes.get(i).getPhysical(); + } + try { + Object result = service.getRuntimeWire(binding).invoke( + operation, + TypeHelpersProxy.toJavaFromList(argsList, + forClasses)); + OtpErlangObject response = null; + if (operation.getOutputType() != null + && operation.getOutputType().getPhysical() + .isArray()) { + response = TypeHelpersProxy.toErlangAsList(result); + } else if (operation.getOutputType() == null) { + Object[] arrArg = new Object[] {}; + response = TypeHelpersProxy.toErlang(arrArg); + } else { + Object[] arrArg = new Object[] { result }; + response = TypeHelpersProxy.toErlang(arrArg); + } + sendMessage(connection, senderPid, senderRef, + MessageHelper.ATOM_OK, response); + } catch (Exception e) { + if ((e.getClass().equals( + InvocationTargetException.class) && e + .getCause().getClass().equals( + IllegalArgumentException.class)) + || e.getClass().equals( + TypeMismatchException.class)) { + // TODO: externalize message? + OtpErlangObject errorMsg = MessageHelper + .functionUndefMessage(module, function, + argsList, + "Operation name found in SCA component, but parameters types didn't match."); + sendMessage(connection, senderPid, senderRef, + MessageHelper.ATOM_BADRPC, errorMsg); + } else { + throw e; + } + } + } else { + // TODO: externalize message? + OtpErlangObject errorMsg = MessageHelper + .functionUndefMessage(module, function, argsList, + "Operation name not found in SCA component."); + sendMessage(connection, senderPid, senderRef, + MessageHelper.ATOM_BADRPC, errorMsg); + } + } + } catch (Exception e) { + // TODO: distinguish and describe errors! + try { + e.printStackTrace(); + sendMessage(connection, senderPid, senderRef, + MessageHelper.ATOM_ERROR, new OtpErlangString( + "Unhandled error while processing request: " + + e.getClass().getCanonicalName() + + ", message: " + e.getMessage())); + } catch (IOException e1) { + // error while sending error message. Can't do anything now + } + } + } + + private void handleMsg(OtpMsg msg) { + Operation matchedOperation = null; + Object args[] = null; + List operations = groupedOperations.get(msg + .getRecipientName()); + if (operations == null) { + // TODO: no such mbox, send error message? + } else { + for (Operation operation : operations) { + List iTypes = operation.getInputType().getLogical(); + Class[] forClasses = new Class[iTypes.size()]; + for (int i = 0; i < iTypes.size(); i++) { + forClasses[i] = iTypes.get(i).getPhysical(); + } + try { + args = TypeHelpersProxy.toJavaAsArgs(msg.getMsg(), + forClasses); + matchedOperation = operation; + break; + } catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + if (matchedOperation != null) { + try { + Object result = erlangMbox.getService().getRuntimeWire( + erlangMbox.getBinding()).invoke(matchedOperation, + args); + OtpErlangObject response = null; + if (matchedOperation.getOutputType() != null + && matchedOperation.getOutputType().getPhysical() + .isArray()) { + response = TypeHelpersProxy.toErlangAsList(result); + } else if (matchedOperation.getOutputType() != null) { + Object[] arrArg = new Object[] { result }; + response = TypeHelpersProxy.toErlang(arrArg); + } + if (response != null) { + OtpNode node = new OtpNode("_response_connector_to_" + + msg.getSenderPid()); + OtpMbox mbox = node.createMbox(); + mbox.send(msg.getSenderPid(), response); + } + } catch (InvocationTargetException e) { + // TODO send some error? + e.printStackTrace(); + } catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } else { + // TODO: send some error - no mapping for such arguments + System.out + .println("TODO: send some error - no mapping for such arguments"); + } + } + } + + public void run() { + try { + OtpMsg msg = connection.receiveMsg(RECEIVE_TIMEOUT); + if (msg.getRecipientName().equals(MessageHelper.RPC_MBOX)) { + handleRpc(msg); + } else if (msg != null) { + handleMsg(msg); + } else { + // message receive timeout + } + } catch (Exception e) { + // TODO: log, send error? + e.printStackTrace(); + } finally { + connection.close(); + } + } +} diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/TypeMismatchException.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/TypeMismatchException.java index 03b53b60bd..b3562cc413 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/TypeMismatchException.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/TypeMismatchException.java @@ -19,28 +19,32 @@ package org.apache.tuscany.sca.binding.erlang.impl; +/** + * @version $Rev$ $Date$ + */ public class TypeMismatchException extends Exception { - private static final long serialVersionUID = 1L; - private Class expected; - private Class received; - - public TypeMismatchException(Class expected, Class received) { - super("Received " + received + " cannot be mapped to " + expected.getCanonicalName()); - this.expected = expected; - this.received = received; - } - - public TypeMismatchException() { - super("Arguments don't match"); - } - - public Class getExpected() { - return expected; - } - - public Class getReceived() { - return received; - } + private static final long serialVersionUID = 1L; + private Class expected; + private Class received; + + public TypeMismatchException(Class expected, Class received) { + super("Received " + received + " cannot be mapped to " + + expected.getCanonicalName()); + this.expected = expected; + this.received = received; + } + + public TypeMismatchException() { + super("Arguments don't match"); + } + + public Class getExpected() { + return expected; + } + + public Class getReceived() { + return received; + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/exceptions/ErlangException.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/exceptions/ErlangException.java index cf573def95..587d7a509c 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/exceptions/ErlangException.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/exceptions/ErlangException.java @@ -1,5 +1,27 @@ +/* + * 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.impl.exceptions; +/** + * @version $Rev$ $Date$ + */ public class ErlangException extends Exception { private static final long serialVersionUID = 1L; @@ -7,9 +29,9 @@ public class ErlangException extends Exception { public ErlangException(String message) { super(message); } - + public ErlangException(String message, Throwable cause) { super(message, cause); } - + } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/BooleanTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/BooleanTypeHelper.java index dd9f65b4e9..9463b72eb9 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/BooleanTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/BooleanTypeHelper.java @@ -23,18 +23,22 @@ import com.ericsson.otp.erlang.OtpErlangAtom; import com.ericsson.otp.erlang.OtpErlangBoolean; import com.ericsson.otp.erlang.OtpErlangObject; +/** + * @version $Rev$ $Date$ + */ public class BooleanTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - return new OtpErlangBoolean((Boolean)object); - } + public OtpErlangObject toErlang(Object object) { + return new OtpErlangBoolean((Boolean) object); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - if (object.getClass().equals(OtpErlangAtom.class)) { - return ((OtpErlangAtom)object).booleanValue(); - } else { - return ((OtpErlangBoolean)object).booleanValue(); - } - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + if (object.getClass().equals(OtpErlangAtom.class)) { + return ((OtpErlangAtom) object).booleanValue(); + } else { + return ((OtpErlangBoolean) object).booleanValue(); + } + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ByteTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ByteTypeHelper.java index d4a92e768a..c6c8f6690f 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ByteTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ByteTypeHelper.java @@ -23,13 +23,17 @@ import com.ericsson.otp.erlang.OtpErlangByte; import com.ericsson.otp.erlang.OtpErlangLong; import com.ericsson.otp.erlang.OtpErlangObject; +/** + * @version $Rev$ $Date$ + */ public class ByteTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - return new OtpErlangByte((Byte)object); - } + public OtpErlangObject toErlang(Object object) { + return new OtpErlangByte((Byte) object); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - return (byte)((OtpErlangLong)object).longValue(); - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + return (byte) ((OtpErlangLong) object).longValue(); + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/CharTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/CharTypeHelper.java index 17100c65b8..b0479c9b0c 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/CharTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/CharTypeHelper.java @@ -23,14 +23,18 @@ import com.ericsson.otp.erlang.OtpErlangChar; import com.ericsson.otp.erlang.OtpErlangLong; import com.ericsson.otp.erlang.OtpErlangObject; +/** + * @version $Rev$ $Date$ + */ public class CharTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - return new OtpErlangChar((Character)object); - } + public OtpErlangObject toErlang(Object object) { + return new OtpErlangChar((Character) object); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - return (char)((OtpErlangLong)object).longValue(); - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + return (char) ((OtpErlangLong) object).longValue(); + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/DoubleTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/DoubleTypeHelper.java index 760fb0723b..92dd4749ac 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/DoubleTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/DoubleTypeHelper.java @@ -22,14 +22,18 @@ package org.apache.tuscany.sca.binding.erlang.impl.types; import com.ericsson.otp.erlang.OtpErlangDouble; import com.ericsson.otp.erlang.OtpErlangObject; +/** + * @version $Rev$ $Date$ + */ public class DoubleTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - return new OtpErlangDouble((Double)object); - } + public OtpErlangObject toErlang(Object object) { + return new OtpErlangDouble((Double) object); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - return ((OtpErlangDouble)object).doubleValue(); - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + return ((OtpErlangDouble) object).doubleValue(); + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/FloatTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/FloatTypeHelper.java index 851d0982f3..3ee695c3cc 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/FloatTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/FloatTypeHelper.java @@ -22,14 +22,18 @@ package org.apache.tuscany.sca.binding.erlang.impl.types; import com.ericsson.otp.erlang.OtpErlangDouble; import com.ericsson.otp.erlang.OtpErlangObject; +/** + * @version $Rev$ $Date$ + */ public class FloatTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - return new OtpErlangDouble((Float)object); - } + public OtpErlangObject toErlang(Object object) { + return new OtpErlangDouble((Float) object); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - return (float)((OtpErlangDouble)object).doubleValue(); - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + return (float) ((OtpErlangDouble) object).doubleValue(); + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/IntTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/IntTypeHelper.java index 3e79577b1e..3ee8e7d9ac 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/IntTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/IntTypeHelper.java @@ -23,14 +23,18 @@ import com.ericsson.otp.erlang.OtpErlangInt; import com.ericsson.otp.erlang.OtpErlangLong; import com.ericsson.otp.erlang.OtpErlangObject; +/** + * @version $Rev$ $Date$ + */ public class IntTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - return new OtpErlangInt((Integer)object); - } + public OtpErlangObject toErlang(Object object) { + return new OtpErlangInt((Integer) object); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - return (int)((OtpErlangLong)object).longValue(); - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + return (int) ((OtpErlangLong) object).longValue(); + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ListTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ListTypeHelper.java index 86dcd4fc0f..adac10bcef 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ListTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ListTypeHelper.java @@ -26,32 +26,39 @@ import java.util.List; import com.ericsson.otp.erlang.OtpErlangList; import com.ericsson.otp.erlang.OtpErlangObject; +/** + * @version $Rev$ $Date$ + */ public class ListTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - int i = 0; - List elements = new ArrayList(); - while (true) { - try { - Object arrElement = Array.get(object, i); - Object[] args = new Object[] {arrElement}; - elements.add(TypeHelpersProxy.toErlang(args)); - i++; - } catch (ArrayIndexOutOfBoundsException e) { - // expected - break; - } - } - return new OtpErlangList(elements.toArray(new OtpErlangObject[elements.size()])); - } + public OtpErlangObject toErlang(Object object) { + int i = 0; + List elements = new ArrayList(); + while (true) { + try { + Object arrElement = Array.get(object, i); + Object[] args = new Object[] { arrElement }; + elements.add(TypeHelpersProxy.toErlang(args)); + i++; + } catch (ArrayIndexOutOfBoundsException e) { + // expected + break; + } + } + return new OtpErlangList(elements.toArray(new OtpErlangObject[elements + .size()])); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - OtpErlangList erlangList = (OtpErlangList)object; - Object result = Array.newInstance(forClass.getComponentType(), erlangList.arity()); - for (int i = 0; i < erlangList.arity(); i++) { - Array.set(result, i, TypeHelpersProxy.toJava(erlangList.elementAt(i), forClass.getComponentType())); - } - return result; - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + OtpErlangList erlangList = (OtpErlangList) object; + Object result = Array.newInstance(forClass.getComponentType(), + erlangList.arity()); + for (int i = 0; i < erlangList.arity(); i++) { + Array.set(result, i, TypeHelpersProxy.toJava(erlangList + .elementAt(i), forClass.getComponentType())); + } + return result; + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/LongTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/LongTypeHelper.java index 1437c8f8da..711057569a 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/LongTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/LongTypeHelper.java @@ -22,14 +22,18 @@ package org.apache.tuscany.sca.binding.erlang.impl.types; import com.ericsson.otp.erlang.OtpErlangLong; import com.ericsson.otp.erlang.OtpErlangObject; +/** + * @version $Rev$ $Date$ + */ public class LongTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - return new OtpErlangLong((Long)object); - } + public OtpErlangObject toErlang(Object object) { + return new OtpErlangLong((Long) object); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - return ((OtpErlangLong)object).longValue(); - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + return ((OtpErlangLong) object).longValue(); + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ShortTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ShortTypeHelper.java index 594875f348..73a68691a4 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ShortTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/ShortTypeHelper.java @@ -23,14 +23,18 @@ import com.ericsson.otp.erlang.OtpErlangLong; import com.ericsson.otp.erlang.OtpErlangObject; import com.ericsson.otp.erlang.OtpErlangShort; +/** + * @version $Rev$ $Date$ + */ public class ShortTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - return new OtpErlangShort((Short)object); - } + public OtpErlangObject toErlang(Object object) { + return new OtpErlangShort((Short) object); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - return (short)((OtpErlangLong)object).longValue(); - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + return (short) ((OtpErlangLong) object).longValue(); + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/StringTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/StringTypeHelper.java index 8a10e1818a..001ec47655 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/StringTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/StringTypeHelper.java @@ -22,14 +22,18 @@ package org.apache.tuscany.sca.binding.erlang.impl.types; import com.ericsson.otp.erlang.OtpErlangObject; import com.ericsson.otp.erlang.OtpErlangString; +/** + * @version $Rev$ $Date$ + */ public class StringTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - return new OtpErlangString((String)object); - } + public OtpErlangObject toErlang(Object object) { + return new OtpErlangString((String) object); + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - return ((OtpErlangString)object).stringValue(); - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + return ((OtpErlangString) object).stringValue(); + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TupleTypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TupleTypeHelper.java index 86a78ccf87..3b5b30ac4d 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TupleTypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TupleTypeHelper.java @@ -26,43 +26,49 @@ import java.util.List; import com.ericsson.otp.erlang.OtpErlangObject; import com.ericsson.otp.erlang.OtpErlangTuple; +/** + * @version $Rev$ $Date$ + */ public class TupleTypeHelper implements TypeHelper { - public OtpErlangObject toErlang(Object object) { - Class forClass = object.getClass(); - List tupleMembers = new ArrayList(); - Field[] fields = forClass.getFields(); - for (int i = 0; i < fields.length; i++) { - Object[] args; - try { - args = new Object[] {fields[i].get(object)}; - OtpErlangObject member = TypeHelpersProxy.toErlang(args); - tupleMembers.add(member); - } catch (Exception e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - } - OtpErlangObject result = new OtpErlangTuple(tupleMembers.toArray(new OtpErlangObject[tupleMembers.size()])); - return result; - } + public OtpErlangObject toErlang(Object object) { + Class forClass = object.getClass(); + List tupleMembers = new ArrayList(); + Field[] fields = forClass.getFields(); + for (int i = 0; i < fields.length; i++) { + Object[] args; + try { + args = new Object[] { fields[i].get(object) }; + OtpErlangObject member = TypeHelpersProxy.toErlang(args); + tupleMembers.add(member); + } catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + OtpErlangObject result = new OtpErlangTuple(tupleMembers + .toArray(new OtpErlangObject[tupleMembers.size()])); + return result; + } - public Object toJava(OtpErlangObject object, Class forClass) throws Exception { - Object result = null; - OtpErlangTuple tuple = (OtpErlangTuple)object; - Field[] fields = forClass.getFields(); - if (fields.length != tuple.arity()) { - // TODO: received tuple with different element count - wrong - // message, exception! - } - result = forClass.newInstance(); - for (int i = 0; i < tuple.arity(); i++) { - OtpErlangObject tupleMember = tuple.elementAt(i); - Object javaMember = TypeHelpersProxy.toJava(tupleMember, fields[i].getType()); - fields[i].setAccessible(true); - fields[i].set(result, javaMember); - } - return result; - } + public Object toJava(OtpErlangObject object, Class forClass) + throws Exception { + Object result = null; + OtpErlangTuple tuple = (OtpErlangTuple) object; + Field[] fields = forClass.getFields(); + if (fields.length != tuple.arity()) { + // TODO: received tuple with different element count - wrong + // message, exception! + } + result = forClass.newInstance(); + for (int i = 0; i < tuple.arity(); i++) { + OtpErlangObject tupleMember = tuple.elementAt(i); + Object javaMember = TypeHelpersProxy.toJava(tupleMember, fields[i] + .getType()); + fields[i].setAccessible(true); + fields[i].set(result, javaMember); + } + return result; + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TypeHelper.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TypeHelper.java index 2d32ed586b..add885ef6e 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TypeHelper.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TypeHelper.java @@ -21,10 +21,13 @@ package org.apache.tuscany.sca.binding.erlang.impl.types; import com.ericsson.otp.erlang.OtpErlangObject; +/** + * @version $Rev$ $Date$ + */ public interface TypeHelper { - Object toJava(OtpErlangObject object, Class forClass) throws Exception; + Object toJava(OtpErlangObject object, Class forClass) throws Exception; - OtpErlangObject toErlang(Object object); + OtpErlangObject toErlang(Object object); } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TypeHelpersProxy.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TypeHelpersProxy.java index 208216eef2..0d0dd25a41 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TypeHelpersProxy.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/types/TypeHelpersProxy.java @@ -31,6 +31,9 @@ import com.ericsson.otp.erlang.OtpErlangList; import com.ericsson.otp.erlang.OtpErlangObject; import com.ericsson.otp.erlang.OtpErlangTuple; +/** + * @version $Rev$ $Date$ + */ public class TypeHelpersProxy { private static Map, TypeHelper> primitiveTypes = null; @@ -72,6 +75,13 @@ public class TypeHelpersProxy { return typeHelper; } + /** + * Converts Java objects arrays to Erlang: 1. single object (if array arity + * == 1) or 2. tuple (if array arity > 1) + * + * @param objects + * @return + */ public static OtpErlangObject toErlang(Object[] objects) { OtpErlangObject result = null; if (objects != null) { @@ -97,12 +107,15 @@ public class TypeHelpersProxy { return result; } + /** + * Creates Erlang list basing on unknown Java arrays + * + * @param array + * @return + */ public static OtpErlangList toErlangAsList(Object array) { OtpErlangList result = null; if (array != null) { - if (!array.getClass().isArray()) { - array = new Object[] { array }; - } List attrsList = new ArrayList(); int i = 0; while (true) { @@ -123,6 +136,14 @@ public class TypeHelpersProxy { return result; } + /** + * Converts single Erlang object to Java + * + * @param object + * @param forClass + * @return + * @throws Exception + */ public static Object toJava(OtpErlangObject object, Class forClass) throws Exception { try { @@ -133,6 +154,14 @@ public class TypeHelpersProxy { } } + /** + * Creates array of Java objects from Erlang list + * + * @param objects + * @param forClass + * @return + * @throws Exception + */ public static Object[] toJavaFromList(OtpErlangList objects, Class[] forClass) throws Exception { Object[] result = new Object[objects.arity()]; @@ -151,4 +180,41 @@ public class TypeHelpersProxy { return result; } + /** + * Converts incoming Erlang message to operation arguments + * + * @param objects + * @param forClass + * @return + * @throws Exception + */ + public static Object[] toJavaAsArgs(OtpErlangObject objects, + Class[] forClass) throws Exception { + OtpErlangObject[] args = null; + // normalize input + if (objects.getClass().equals(OtpErlangTuple.class)) { + args = new OtpErlangObject[((OtpErlangTuple) objects).arity()]; + for (int i = 0; i < ((OtpErlangTuple) objects).arity(); i++) { + args[i] = ((OtpErlangTuple) objects).elementAt(i); + } + } else { + args = new OtpErlangObject[1]; + args[0] = objects; + } + Object[] result = new Object[args.length]; + try { + for (int i = 0; i < args.length; i++) { + TypeHelper helper = getTypeHelper(forClass[i]); + result[i] = helper.toJava(args[i], forClass[i]); + } + } catch (Exception e) { + // type mismatch as mismatch of parameters count or parameters type + if (e.getClass().equals(ClassCastException.class) + || e.getClass() + .equals(ArrayIndexOutOfBoundsException.class)) + throw new TypeMismatchException(); + } + return result; + } + } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxInterface.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxInterface.java index d7ac443055..0f477fe660 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxInterface.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxInterface.java @@ -1,30 +1,52 @@ +/* + * 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; +/** + * @version $Rev$ $Date$ + */ public interface MboxInterface { - String sendArgs(String arg) throws Exception; + String sendArgs(String arg) throws Exception; + + boolean sendArgs(boolean arg) throws Exception; + + float sendArgs(float arg) throws Exception; + + double sendArgs(double arg) throws Exception; - boolean sendArgs(boolean arg) throws Exception; + long sendArgs(long arg) throws Exception; - float sendArgs(float arg) throws Exception; + int sendArgs(int arg) throws Exception; - double sendArgs(double arg) throws Exception; + char sendArgs(char arg) throws Exception; - long sendArgs(long arg) throws Exception; + short sendArgs(short arg) throws Exception; - int sendArgs(int arg) throws Exception; + byte sendArgs(byte arg) throws Exception; - char sendArgs(char arg) throws Exception; + void sendArgs(int arg1, String arg2) throws Exception; - short sendArgs(short arg) throws Exception; + StructuredTuple sendArgs(StructuredTuple arg) throws Exception; - byte sendArgs(byte arg) throws Exception; - - void sendArgs(int arg1, String arg2) throws Exception; - - StructuredTuple sendArgs(StructuredTuple arg) throws Exception; + String[] sendArgs(String[] arg) throws Exception; - String[] sendArgs(String[] arg) throws Exception; - - String[][] sendArgs(String[][] arg); + String[][] sendArgs(String[][] arg); } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java index b5d5e67b00..e64728b01e 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java @@ -25,6 +25,9 @@ import com.ericsson.otp.erlang.OtpErlangExit; import com.ericsson.otp.erlang.OtpMbox; import com.ericsson.otp.erlang.OtpMsg; +/** + * @version $Rev$ $Date$ + */ public class MboxListener implements Runnable { private OtpMbox mbox; @@ -39,7 +42,6 @@ public class MboxListener implements Runnable { public void run() { try { msg = mbox.receiveMsg(); - if (response != null) { Object[] args = new Object[1]; args[0] = response; diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ModuleInterface.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ModuleInterface.java index 7d3fc99f26..6fc95ac120 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ModuleInterface.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ModuleInterface.java @@ -1,9 +1,31 @@ +/* + * 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; +/** + * @version $Rev$ $Date$ + */ public interface ModuleInterface { - String start(String arg1, String arg2) throws Exception; - - String start() throws Exception; + String start(String arg1, String arg2) throws Exception; + + String start() throws Exception; } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java index 34efb04812..2312c5ebea 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java @@ -36,15 +36,21 @@ import org.junit.runner.RunWith; import org.osoa.sca.ServiceRuntimeException; import com.ericsson.otp.erlang.OtpErlangAtom; +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; -//this test runner will ignore tests if epmd is not available +/** + * Test is annotated with test runner, which will ignore tests if epmd is not available + * @version $Rev$ $Date$ + */ @RunWith(IgnorableRunner.class) public class ReferenceServiceTestCase { @@ -53,8 +59,10 @@ public class ReferenceServiceTestCase { private static MboxInterface mboxReference; private static ServiceInterface moduleReference; private static ServiceInterface clonedModuleReference; - private static OtpNode node; - private static OtpMbox mbox; + private static OtpNode serNode; + private static OtpMbox serMbox; + private static OtpNode refNode; + private static OtpMbox refMbox; private static Process epmdProcess; @BeforeClass @@ -69,8 +77,10 @@ public class ReferenceServiceTestCase { mboxReference = component.getMboxReference(); moduleReference = component.getModuleReference(); clonedModuleReference = component.getClonedModuleReference(); - node = new OtpNode("MboxServer"); - mbox = node.createMbox("sendArgs"); + 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."); @@ -100,7 +110,7 @@ public class ReferenceServiceTestCase { public void testStrings() throws Exception { String strArg = "Test message"; String strResult = "OK"; - MboxListener mboxListener = new MboxListener(mbox, strResult); + MboxListener mboxListener = new MboxListener(serMbox, strResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); String testResult = mboxReference.sendArgs(strArg); @@ -118,7 +128,7 @@ public class ReferenceServiceTestCase { public void testBooleans() throws Exception { boolean booleanArg = true; boolean booleanResult = false; - MboxListener mboxListener = new MboxListener(mbox, booleanResult); + MboxListener mboxListener = new MboxListener(serMbox, booleanResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); boolean testResult = mboxReference.sendArgs(booleanArg); @@ -136,7 +146,7 @@ public class ReferenceServiceTestCase { public void testFloats() throws Exception { float floatArg = 1.0f; float floatResult = 2.0f; - MboxListener mboxListener = new MboxListener(mbox, floatResult); + MboxListener mboxListener = new MboxListener(serMbox, floatResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); float testResult = mboxReference.sendArgs(floatArg); @@ -154,7 +164,7 @@ public class ReferenceServiceTestCase { public void testDoubles() throws Exception { double doubleArg = 1.0f; double doubleResult = 2.0f; - MboxListener mboxListener = new MboxListener(mbox, doubleResult); + MboxListener mboxListener = new MboxListener(serMbox, doubleResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); double testResult = mboxReference.sendArgs(doubleArg); @@ -172,7 +182,7 @@ public class ReferenceServiceTestCase { public void testLongs() throws Exception { long longArg = 1; long longResult = 2; - MboxListener mboxListener = new MboxListener(mbox, longResult); + MboxListener mboxListener = new MboxListener(serMbox, longResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); long testResult = mboxReference.sendArgs(longArg); @@ -190,7 +200,7 @@ public class ReferenceServiceTestCase { public void testInts() throws Exception { int intArg = 1; int intResult = 2; - MboxListener mboxListener = new MboxListener(mbox, intResult); + MboxListener mboxListener = new MboxListener(serMbox, intResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); int testResult = mboxReference.sendArgs(intArg); @@ -208,7 +218,7 @@ public class ReferenceServiceTestCase { public void testChars() throws Exception { char charArg = 1; char charResult = 2; - MboxListener mboxListener = new MboxListener(mbox, charResult); + MboxListener mboxListener = new MboxListener(serMbox, charResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); char testResult = mboxReference.sendArgs(charArg); @@ -226,7 +236,7 @@ public class ReferenceServiceTestCase { public void testShorts() throws Exception { short shortArg = 1; short shortResult = 2; - MboxListener mboxListener = new MboxListener(mbox, shortResult); + MboxListener mboxListener = new MboxListener(serMbox, shortResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); short testResult = mboxReference.sendArgs(shortArg); @@ -244,7 +254,7 @@ public class ReferenceServiceTestCase { public void testBytes() throws Exception { byte byteArg = 1; byte byteResult = 2; - MboxListener mboxListener = new MboxListener(mbox, byteResult); + MboxListener mboxListener = new MboxListener(serMbox, byteResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); byte testResult = mboxReference.sendArgs(byteArg); @@ -260,7 +270,7 @@ public class ReferenceServiceTestCase { */ @Test(timeout = 1000) public void testMultipleArguments() throws Exception { - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); String testString = "TupleString"; @@ -285,7 +295,7 @@ public class ReferenceServiceTestCase { tupleResult.arg1.arg2 = "Tuple inside tuple"; tupleResult.arg2 = "Tuple!"; tupleResult.arg3 = true; - MboxListener mboxListener = new MboxListener(mbox, tupleResult); + MboxListener mboxListener = new MboxListener(serMbox, tupleResult); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); StructuredTuple testArg = new StructuredTuple(); @@ -317,7 +327,7 @@ public class ReferenceServiceTestCase { @Test(timeout = 1000) public void testLists() throws Exception { String[] testArg = new String[] { "One", "Two", "Three" }; - MboxListener mboxListener = new MboxListener(mbox, testArg); + MboxListener mboxListener = new MboxListener(serMbox, testArg); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); String[] testResult = mboxReference.sendArgs(testArg); @@ -342,7 +352,7 @@ public class ReferenceServiceTestCase { public void testMultiDimLists() throws Exception { String[][] testArg = new String[][] { { "One", "Two" }, { "Three", "Four", "Five" }, { "Six" } }; - MboxListener mboxListener = new MboxListener(mbox, testArg); + MboxListener mboxListener = new MboxListener(serMbox, testArg); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); String[][] testResult = mboxReference.sendArgs(testArg); @@ -372,7 +382,7 @@ public class ReferenceServiceTestCase { public void typeMismatch() throws Exception { try { StructuredTuple arg = new StructuredTuple(); - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -383,7 +393,7 @@ public class ReferenceServiceTestCase { try { String[] arg = new String[] { "test" }; - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -394,7 +404,7 @@ public class ReferenceServiceTestCase { try { long arg = 1; - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -405,7 +415,7 @@ public class ReferenceServiceTestCase { try { int arg = 1; - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -416,7 +426,7 @@ public class ReferenceServiceTestCase { try { short arg = 1; - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -427,7 +437,7 @@ public class ReferenceServiceTestCase { try { char arg = 1; - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -438,7 +448,7 @@ public class ReferenceServiceTestCase { try { byte arg = 1; - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -449,7 +459,7 @@ public class ReferenceServiceTestCase { try { double arg = 1; - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -460,7 +470,7 @@ public class ReferenceServiceTestCase { try { float arg = 1; - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -471,7 +481,7 @@ public class ReferenceServiceTestCase { try { String arg = "1"; - MboxListener mboxListener = new MboxListener(mbox, true); + MboxListener mboxListener = new MboxListener(serMbox, true); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -482,7 +492,7 @@ public class ReferenceServiceTestCase { try { boolean arg = true; - MboxListener mboxListener = new MboxListener(mbox, 1); + MboxListener mboxListener = new MboxListener(serMbox, 1); Thread mboxThread = new Thread(mboxListener); mboxThread.start(); mboxReference.sendArgs(arg); @@ -533,6 +543,16 @@ public class ReferenceServiceTestCase { 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 * @@ -603,4 +623,65 @@ public class ReferenceServiceTestCase { } } + /** + * Tests mbox with retrieving and answering with basic arguments + * + * @throws Exception + */ + @Test(timeout = 1000) + public void testMbox() throws Exception { + OtpErlangObject[] args = new OtpErlangObject[2]; + args[0] = new OtpErlangString("world"); + args[1] = new OtpErlangString("!"); + OtpErlangTuple tuple = new OtpErlangTuple(args); + refMbox.send("sayHello", "RPCServer", tuple); + OtpErlangString result = (OtpErlangString) refMbox.receiveMsg() + .getMsg(); + assertEquals("Hello world !", result.stringValue()); + } + + /** + * Tests service mbox receiving complex message + * + * @throws Exception + */ + @Test(timeout = 1000) + 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); + refMbox.send("passComplexArgs", "RPCServer", args); + 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()); + } + } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponent.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponent.java index 0d11b294dc..be43820b0b 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponent.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponent.java @@ -1,5 +1,27 @@ +/* + * 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; +/** + * @version $Rev$ $Date$ + */ public interface ReferenceTestComponent { } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponentImpl.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponentImpl.java index 919ca64568..71041a2be2 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponentImpl.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponentImpl.java @@ -1,38 +1,60 @@ +/* + * 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 org.osoa.sca.annotations.Reference; +/** + * @version $Rev$ $Date$ + */ public class ReferenceTestComponentImpl implements ReferenceTestComponent { - private MboxInterface mboxReference; - private ServiceInterface moduleReference; - private ServiceInterface clonedModuleReference; - - @Reference - public void setMboxReference(MboxInterface mboxReference) { - this.mboxReference = mboxReference; - } - - @Reference - public void setModuleReference(ServiceInterface moduleReference) { - this.moduleReference = moduleReference; - } - - @Reference - public void setClonedModuleReference(ServiceInterface clonedModuleReference) { - this.clonedModuleReference = clonedModuleReference; - } - - public MboxInterface getMboxReference() { - return mboxReference; - } - - public ServiceInterface getModuleReference() { - return moduleReference; - } - - public ServiceInterface getClonedModuleReference() { - return clonedModuleReference; - } + private MboxInterface mboxReference; + private ServiceInterface moduleReference; + private ServiceInterface clonedModuleReference; + + @Reference + public void setMboxReference(MboxInterface mboxReference) { + this.mboxReference = mboxReference; + } + + @Reference + public void setModuleReference(ServiceInterface moduleReference) { + this.moduleReference = moduleReference; + } + + @Reference + public void setClonedModuleReference(ServiceInterface clonedModuleReference) { + this.clonedModuleReference = clonedModuleReference; + } + + public MboxInterface getMboxReference() { + return mboxReference; + } + + public ServiceInterface getModuleReference() { + return moduleReference; + } + + public ServiceInterface getClonedModuleReference() { + return clonedModuleReference; + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceInterface.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceInterface.java index 33afcfb53d..95c0ea06f6 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceInterface.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceInterface.java @@ -1,20 +1,44 @@ +/* + * 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; +/** + * @version $Rev$ $Date$ + */ public interface ServiceInterface { - String sayHello(String arg1, String arg2); - - String[] sayHellos() throws Exception; - - StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2); - - String sayHello() throws Exception; - - String sayHello(String arg) throws Exception; - - String sayHello(int arg1, int arg2); - - void notExistWithException() throws Exception; - - void notExist(); + void doNothing(); + + String sayHello(String arg1, String arg2); + + String[] sayHellos() throws Exception; + + StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2); + + String sayHello() throws Exception; + + String sayHello(String arg) throws Exception; + + String sayHello(int arg1, int arg2); + + void notExistWithException() throws Exception; + + void notExist(); } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponent.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponent.java index f5c03ef281..60650188bc 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponent.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponent.java @@ -1,11 +1,35 @@ +/* + * 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; +/** + * @version $Rev$ $Date$ + */ public interface ServiceTestComponent { - String sayHello(String arg1, String arg2); - - String[] sayHellos() throws Exception; - - StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2); - + String sayHello(String arg1, String arg2); + + String[] sayHellos() throws Exception; + + StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2); + + void doNothing(); + } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImpl.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImpl.java index 4d79005938..551ad3d063 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImpl.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImpl.java @@ -1,19 +1,44 @@ -package org.apache.tuscany.sca.binding.erlang.testing; +/* + * 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; +/** + * @version $Rev$ $Date$ + */ public class ServiceTestComponentImpl implements ServiceTestComponent { - public String sayHello(String arg1, String arg2) { - return "Hello " + arg1 + " " + arg2; - } + public String sayHello(String arg1, String arg2) { + return "Hello " + arg1 + " " + arg2; + } + + public String[] sayHellos() { + String[] result = new String[] { "1", "2" }; + return result; + } - public String[] sayHellos() { - String[] result = new String[] {"1", "2"}; - return result; - } + public StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2) { + return arg1; + } - public StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2) { - return arg1; - } + public void doNothing() { + // doing nothing + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplClone.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplClone.java index 98921bd24d..b59662551c 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplClone.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplClone.java @@ -1,19 +1,44 @@ -package org.apache.tuscany.sca.binding.erlang.testing; +/* + * 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; +/** + * @version $Rev$ $Date$ + */ public class ServiceTestComponentImplClone implements ServiceTestComponent { - public String sayHello(String arg1, String arg2) { - return "Bye " + arg1 + " " + arg2; - } + public String sayHello(String arg1, String arg2) { + return "Bye " + arg1 + " " + arg2; + } + + public String[] sayHellos() { + String[] result = new String[] { "-1", "-2" }; + return result; + } + + public StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2) { + return arg1; + } - public String[] sayHellos() { - String[] result = new String[] {"-1", "-2"}; - return result; - } + public void doNothing() { - public StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2) { - return arg1; - } + } } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/SmallTuple.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/SmallTuple.java index 4b318e4a61..ac8b9e426a 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/SmallTuple.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/SmallTuple.java @@ -19,14 +19,17 @@ package org.apache.tuscany.sca.binding.erlang.testing; +/** + * @version $Rev$ $Date$ + */ public class SmallTuple { - public int arg1; - public String arg2 = ""; - - public boolean equals(Object o) { - SmallTuple comp = (SmallTuple)o; - return arg1 == comp.arg1 && arg2.equals(arg2); - } - + public int arg1; + public String arg2 = ""; + + public boolean equals(Object o) { + SmallTuple comp = (SmallTuple) o; + return arg1 == comp.arg1 && arg2.equals(arg2); + } + } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/StructuredTuple.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/StructuredTuple.java index 736cc2046d..193654172f 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/StructuredTuple.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/StructuredTuple.java @@ -19,15 +19,19 @@ package org.apache.tuscany.sca.binding.erlang.testing; +/** + * @version $Rev$ $Date$ + */ public class StructuredTuple { - public SmallTuple arg1 = new SmallTuple(); - public String arg2 = ""; - public boolean arg3; - - public boolean equals(Object o) { - StructuredTuple comp = (StructuredTuple)o; - return arg2.equals(comp.arg2) && arg3 == comp.arg3 && arg1.equals(comp.arg1); - } - + public SmallTuple arg1 = new SmallTuple(); + public String arg2 = ""; + public boolean arg3; + + public boolean equals(Object o) { + StructuredTuple comp = (StructuredTuple) o; + return arg2.equals(comp.arg2) && arg3 == comp.arg3 + && arg1.equals(comp.arg1); + } + } diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnorableRunner.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnorableRunner.java index 81a17ff9dd..33e6d4862b 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnorableRunner.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnorableRunner.java @@ -29,6 +29,9 @@ import org.junit.runner.notification.StoppedByUserException; import org.junit.runners.BlockJUnit4ClassRunner; import org.junit.runners.model.InitializationError; +/** + * @version $Rev$ $Date$ + */ public class IgnorableRunner extends Runner { private static final class Notifier extends RunNotifier { diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnoreTest.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnoreTest.java index 9a8372051c..3d736da19d 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnoreTest.java +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnoreTest.java @@ -19,6 +19,9 @@ package org.apache.tuscany.sca.binding.erlang.testing.dynaignore; +/** + * @version $Rev$ $Date$ + */ public final class IgnoreTest extends Error { private static final long serialVersionUID = 1L; diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/resources/ErlangService.composite b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/resources/ErlangService.composite index 441819b95d..ce94340bb6 100644 --- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/resources/ErlangService.composite +++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/resources/ErlangService.composite @@ -11,6 +11,10 @@ + + + + -- cgit v1.2.3