/*
* %CopyrightBegin%
*
* Copyright Ericsson AB 2004-2012. 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("codepointBug")
&& i instanceof OtpErlangString) {
final OtpErlangString s = (OtpErlangString) i;
final String ss = s.stringValue().substring(3, 6);
final int[] cps = OtpErlangString.stringToCodePoints(ss);
return s;
} 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;
}
}
