aboutsummaryrefslogtreecommitdiff
path: root/src/java
diff options
context:
space:
mode:
Diffstat (limited to 'src/java')
-rw-r--r--src/java/com/cycling74/max/Callback.java22
-rw-r--r--src/java/com/cycling74/max/MaxObject.java2
-rw-r--r--src/java/com/cycling74/max/MaxSystem.java6
-rw-r--r--src/java/com/cycling74/max/package.html2
-rw-r--r--src/java/com/cycling74/msp/MSPPerformable.java4
-rw-r--r--src/java/com/cycling74/net/TcpReceiver.java97
-rw-r--r--src/java/com/cycling74/net/TcpSender.java92
-rw-r--r--src/java/com/cycling74/net/UdpReceiver.java64
-rw-r--r--src/java/com/cycling74/net/UdpSender.java45
-rw-r--r--src/java/com/cycling74/net/package.html5
-rw-r--r--src/java/com/e1/pdj/PDJSystem.java58
-rw-r--r--src/java/com/e1/pdj/test/CallbackTest.java12
-rw-r--r--src/java/com/e1/pdj/test/NetTest.java55
-rw-r--r--src/java/pdj_test_class.java5
14 files changed, 292 insertions, 177 deletions
diff --git a/src/java/com/cycling74/max/Callback.java b/src/java/com/cycling74/max/Callback.java
index 1eed30f..14d4848 100644
--- a/src/java/com/cycling74/max/Callback.java
+++ b/src/java/com/cycling74/max/Callback.java
@@ -130,6 +130,7 @@ public class Callback implements Executable {
try {
method.invoke(obj, args);
} catch (IllegalArgumentException e) {
+ e.printStackTrace();
MaxSystem.error("pdj: IllegalArgumentException:" + e);
} catch (IllegalAccessException e) {
MaxSystem.error("pdj: IllegalAccessException:" + e);
@@ -144,7 +145,7 @@ public class Callback implements Executable {
* @return the array of arguments
*/
public Object[] getArgs() {
- return args;
+ return (Object[]) args[0];
}
/**
@@ -176,7 +177,7 @@ public class Callback implements Executable {
* @param i int value
*/
public void setArgs(int i) {
- args = new Object[] { new Integer(i) };
+ setSubArgs(new Object[] { new Integer(i) });
}
/**
@@ -184,7 +185,7 @@ public class Callback implements Executable {
* @param f float argument
*/
public void setArgs(float f) {
- args = new Object[] { new Float(f) };
+ setSubArgs(new Object[] { new Float(f) });
}
/**
@@ -192,7 +193,7 @@ public class Callback implements Executable {
* @param value int value
*/
public void setArgs(String value) {
- args = new Object[] { value };
+ setSubArgs(new Object[] { value });
}
/**
@@ -200,7 +201,7 @@ public class Callback implements Executable {
* @param flag boolean value
*/
public void setArgs(boolean flag) {
- args = new Object[] { flag ? Boolean.TRUE : Boolean.FALSE };
+ setSubArgs(new Object[] { flag ? Boolean.TRUE : Boolean.FALSE });
}
/**
@@ -208,6 +209,15 @@ public class Callback implements Executable {
* @param args the array object to pass to the method
*/
public void setArgs(Object args[]) {
- this.args = (Object[]) args.clone();
+ setSubArgs((Object[]) args.clone());
+ }
+
+ /**
+ * Fix for <1.5 method.invoke.
+ * @param args
+ */
+ private void setSubArgs(Object args[]) {
+ this.args = new Object[1];
+ this.args[0] = args;
}
}
diff --git a/src/java/com/cycling74/max/MaxObject.java b/src/java/com/cycling74/max/MaxObject.java
index 15f2a16..5b93bc3 100644
--- a/src/java/com/cycling74/max/MaxObject.java
+++ b/src/java/com/cycling74/max/MaxObject.java
@@ -863,7 +863,7 @@ public class MaxObject {
} catch (NoSuchMethodException e) {
try {
Constructor c = clz.getConstructor(argType);
- obj = (MaxObject) c.newInstance(new Object[0]);
+ obj = (MaxObject) c.newInstance((Object[]) new Object[0]);
} catch ( Exception e1 ) {
popPdjPointer();
throw e1;
diff --git a/src/java/com/cycling74/max/MaxSystem.java b/src/java/com/cycling74/max/MaxSystem.java
index dd8fe48..cdecb0b 100644
--- a/src/java/com/cycling74/max/MaxSystem.java
+++ b/src/java/com/cycling74/max/MaxSystem.java
@@ -146,8 +146,8 @@ public class MaxSystem {
int ret[] = new int[3];
ret[0] = 0;
- ret[1] = 99;
- ret[2] = 0;
+ ret[1] = 8;
+ ret[2] = 5;
return ret;
}
@@ -171,7 +171,7 @@ public class MaxSystem {
}
// constants
- public static String MXJ_VERSION = "pdj 0.8.4";
+ public static String MXJ_VERSION = "pdj 0.8.5";
public static final int PATH_STYLE_COLON = 2;
public static final int PATH_STYLE_MAX = 0;
diff --git a/src/java/com/cycling74/max/package.html b/src/java/com/cycling74/max/package.html
index dcd23c3..1df006d 100644
--- a/src/java/com/cycling74/max/package.html
+++ b/src/java/com/cycling74/max/package.html
@@ -1,5 +1,5 @@
<html>
<body>
-<p>Basic package for PDJ</p>
+<p>Basic package for PDJ.</p>
</body>
</html> \ No newline at end of file
diff --git a/src/java/com/cycling74/msp/MSPPerformable.java b/src/java/com/cycling74/msp/MSPPerformable.java
index 6f27241..75b3e13 100644
--- a/src/java/com/cycling74/msp/MSPPerformable.java
+++ b/src/java/com/cycling74/msp/MSPPerformable.java
@@ -6,12 +6,12 @@ package com.cycling74.msp;
*/
public interface MSPPerformable {
/**
- * @see MSPPerformer.dspsetup(MSPSignal in[], MSPSignal out[])
+ * Interface for MSPPerformer.dspsetup(MSPSignal in[], MSPSignal out[])
*/
public void dspsetup(MSPSignal in[], MSPSignal out[]);
/**
- * @see MSPPerformer.perform(MSPSignal in[], MSPSignal out[]);
+ * Interface for MSPPerformer.perform(MSPSignal in[], MSPSignal out[]);
*/
public void perform(MSPSignal in[], MSPSignal out[]);
}
diff --git a/src/java/com/cycling74/net/TcpReceiver.java b/src/java/com/cycling74/net/TcpReceiver.java
index f449517..3de2343 100644
--- a/src/java/com/cycling74/net/TcpReceiver.java
+++ b/src/java/com/cycling74/net/TcpReceiver.java
@@ -1,33 +1,54 @@
package com.cycling74.net;
-import java.lang.reflect.Method;
-import java.net.DatagramPacket;
-import java.net.DatagramSocket;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.ServerSocket;
+import java.net.Socket;
import com.cycling74.max.Atom;
+import com.cycling74.max.Callback;
import com.cycling74.max.MaxRuntimeException;
import com.cycling74.max.MaxSystem;
-/**
- * This portion of code is scheduled for pdj-0.8.5
- * IT IS NOT FUNCTIONAL
+/**
+ * Class wrapper to receive atoms via TCP/IP using the class
+ * TcpSender.
+ *
+ * This class is a work in progress and have been lightly tested.
*/
public class TcpReceiver implements Runnable {
- DatagramSocket receiver;
- DatagramPacket packet;
-
- Method callback = null;
- Object instance;
+ ServerSocket receiver;
+
+ Callback callback = null;
String debugString = null;
- int port;
+ int port = -1;
boolean runnable = true;
+ public TcpReceiver() {
+
+ }
+
+ public TcpReceiver(int port) {
+ this.port = port;
+ }
+
+ public TcpReceiver(int port, Object caller, String method) {
+ this.port = port;
+ this.callback = new Callback(caller, method, new Object[] { new Atom[0] });
+ }
+
+
public void close() {
if ( receiver == null )
return;
runnable = false;
- receiver.close();
+ try {
+ receiver.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
}
public int getPort() {
@@ -35,9 +56,17 @@ public class TcpReceiver implements Runnable {
}
public void setActive(boolean active) {
- if ( active == false ) {
- runnable = true;
- new Thread(this).start();
+ if ( port == -1 )
+ throw new MaxRuntimeException("No TCP port specified");
+
+ if ( active == true ) {
+ try {
+ receiver = new ServerSocket(port);
+ } catch (IOException e) {
+ throw new MaxRuntimeException(e);
+ }
+ runnable = true;
+ new Thread(this, "TcpSender[" + port + "]").start();
} else {
close();
}
@@ -46,8 +75,7 @@ public class TcpReceiver implements Runnable {
public void setCallback(Object caller, String methodName) {
try {
- callback = caller.getClass().getDeclaredMethod(methodName, new Class[] { Atom.class });
- instance = caller;
+ this.callback = new Callback(caller, methodName, new Object[] { new Atom[0] });
} catch (Exception e) {
throw new MaxRuntimeException(e);
}
@@ -62,22 +90,29 @@ public class TcpReceiver implements Runnable {
this.debugString = debugString;
}
+ private void parseMessage(BufferedReader reader) throws IOException {
+ while(runnable) {
+ String msg = reader.readLine();
+ if ( debugString != null )
+ MaxSystem.post(debugString + " " + msg);
+
+ if ( callback != null ) {
+ callback.setArgs(Atom.parse(msg));
+ try {
+ callback.execute();
+ } catch( Exception e ) {
+ e.printStackTrace();
+ }
+ }
+ }
+ }
+
public void run() {
- DatagramPacket packet = new DatagramPacket(new byte[4096], 4096);
- Object callerArgs[] = new Object[1];
-
try {
while(runnable) {
- receiver.receive(packet);
- String msg = new String(packet.getData(), 0, packet.getLength());
- if ( debugString != null )
- MaxSystem.post(debugString + " " + msg);
- callerArgs[0] = Atom.parse(msg);
- try {
- callback.invoke(instance, callerArgs);
- } catch( Exception e ) {
- e.printStackTrace();
- }
+ Socket socket = receiver.accept();
+ BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
+ parseMessage(reader);
}
} catch (Exception e) {
if ( runnable != false) {
diff --git a/src/java/com/cycling74/net/TcpSender.java b/src/java/com/cycling74/net/TcpSender.java
index 2ba0f67..a092bfb 100644
--- a/src/java/com/cycling74/net/TcpSender.java
+++ b/src/java/com/cycling74/net/TcpSender.java
@@ -1,20 +1,21 @@
package com.cycling74.net;
import java.io.IOException;
-import java.net.DatagramPacket;
-import java.net.DatagramSocket;
-import java.net.InetSocketAddress;
+import java.net.InetAddress;
+import java.net.Socket;
+import java.net.UnknownHostException;
import com.cycling74.max.Atom;
import com.cycling74.max.MaxRuntimeException;
-/**
- * This portion of code is scheduled for pdj-0.8.5
- * IT IS NOT FUNCTIONAL
+/**
+ * Class wrapper to send atoms via TCP/IP. The host on the other side
+ * must use TcpReceive to read the sended atoms.
+ *
+ * This class is a work in progress and have been lightly tested.
*/
public class TcpSender {
- DatagramSocket sender;
- DatagramPacket packet;
+ InetAddress inetAddress;
String address = null;
int port = -1;
@@ -22,58 +23,47 @@ public class TcpSender {
}
public TcpSender(String address, int port) {
- this.address= address;
+ setAddress(address);
this.port = port;
}
public void send(Atom args[]) {
- if ( sender == null )
- initsocket();
-
- byte buff[] = Atom.toOneString(args).getBytes();
- packet.setData(buff, 0, buff.length);
- try {
- sender.send(packet);
- } catch (IOException e) {
- throw new MaxRuntimeException(e);
- }
+ send(Atom.toOneString(args));
}
public void send(int i) {
- if ( sender == null )
- initsocket();
-
- byte buff[] = Integer.toString(i).getBytes();
- packet.setData(buff, 0, buff.length);
- try {
- sender.send(packet);
- } catch (IOException e) {
- throw new MaxRuntimeException(e);
- }
+ send(Integer.toString(i));
}
public void send(float f) {
- if ( sender == null )
- initsocket();
-
- byte buff[] = Float.toString(f).getBytes();
- packet.setData(buff, 0, buff.length);
- try {
- sender.send(packet);
- } catch (IOException e) {
- throw new MaxRuntimeException(e);
- }
+ send(Float.toString(f));
}
+ public void send(String msg) {
+ if ( address == null )
+ throw new MaxRuntimeException("TcpSender has no active hosts");
+ if ( port == -1 )
+ throw new MaxRuntimeException("TcpSender has no active port");
+
+ try {
+ Socket sender = new Socket(inetAddress, port);
+ sender.getOutputStream().write(msg.getBytes());
+ sender.close();
+ } catch (IOException e) {
+ throw new MaxRuntimeException(e);
+ }
+ }
+
public String getAddress() {
return address;
}
public void setAddress(String address) {
- if ( sender != null ) {
- sender = null;
- sender.close();
- }
+ try {
+ inetAddress = InetAddress.getByName(address);
+ } catch (UnknownHostException e) {
+ throw new MaxRuntimeException(e);
+ }
this.address = address;
}
@@ -82,22 +72,6 @@ public class TcpSender {
}
public void setPort(int port) {
- if ( sender != null ) {
- sender = null;
- sender.close();
- }
this.port = port;
}
-
- private synchronized void initsocket() {
- if ( sender != null )
- return;
- try {
- sender = new DatagramSocket();
- sender.connect(new InetSocketAddress(address, port));
- packet = new DatagramPacket(new byte[0], 0);
- } catch (Exception e) {
- throw new MaxRuntimeException(e);
- }
- }
}
diff --git a/src/java/com/cycling74/net/UdpReceiver.java b/src/java/com/cycling74/net/UdpReceiver.java
index fd47e25..f7423fd 100644
--- a/src/java/com/cycling74/net/UdpReceiver.java
+++ b/src/java/com/cycling74/net/UdpReceiver.java
@@ -5,24 +5,32 @@ import java.net.DatagramSocket;
import com.cycling74.max.Atom;
import com.cycling74.max.MaxRuntimeException;
-import com.cycling74.max.MaxSystem;
+//import com.cycling74.max.MaxSystem;
import com.cycling74.max.Callback;
-/**
- * This portion of code is scheduled for pdj-0.8.5
- * IT IS NOT FUNCTIONAL
+/**
+ * Class wrapper to receive atoms via UDP/IP using the class
+ * UdpSender.
+ *
+ * This class is a work in progress and have been lightly tested.
*/
public class UdpReceiver implements Runnable {
DatagramSocket receiver;
DatagramPacket packet;
- Callback callback;
-
+ Callback callback = null;
String debugString = null;
- int port;
boolean runnable = true;
+ int port = -1;
- public void close() {
+ public UdpReceiver() {
+ }
+
+ public UdpReceiver(int port) {
+ this.port = port;
+ }
+
+ public void close() {
if ( receiver == null )
return;
runnable = false;
@@ -34,17 +42,23 @@ public class UdpReceiver implements Runnable {
}
public void setActive(boolean active) {
- if ( active == false ) {
- runnable = true;
- new Thread(this).start();
+ if ( active == true ) {
+ if ( port == -1 )
+ throw new MaxRuntimeException("No UDP port specified");
+ try {
+ receiver = new DatagramSocket(port);
+ } catch ( Exception e ) {
+ throw new MaxRuntimeException(e);
+ }
+ runnable = true;
+ new Thread(this, "UdpReceiver[" + port + "]").start();
} else {
close();
}
-
}
public void setCallback(Object caller, String methodName) {
- callback = new Callback(caller, methodName);
+ callback = new Callback(caller, methodName, new Object[] { new Atom[0] });
}
public void setPort(int port) {
@@ -57,22 +71,22 @@ public class UdpReceiver implements Runnable {
}
public void run() {
- DatagramPacket packet = new DatagramPacket(new byte[4096], 4096);
- Object callerArgs[] = new Object[1];
-
try {
while(runnable) {
+ DatagramPacket packet = new DatagramPacket(new byte[4096], 4096);
receiver.receive(packet);
String msg = new String(packet.getData(), 0, packet.getLength());
- if ( debugString != null )
- MaxSystem.post(debugString + " " + msg);
- callerArgs[0] = Atom.parse(msg);
-
- /* try {
- callback.invoke(instance, callerArgs);
- } catch( Exception e ) {
- e.printStackTrace();
- } */
+ //if ( debugString != null )
+ // MaxSystem.post(debugString + " " + msg);
+
+ if ( callback != null ) {
+ callback.setArgs(Atom.parse(msg));
+ try {
+ callback.execute();
+ } catch( Exception e ) {
+ e.printStackTrace();
+ }
+ }
}
} catch (Exception e) {
if ( runnable != false) {
diff --git a/src/java/com/cycling74/net/UdpSender.java b/src/java/com/cycling74/net/UdpSender.java
index 6ef7e34..e4c2d53 100644
--- a/src/java/com/cycling74/net/UdpSender.java
+++ b/src/java/com/cycling74/net/UdpSender.java
@@ -8,9 +8,11 @@ import java.net.InetAddress;
import com.cycling74.max.Atom;
import com.cycling74.max.MaxRuntimeException;
-/**
- * This portion of code is scheduled for pdj-0.8.5
- * IT IS NOT FUNCTIONAL
+/**
+ * Class wrapper to send atoms via UDP/IP. The host on the other side
+ * must use UdpReceive to read the sended atoms.
+ *
+ * This class is a work in progress and have been lightly tested.
*/
public class UdpSender {
InetAddress inetAddress;
@@ -23,6 +25,11 @@ public class UdpSender {
public UdpSender() {
}
+ /**
+ * Create a UpdSender.
+ * @param address the hostname/ip address of the host to reach
+ * @param port the UDP port to use
+ */
public UdpSender(String address, int port) {
this.address = address;
this.port = port;
@@ -41,22 +48,45 @@ public class UdpSender {
send(Float.toString(f).getBytes());
}
+ public void send(String msg, Atom args[]) {
+ send((msg + " " + Atom.toOneString(args)).getBytes());
+ }
+
+ /**
+ * Returns the hostname/ip address to reach.
+ * @return hostname/ip address to reach
+ */
public String getAddress() {
return address;
}
+ /**
+ * Sets hostname/ip address to reach.
+ * @param address hostname/ip address to reach
+ */
+
public void setAddress(String address) {
this.address = address;
- initsocket();
+ if ( port != -1 )
+ initsocket();
}
+ /**
+ * Returns the UDP port to use.
+ * @return the UDP port to use
+ */
public int getPort() {
return port;
}
+ /**
+ * Sets the UDP port to use.
+ * @param port the UDP port to use
+ */
public void setPort(int port) {
this.port = port;
- initsocket();
+ if ( address != null )
+ initsocket();
}
synchronized void initsocket() {
@@ -71,14 +101,13 @@ public class UdpSender {
void send(byte buff[]) {
if ( sender == null )
- throw new MaxRuntimeException("UdpSender is not initialized");
-
+ throw new MaxRuntimeException("UdpSender: UPD port or address is missing");
+
try {
DatagramPacket packet = new DatagramPacket(buff, buff.length, inetAddress, port);
sender.send(packet);
} catch (IOException e) {
throw new MaxRuntimeException(e);
}
-
}
}
diff --git a/src/java/com/cycling74/net/package.html b/src/java/com/cycling74/net/package.html
new file mode 100644
index 0000000..830ac7c
--- /dev/null
+++ b/src/java/com/cycling74/net/package.html
@@ -0,0 +1,5 @@
+<html>
+<body>
+<p>Network utilities for sending atoms.</p>
+</body>
+</html> \ No newline at end of file
diff --git a/src/java/com/e1/pdj/PDJSystem.java b/src/java/com/e1/pdj/PDJSystem.java
index 1fd50d2..ac3fd47 100644
--- a/src/java/com/e1/pdj/PDJSystem.java
+++ b/src/java/com/e1/pdj/PDJSystem.java
@@ -2,12 +2,10 @@ package com.e1.pdj;
import com.cycling74.max.MaxSystem;
-import java.awt.Component;
-import java.awt.Frame;
import java.awt.Toolkit;
import java.io.*;
-
import java.awt.GraphicsEnvironment;
+
/**
* Startup class for pdj.
*/
@@ -24,7 +22,7 @@ public class PDJSystem {
public static void _init_system() {
if ( loaded == 1 )
return;
- linknative();
+ javainit();
initIO();
}
@@ -42,49 +40,29 @@ public class PDJSystem {
GenericCompiler.rtJar = systemCpJar + ps + "jre" + ps + "lib" + ps + "rt.jar" + File.pathSeparator;
}
- /**
- * Link the Java native classes
- */
- static void linknative() {
- String pdjHome = System.getProperty("pdj.home");
+ static void javainit() {
// this is a hack to be sure that statics of MaxSystem are loaded
// before everything
Class cls = MaxSystem.class;
String osname = System.getProperty("os.name");
-
- if ( osname.indexOf("Linux") != -1 ) {
- // maps PD object as a JVM native library
- Runtime.getRuntime().load(pdjHome + "/pdj.pd_linux");
- loaded = 1;
- resolvRtJar();
- return;
- }
-
- if ( osname.indexOf("Windows") != -1 ) {
- // maps PD object as a JVM native library
- Runtime.getRuntime().load(pdjHome + "/pdj.dll");
- loaded = 1;
- resolvRtJar();
- return;
- }
-
if ( osname.indexOf("OS X") != -1 ) {
- // maps PD object as a JVM native library
- Runtime.getRuntime().load(pdjHome + "/pdj.d_fat");
- loaded = 1;
-
- if ( System.getenv("PDJ_USE_AWT") != null ) {
- GraphicsEnvironment.getLocalGraphicsEnvironment().getScreenDevices();
- Toolkit.getDefaultToolkit();
- }
- GenericCompiler.rtJar = "/System/Library/Frameworks/JavaVM.framework/Classes/classes.jar:";
-
- return;
- }
-
- System.err.println("pdj: operating system type not found, the native link has not been made");
+ try {
+ if (System.getenv("PDJ_USE_AWT") != null) {
+ GraphicsEnvironment.getLocalGraphicsEnvironment().getScreenDevices();
+ Toolkit.getDefaultToolkit();
+ }
+ } catch (Error e) {
+ // on java 1.4, this will throw an error, we simply ignore AWT with 1.4
+ }
+ GenericCompiler.rtJar = "/System/Library/Frameworks/JavaVM.framework/Classes/classes.jar:";
+ loaded = 1;
+ return;
+ }
+
+ loaded = 1;
+ resolvRtJar();
}
static boolean redirectIO() {
diff --git a/src/java/com/e1/pdj/test/CallbackTest.java b/src/java/com/e1/pdj/test/CallbackTest.java
index 4105479..526a5f4 100644
--- a/src/java/com/e1/pdj/test/CallbackTest.java
+++ b/src/java/com/e1/pdj/test/CallbackTest.java
@@ -1,10 +1,20 @@
package com.e1.pdj.test;
+import com.cycling74.max.*;
import junit.framework.TestCase;
public class CallbackTest extends TestCase {
- public void testSomething() {
+
+
+ public void testArgs() {
+ Callback callback = new Callback(this, "callme", new Object[] { new Integer[0] });
+ Integer[] args = new Integer[] { new Integer(1), new Integer(2) };
+ callback.setArgs((Object[]) args);
+ callback.execute();
+ }
+
+ public void callme(Integer args[]) {
}
}
diff --git a/src/java/com/e1/pdj/test/NetTest.java b/src/java/com/e1/pdj/test/NetTest.java
new file mode 100644
index 0000000..01b103a
--- /dev/null
+++ b/src/java/com/e1/pdj/test/NetTest.java
@@ -0,0 +1,55 @@
+package com.e1.pdj.test;
+
+import com.cycling74.max.*;
+import com.cycling74.net.*;
+import junit.framework.TestCase;
+
+public class NetTest extends TestCase {
+ Atom value[];
+
+ public void testUDP() {
+ UdpReceiver receive = new UdpReceiver(7500);
+ receive.setCallback(this, "callback_test");
+ receive.setActive(true);
+
+ value = null;
+
+ UdpSender send = new UdpSender("localhost", 7500);
+ send.send(7500);
+
+ try {
+ Thread.sleep(1000);
+ } catch ( InterruptedException e ) {
+ }
+
+ receive.close();
+
+ assertNotNull(value);
+ assertEquals(Integer.parseInt(value[0].toString()), 7500);
+ }
+
+ public void callback_test(Atom args[]) {
+ value = args;
+ }
+
+ public void testTCP() {
+ TcpReceiver receive = new TcpReceiver(7500);
+ receive.setCallback(this, "callback_test");
+ receive.setActive(true);
+
+ value = null;
+
+ TcpSender send = new TcpSender("localhost", 7500);
+ send.send(7500);
+
+ try {
+ Thread.sleep(1000);
+ } catch ( InterruptedException e ) {
+ }
+
+ receive.close();
+
+ assertNotNull(value);
+ assertEquals(Integer.parseInt(value[0].toString()), 7500);
+ }
+}
diff --git a/src/java/pdj_test_class.java b/src/java/pdj_test_class.java
index 61cf804..949e2e9 100644
--- a/src/java/pdj_test_class.java
+++ b/src/java/pdj_test_class.java
@@ -51,6 +51,11 @@ public class pdj_test_class extends MaxObject implements Executable {
protected void inlet(float f) {
post("le float " + f + "inlet " + getInlet());
+
+ Atom args[] = new Atom[2];
+ args[0] = Atom.newAtom(1);
+
+ outlet(0, args);
}
void wer(Atom[] atom) {
generated by cgit v1.2.1 (git 2.18.0) at 2024-11-16 04:20:39 +0000