Mercurial > hg > FederatedLinda
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."); + } + } + + +} +