rina.flow
Class Flow

java.lang.Object
  rina.flow.Flow

All Implemented Interfaces:

FlowAPI

public class Flow
extends java.lang.Object
implements FlowAPI

This class is used to create a flow for Zero DIF It uses TCP flow.

Version:

1.0

Author:

Yuefeng Wang and Flavio Esposito . Computer Science Department, Boston University

Constructor Summary

Flow(java.lang.String srcIPCName, java.lang.String dstIPCName)

Flow(java.lang.String srcIPCName, java.lang.String dstIPCName, int dstPort)

Flow(java.lang.String srcIPCName, java.lang.String dstIPCName, int dstPort, TCPFlow tcpFlow)

Flow(java.lang.String srcIPCName, java.lang.String dstIPCName, java.lang.String srcUnderlyingIPCName, java.lang.String dstUnderlyingIPCName, Flow underlyingFlow)

Flow(java.lang.String srcIPCName, java.lang.String dstIPCName, java.lang.String srcUnderlyingIPCName, java.lang.String dstUnderlyingIPCName, int dstPort, Flow underlyingFlow)

Flow(java.lang.String srcIPCName, java.lang.String dstIPCName, TCPFlow tcpFlow)

Method Summary

java.lang.String	getDstIPCName()
int	getDstPort()
MessageQueue	getMsgQueue()
java.lang.String	getSrcIPCName()
int	getSrcPort()
TCPFlow	getTcpFlow()
Flow	getUnderlyingFlow()
void	printFlow()
byte[]	receive()
void	send(byte[] message)
void	sendCDAPMsg(byte[] cdapMsg)
void	sendDTPMsg(byte[] dtpMsg)
void	setDstIPCName(java.lang.String dstIPCName)
void	setDstPort(int dstPort)
void	setMsgQueue(MessageQueue msgQueue)
void	setSrcIPCName(java.lang.String srcIPCName)
void	setSrcPort(int srcPort)
void	setTcpFlow(TCPFlow tcpFlow)
void	setUnderlyingFlow(Flow underlyingFlow)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Flow

public Flow(java.lang.String srcIPCName,
            java.lang.String dstIPCName)

Flow

public Flow(java.lang.String srcIPCName,
            java.lang.String dstIPCName,
            TCPFlow tcpFlow)

Flow

public Flow(java.lang.String srcIPCName,
            java.lang.String dstIPCName,
            int dstPort,
            TCPFlow tcpFlow)

Flow

public Flow(java.lang.String srcIPCName,
            java.lang.String dstIPCName,
            int dstPort)

Flow

public Flow(java.lang.String srcIPCName,
            java.lang.String dstIPCName,
            java.lang.String srcUnderlyingIPCName,
            java.lang.String dstUnderlyingIPCName,
            Flow underlyingFlow)

Flow

public Flow(java.lang.String srcIPCName,
            java.lang.String dstIPCName,
            java.lang.String srcUnderlyingIPCName,
            java.lang.String dstUnderlyingIPCName,
            int dstPort,
            Flow underlyingFlow)

Method Detail

send

public void send(byte[] message)
          throws java.lang.Exception

Specified by:

send in interface FlowAPI

Parameters:

message - to send

Throws:

java.lang.Exception

receive

public byte[] receive()

Specified by:

receive in interface FlowAPI

Returns:

message

sendDTPMsg

public void sendDTPMsg(byte[] dtpMsg)
                throws java.lang.Exception

Throws:

java.lang.Exception

sendCDAPMsg

public void sendCDAPMsg(byte[] cdapMsg)
                 throws java.lang.Exception

Throws:

java.lang.Exception

printFlow

public void printFlow()

getSrcPort

public int getSrcPort()

Returns:

the srcPort

setSrcPort

public void setSrcPort(int srcPort)

Parameters:

srcPort - the srcPort to set

getDstPort

public int getDstPort()

Returns:

the dstPort

setDstPort

public void setDstPort(int dstPort)

Parameters:

dstPort - the dstPort to set

getDstIPCName

public java.lang.String getDstIPCName()

Returns:

the dstIPCName

setDstIPCName

public void setDstIPCName(java.lang.String dstIPCName)

Parameters:

dstIPCName - the dstIPCName to set

getSrcIPCName

public java.lang.String getSrcIPCName()

Returns:

the srcIPCName

setSrcIPCName

public void setSrcIPCName(java.lang.String srcIPCName)

Parameters:

srcIPCName - the srcIPCName to set

getMsgQueue

public MessageQueue getMsgQueue()

Returns:

the msgQueue

setMsgQueue

public void setMsgQueue(MessageQueue msgQueue)

Parameters:

msgQueue - the msgQueue to set

getTcpFlow

public TCPFlow getTcpFlow()

Returns:

the tcpFlow

setTcpFlow

public void setTcpFlow(TCPFlow tcpFlow)

Parameters:

tcpFlow - the tcpFlow to set

getUnderlyingFlow

public Flow getUnderlyingFlow()

Returns:

the underlyingFlow

setUnderlyingFlow

public void setUnderlyingFlow(Flow underlyingFlow)

Parameters:

underlyingFlow - the underlyingFlow to set