diff src/fdl/test/TestMetaLinda.java @ 28:132c9bc28d6b

*** empty log message ***
author kono
date Wed, 20 Aug 2008 18:11:30 +0900
parents
children 7a74d7396d65
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/fdl/test/TestMetaLinda.java	Wed Aug 20 18:11:30 2008 +0900
@@ -0,0 +1,86 @@
+/*
+ * @(#)TestMetaLinda.java       1.1 06/04/01
+ *
+ * Copyright 2006  Shinji KONO
+ * 
+
+   Test PSX Lidna
+
+ */
+
+package fdl.test;
+
+import java.io.IOException;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.net.UnknownHostException;
+import java.nio.ByteBuffer;
+
+import fdl.FederatedLinda;
+import fdl.PSXLinda;
+import fdl.PSXReply;
+import fdl.PSX;
+
+
+/**
+ *   PSXLinda stream
+ *
+ * @author Shinji Kono
+ *
+ * @param host The host to connect to
+ * @param port The port to connect to at the host
+
+ */
+
+
+public class TestMetaLinda {
+	static int id;
+	public static void main (String args[]) {
+
+		FederatedLinda fdl;
+		PSXLinda psx;
+		String host;
+		int port = 10000;
+		PSXReply r;
+		InetSocketAddress localAddress;
+
+
+		try {
+			localAddress = new InetSocketAddress(InetAddress.getLocalHost(), port);
+			host = localAddress.getHostName();
+		} catch (UnknownHostException e) {
+			host = "localhost";
+		}
+
+		try {
+			fdl = FederatedLinda.init();
+			psx = fdl.open(host,port);
+			System.out.println("Connected.");
+
+			ByteBuffer data = ByteBuffer.allocate(10);
+
+			for(int i=0;i<10;i++) {
+				data.clear();
+				data.putInt(i);
+				data.flip();
+				psx.out(1,data);
+				r = psx.in(1);
+				if (r.ready()) {
+					System.out.println("Get:"+r.data);
+					r = psx.in(1);
+				}
+				psx.sync(100);
+			}
+
+			data.clear();
+			psx.out(PSX.META_STOP, data);
+			psx.sync();
+			
+		} catch (IOException e) {
+			System.err.println("Communication failure.");
+		}
+	}
+
+
+}
+