Add test suite for jinterface

3 files changed, 410 insertions, 0 deletions

diff --git a/lib/jinterface/test/nc_SUITE_data/Makefile.src b/lib/jinterface/test/nc_SUITE_data/Makefile.src
new file mode 100644
index 0000000000..3d131250be
--- /dev/null
+++ b/lib/jinterface/test/nc_SUITE_data/Makefile.src
@@ -0,0 +1,53 @@
+#
+# %CopyrightBegin%
+#
+# Copyright Ericsson AB 2004-2010. All Rights Reserved.
+#
+# The contents of this file are subject to the Erlang Public License,
+# Version 1.1, (the "License"); you may not use this file except in
+# compliance with the License. You should have received a copy of the
+# Erlang Public License along with this software. If not, it can be
+# retrieved online at http://www.erlang.org/.
+#
+# Software distributed under the License is distributed on an "AS IS"
+# basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
+# the License for the specific language governing rights and limitations
+# under the License.
+#
+# %CopyrightEnd%
+#
+
+# Makefile.src for java_client_erl_server test
+# Note: This file *must* work for both Unix and Windows
+#
+# We use both `rm' (Unix) and `del' (Windows) for removing files, but
+# with a `-' in front so that the error in not finding `rm' (`del') on
+# Windows (Unix) is ignored.
+#
+# VxWorks? XXX
+#
+
+.SUFFIXES:
+.SUFFIXES: .java
+
+
+JAVAC = @JAVAC@
+ERLC = erlc
+
+JINTERFACE_CLASSPATH = @jinterface_classpath@
+
+CLASSPATH = .@PS@$(JINTERFACE_CLASSPATH)@PS@
+
+JAVA_FILES = echo_server.java connection_server.java
+CLASS_FILES = $(JAVA_FILES:.java=.class)
+
+all: $(CLASS_FILES)
+
+clean:
+	-rm -f $(CLASS_FILES)
+	-del /F /Q $(CLASS_FILES)
+
+$(CLASS_FILES) : $(JAVA_FILES)
+	$(JAVAC) -classpath $(CLASSPATH) $(JAVA_FILES)
+
+#
diff --git a/lib/jinterface/test/nc_SUITE_data/connection_server.java b/lib/jinterface/test/nc_SUITE_data/connection_server.java
new file mode 100644
index 0000000000..19ed1c7d5c
--- /dev/null
+++ b/lib/jinterface/test/nc_SUITE_data/connection_server.java
@@ -0,0 +1,96 @@
+/*
+ * %CopyrightBegin%
+ *
+ * Copyright Ericsson AB 2004-2010. All Rights Reserved.
+ *
+ * The contents of this file are subject to the Erlang Public License,
+ * Version 1.1, (the "License"); you may not use this file except in
+ * compliance with the License. You should have received a copy of the
+ * Erlang Public License along with this software. If not, it can be
+ * retrieved online at http://www.erlang.org/.
+ *
+ * Software distributed under the License is distributed on an "AS IS"
+ * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
+ * the License for the specific language governing rights and limitations
+ * under the License.
+ *
+ * %CopyrightEnd%
+ */
+
+import com.ericsson.otp.erlang.*;
+
+public class connection_server {
+    static java.lang.String Name = "connection_server";
+
+    public static void main(String[] argv) {
+	try {
+	    System.out.println("connection_server booting...");
+
+	    for (int j = 0; j < argv.length; j++)
+		System.out.println("argv[" + j + "] = \"" + argv[j] + "\"");
+
+	    if (argv.length != 4) {
+		System.out.println("Wrong number of arguments!");
+		System.exit(1);
+	    }
+
+	    // Start node and mbox
+	    OtpNode node = new OtpNode(argv[0], argv[1]);
+	    OtpMbox mbox = node.createMbox();
+	    if (! mbox.registerName(Name)) {
+		System.out.println("Could not register name " + Name);
+		System.exit(3);
+	    }
+
+	    // Announce our presence
+	    OtpErlangObject[] amsg = new OtpErlangObject[3];
+	    amsg[0] = new OtpErlangAtom(Name);
+	    amsg[1] = new OtpErlangAtom(argv[0]);
+	    amsg[2] = mbox.self();
+	    OtpErlangTuple atuple = new OtpErlangTuple(amsg);
+	    mbox.send(argv[3], argv[2], atuple);
+
+	    // Do connects ...
+	    while (true) {
+		OtpErlangObject o = mbox.receive();
+		if (o == null)
+		    continue;
+		if (o instanceof OtpErlangTuple) {
+		    OtpErlangTuple msg = (OtpErlangTuple) o;
+		    OtpErlangPid from = (OtpErlangPid)(msg.elementAt(0));
+		    OtpErlangAtom conn_node = (OtpErlangAtom) msg.elementAt(1);
+
+		    System.out.println("Got request to connect to: "
+				       + conn_node);
+		    OtpErlangObject[] rmsg = new OtpErlangObject[3];
+		    rmsg[0] = mbox.self();
+		    rmsg[1] = conn_node;
+		    if (node.ping(conn_node.atomValue(), 1000)) {
+			System.out.println("Successfully connected to "
+					   + conn_node.toString());
+			rmsg[2] = new OtpErlangAtom("true");
+		    }
+		    else {
+			System.out.println("Failed to connect to "
+					   + conn_node.toString());
+			rmsg[2] = new OtpErlangAtom("false");
+		    }
+
+		    OtpErlangTuple rtuple = new OtpErlangTuple(rmsg);
+
+		    mbox.send(from, rtuple);
+		}
+		else { // probably 'bye'
+		    System.out.println("connection_server halting...");
+		    System.exit(0);
+		}
+	    }
+	}
+	catch (Exception e) {
+	    System.out.println("" + e);
+	    System.exit(2);
+	}
+
+    }
+
+}
diff --git a/lib/jinterface/test/nc_SUITE_data/echo_server.java b/lib/jinterface/test/nc_SUITE_data/echo_server.java
new file mode 100644
index 0000000000..0550e4beb1
--- /dev/null
+++ b/lib/jinterface/test/nc_SUITE_data/echo_server.java
@@ -0,0 +1,261 @@
+/*
+ * %CopyrightBegin%
+ *
+ * Copyright Ericsson AB 2004-2010. All Rights Reserved.
+ *
+ * The contents of this file are subject to the Erlang Public License,
+ * Version 1.1, (the "License"); you may not use this file except in
+ * compliance with the License. You should have received a copy of the
+ * Erlang Public License along with this software. If not, it can be
+ * retrieved online at http://www.erlang.org/.
+ *
+ * Software distributed under the License is distributed on an "AS IS"
+ * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
+ * the License for the specific language governing rights and limitations
+ * under the License.
+ *
+ * %CopyrightEnd%
+ */
+
+import java.io.UnsupportedEncodingException;
+import java.util.HashSet;
+
+import com.ericsson.otp.erlang.OtpErlangAtom;
+import com.ericsson.otp.erlang.OtpErlangBinary;
+import com.ericsson.otp.erlang.OtpErlangBoolean;
+import com.ericsson.otp.erlang.OtpErlangException;
+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.OtpErlangPid;
+import com.ericsson.otp.erlang.OtpErlangString;
+import com.ericsson.otp.erlang.OtpErlangTuple;
+import com.ericsson.otp.erlang.OtpExternal;
+import com.ericsson.otp.erlang.OtpInputStream;
+import com.ericsson.otp.erlang.OtpMbox;
+import com.ericsson.otp.erlang.OtpNode;
+import com.ericsson.otp.erlang.OtpOutputStream;
+
+public class echo_server {
+    private static boolean debug = false;
+
+    public static void main(final String[] argv) {
+	try {
+	    System.out.println("echo_server booting...");
+
+	    for (int j = 0; j < argv.length; j++) {
+		System.out.println("argv[" + j + "] = \"" + argv[j] + "\"");
+	    }
+
+	    if (argv.length != 4 && argv.length != 5) {
+		System.out.println("Wrong number of arguments!");
+		System.exit(1);
+	    }
+
+	    // Start node and mbox
+	    final OtpNode node = new OtpNode(argv[0], argv[1]);
+	    if (argv.length == 5 && argv[4].equals("unicode")) {
+		System.out.println("Setting unicode string mode.");
+		node.setFlags(OtpInputStream.DECODE_INT_LISTS_AS_STRINGS);
+	    }
+	    final OtpMbox mbox = node.createMbox();
+
+	    // Announce our presence
+	    final OtpErlangObject[] amsg = new OtpErlangObject[3];
+	    amsg[0] = new OtpErlangAtom("echo_server");
+	    amsg[1] = new OtpErlangAtom(argv[0]);
+	    amsg[2] = mbox.self();
+	    final OtpErlangTuple atuple = new OtpErlangTuple(amsg);
+	    mbox.send(argv[3], argv[2], atuple);
+
+	    // Do echoing...
+	    while (true) {
+		final OtpErlangObject o = mbox.receive();
+		if (o == null) {
+		    continue;
+		}
+		if (o instanceof OtpErlangTuple) {
+		    final OtpErlangTuple msg = (OtpErlangTuple) o;
+		    final int arity = msg.arity();
+		    if (arity < 2) {
+			System.out
+				.println("Arity < 2; echo_server aborting...");
+			System.exit(2);
+		    } else if (arity == 2) {
+			final OtpErlangPid from = (OtpErlangPid) msg
+				.elementAt(0);
+			if (debug) System.out.println("Echoing: "
+						      + msg.elementAt(1));
+
+			final OtpErlangObject[] rmsg = new OtpErlangObject[2];
+			rmsg[0] = mbox.self();
+			rmsg[1] = msg.elementAt(1);
+			final OtpErlangTuple rtuple = new OtpErlangTuple(rmsg);
+
+			mbox.send(from, rtuple);
+			continue;
+		    } else if (arity == 3) {
+			echoTwisted(mbox, msg);
+			continue;
+		    } else {
+			System.out
+				.println("Arity > 3; echo_server aborting...");
+			System.exit(2);
+		    }
+		} else if (o instanceof OtpErlangAtom) {
+		    OtpErlangAtom a = (OtpErlangAtom) o;
+		    if (a.atomValue().equals("debug")) {
+			debug = true;
+		    } else if (a.atomValue().equals("bye")) {
+			System.out.println("echo_server halting...");
+			System.exit(0);
+		    }
+		} else { // probably 'bye'
+		}
+		System.out.println("Unexpected: " + o +
+				   " echo_server aborting...");
+		System.exit(2);
+	    }
+	} catch (final Exception e) {
+	    System.out.println("" + e);
+	    System.exit(2);
+	}
+    }
+
+    private static void echoTwisted(final OtpMbox mbox,
+				    final OtpErlangTuple msg)
+	    throws OtpErlangException {
+	final OtpErlangPid from = (OtpErlangPid) msg.elementAt(0);
+
+	final OtpErlangObject[] rmsg = new OtpErlangObject[3];
+	if (debug) System.out.println("Echo in: " + msg);
+	rmsg[0] = mbox.self();
+	rmsg[1] = twist(msg.elementAt(1), rmsg[2] = msg.elementAt(2));
+	final OtpErlangTuple rtuple = new OtpErlangTuple(rmsg);
+	if (debug) System.out.println("Echo out: " + rtuple);
+
+	mbox.send(from, rtuple);
+    }
+
+    private static HashSet<OtpErlangObject> hash_set =
+	new HashSet<OtpErlangObject>();
+
+    private static OtpErlangObject twist(final OtpErlangObject i,
+	    final OtpErlangObject t) throws OtpErlangException {
+	hash_set.add(i);
+	if (t instanceof OtpErlangAtom) {
+	    final String atomValue = ((OtpErlangAtom) t).atomValue();
+	    if (atomValue.equals("binary") && i instanceof OtpErlangBinary) {
+		final OtpErlangBinary b = (OtpErlangBinary) i;
+		final OtpInputStream bis = new OtpInputStream(b.binaryValue(),
+			0);
+		final OtpErlangObject o = bis.read_any();
+		return o;
+	    } else if (atomValue.equals("compress")) {
+		final OtpOutputStream oos = new OtpOutputStream();
+		oos.write1(OtpExternal.versionTag);
+		oos.write_compressed(i);
+		final OtpErlangBinary o =
+		    new OtpErlangBinary(oos.toByteArray());
+		return o;
+	    } else if (atomValue.equals("bigint")
+		       && i instanceof OtpErlangLong) {
+		final OtpErlangLong l = (OtpErlangLong) i;
+		final int w = l.signum() * l.bitLength();
+		final OtpErlangLong x = new OtpErlangLong(l.longValue());
+		final java.math.BigInteger b = l.bigIntegerValue();
+		System.out.println("long: " + l + ": " + w + ": " + b.signum()
+			* b.bitLength() + ": " + x + ": " + l.isLong() + ": "
+			+ l.isULong());
+		return new OtpErlangTuple(new OtpErlangObject[] { l,
+			new OtpErlangInt(w), x,
+			new OtpErlangInt(l.isLong() ? 1 : 0),
+			new OtpErlangInt(l.isULong() ? 1 : 0) });
+	    } else if (atomValue.equals("tail")
+		       && i instanceof OtpErlangList) {
+		final OtpErlangObject o = ((OtpErlangList) i).getTail();
+		if (o == null) {
+		    return new OtpErlangAtom("null");
+		}
+		return o;
+	    } else if (atomValue.equals("tail3")
+		       && i instanceof OtpErlangList) {
+		final OtpErlangObject o = ((OtpErlangList) i).getNthTail(3);
+		if (o == null) {
+		    return new OtpErlangAtom("null");
+		}
+		return o;
+	    } else if (atomValue.equals("strcat")
+		       && i instanceof OtpErlangList) {
+		final java.lang.StringBuffer b = new java.lang.StringBuffer();
+		final OtpErlangList l = (OtpErlangList) i;
+		for (final OtpErlangObject j : l) {
+		    final OtpErlangString k = (OtpErlangString) j;
+		    b.append(k.stringValue());
+		}
+		final OtpErlangObject o = new OtpErlangString(b.toString());
+		return o;
+	    } else if (atomValue.equals("sub3atom")
+		    && i instanceof OtpErlangString) {
+		final OtpErlangString s = (OtpErlangString) i;
+		final OtpErlangAtom o = new OtpErlangAtom(s.stringValue()
+			.substring(3));
+		return o;
+	    } else if (atomValue.equals("utf8")) {
+		if (i instanceof OtpErlangString) {
+		    final OtpErlangString s = (OtpErlangString) i;
+		    byte[] bytes;
+		    try {
+			bytes = s.stringValue().getBytes("UTF-8");
+		    } catch (final UnsupportedEncodingException e) {
+			bytes = new byte[] { 'e', 'r', 'r', 'o', 'r' };
+		    }
+		    final OtpErlangBinary b = new OtpErlangBinary(bytes);
+		    return b;
+		}
+	    } else if(atomValue.equals("to_string_neg_int_list")) {
+		OtpErlangString oes = null;
+		if (i instanceof OtpErlangString) {
+		    oes = (OtpErlangString) i;
+		} else if (i instanceof OtpErlangList) {
+		    OtpErlangList oel = (OtpErlangList) i;
+		    try {
+			oes = new OtpErlangString(oel);
+		    } catch (final Exception e) {
+		    }
+		}
+		if (oes != null) {
+		    String s = oes.stringValue();
+		    int n = s.length();
+		    OtpErlangObject l[] = new OtpErlangObject[n];
+		    for (int j = 0;  j < n;  j++) {
+			int c = s.charAt(j);
+			l[j] = new OtpErlangInt(-c);
+		    }
+		    return new OtpErlangList(l);
+		}
+	    } else if(atomValue.equals("to_neg_int_list")) {
+		if (i instanceof OtpErlangString) {
+		    OtpErlangString oes = (OtpErlangString) i;
+		    OtpErlangList oel = new OtpErlangList(oes.stringValue());
+		    int n = oel.arity();
+		    OtpErlangObject l[] = new OtpErlangObject[n];
+		    for (int j = 0;  j < n;  j++) {
+			OtpErlangLong c = (OtpErlangLong) oel.elementAt(j);
+			l[j] = new OtpErlangInt(-c.intValue());
+		    }
+		    return new OtpErlangList(l);
+		}
+	    } else if (atomValue.equals("hash_lookup")) {
+		final boolean exists = hash_set.contains(i);
+		final OtpErlangBoolean b = new OtpErlangBoolean(exists);
+		return b;
+	    } else if (atomValue.equals("hash_clear")) {
+		hash_set.clear();
+		return new OtpErlangAtom("hash_cleared");
+	    }
+	}
+	return i;
+    }
+}