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;
    }*/    
}