Mercurial > hg > FederatedLinda
view src/fdl/Tuple.java @ 23:b4fd7fb9135a
Simple Test run.
author | kono |
---|---|
date | Wed, 20 Aug 2008 03:28:45 +0900 |
parents | 56e015e8f5dc |
children | 35375016b2f0 |
line wrap: on
line source
package fdl; import java.nio.ByteBuffer; import java.nio.channels.SocketChannel; public class Tuple { public int mode; public int id; public int seq; public ByteBuffer command; public ByteBuffer data; public SocketChannel ch; public Tuple next; static final boolean debug = false; public Tuple() { } public Tuple(SocketChannel ch) { this.ch = ch; } public void setCommand(int _mode, int _seq) { setCommand( _mode, id, _seq,data.limit()); } public void setCommand(int _mode, int _id, int _seq, int _datalen) { command = PSX.setCommand(_mode, _id, _seq, _datalen); } public void setTuple(int _mode,int _id, int _seq, ByteBuffer _data) { mode = _mode; id = _id; seq = _seq; data = _data; if (debug) { System.out.print("setTuple mode:"); System.out.println(mode); } //setCommand(); } public void setSeq(int _seq) { seq = _seq; } public void setMode(int _mode) { mode = _mode; } public void setData(ByteBuffer _data) { data = _data; } public int getMode() { return mode; } public int getSeq() { return seq; } public int getdataLength() { return data.limit(); } public ByteBuffer getData() { return data; } public ByteBuffer getCommand() { return this.command; } /*public ByteBuffer getCommand() { command = ByteBuffer.allocate(LINDA_HEADER_SIZE); command.order(ByteOrder.BIG_ENDIAN); command.putInt(LINDA_PACKET_LENGTH_OFFSET, LINDA_HEADER_SIZE+datalen-INT_SIZE); command.put(LINDA_MODE_OFFSET, (byte)mode); command.putShort(LINDA_ID_OFFSET,(short)id); command.putInt(LINDA_SEQ_OFFSET, seq); command.putInt(LINDA_DATA_LENGTH_OFFSET, datalen); command.rewind(); return command; }*/ }