org.qbroker.cluster

Class PacketNodeBean

java.lang.Object

org.qbroker.cluster.PacketNodeBean

All Implemented Interfaces:

java.io.Serializable

public class PacketNodeBean
extends java.lang.Object
implements java.io.Serializable

PacketNodeBean is a collection of properties for tracking the state of a given source of UPD packets

A PacketNodeBean has bunch of node properties, like name, role, address, port, hearbeat, status, latest timestamp, sequence ID, packet type, packet count, packet info and the first packet. It is used for tracking the state of the node. It can also be used for non UPD schemes.

There are 3 getters and setters for extra uri, address and port, respectively. They are used for storing extra data for the node.

It is NOT MT-Safe. So use it with care.

Author:

yannanlu@yahoo.com

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	MCG_CONFRM
static int	MCG_DATA
static int	MCG_HBEAT
static int	MCG_HSHAKE
static int	MCG_NOTICE
static int	MCG_QUERY
static int	MCG_QUIT
static int	MCG_UPDATE
static int	PKT_ACK
static int	PKT_COUNT
static int	PKT_ROLE
static int	PKT_SID
static int	PKT_STATUS
static int	PKT_TIME
static int	PTP_CONFRM
static int	PTP_DATA
static int	PTP_HBEAT
static int	PTP_HSHAKE
static int	PTP_NOTICE
static int	PTP_QUERY
static int	PTP_QUIT
static int	PTP_UPDATE

Constructor Summary

Constructors

Constructor and Description
PacketNodeBean()

Method Summary

Modifier and Type	Method and Description
void	clear()
protected void	finalize()
java.net.InetAddress	getAddress()
java.lang.String	getContent(int type)
long	getCount()
java.lang.String	getData()
java.net.InetAddress	getExtraAddress()
int	getExtraPort()
java.lang.String	getExtraURI()
long	getLatestTime()
java.lang.String	getName()
java.net.DatagramPacket	getPacket()
long	getPacketInfo(int type, int i)
int	getPacketType()
int	getPort()
int	getRefCount()
int	getRole()
long	getSid()
int	getStatus()
long	getTimestamp()
java.lang.String	getUri()
boolean	isInitialized()
void	setExtraAddress(java.net.InetAddress a)
void	setExtraPort(int port)
void	setExtraURI(java.lang.String u)
int	setPacket(java.net.DatagramPacket packet) It parses the header of packet and updates properties.
void	setPattern(java.lang.String pattern)
void	setRefCount(int refCount)
void	setRole(int role)
void	setStatus(int status)
void	storePacket(java.net.DatagramPacket packet, int type) It stores the header and body of the packet to packetInfo as the given type for public access.

Methods inherited from class java.lang.Object

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

Field Detail

MCG_HBEAT

public static final int MCG_HBEAT

See Also:

Constant Field Values

MCG_QUIT

public static final int MCG_QUIT

See Also:

Constant Field Values

MCG_HSHAKE

public static final int MCG_HSHAKE

See Also:

Constant Field Values

MCG_NOTICE

public static final int MCG_NOTICE

See Also:

Constant Field Values

MCG_UPDATE

public static final int MCG_UPDATE

See Also:

Constant Field Values

MCG_CONFRM

public static final int MCG_CONFRM

See Also:

Constant Field Values

MCG_QUERY

public static final int MCG_QUERY

See Also:

Constant Field Values

MCG_DATA

public static final int MCG_DATA

See Also:

Constant Field Values

PTP_HBEAT

public static final int PTP_HBEAT

See Also:

Constant Field Values

PTP_QUIT

public static final int PTP_QUIT

See Also:

Constant Field Values

PTP_HSHAKE

public static final int PTP_HSHAKE

See Also:

Constant Field Values

PTP_NOTICE

public static final int PTP_NOTICE

See Also:

Constant Field Values

PTP_UPDATE

public static final int PTP_UPDATE

See Also:

Constant Field Values

PTP_CONFRM

public static final int PTP_CONFRM

See Also:

Constant Field Values

PTP_QUERY

public static final int PTP_QUERY

See Also:

Constant Field Values

PTP_DATA

public static final int PTP_DATA

See Also:

Constant Field Values

PKT_TIME

public static final int PKT_TIME

See Also:

Constant Field Values

PKT_SID

public static final int PKT_SID

See Also:

Constant Field Values

PKT_ROLE

public static final int PKT_ROLE

See Also:

Constant Field Values

PKT_STATUS

public static final int PKT_STATUS

See Also:

Constant Field Values

PKT_ACK

public static final int PKT_ACK

See Also:

Constant Field Values

PKT_COUNT

public static final int PKT_COUNT

See Also:

Constant Field Values

Constructor Detail

PacketNodeBean

public PacketNodeBean()

Method Detail

clear

public void clear()

setPattern

public void setPattern(java.lang.String pattern)

storePacket

public void storePacket(java.net.DatagramPacket packet,
                        int type)

It stores the header and body of the packet to packetInfo as the given type for public access. There is no update on the node properties, like status, packetType, timestamp, etc.

setPacket

public int setPacket(java.net.DatagramPacket packet)

It parses the header of packet and updates properties. Then it stores the body into packetInfo for public access. The class member of packet is kind of final. It will be initialized at the first set. After that it is read-only. But its content can be changed. The update will be controlled by the sid and timestamp. If it is a new packet, the packetInfo and metadata will be updated. In this case, it returns 1 to indicate success. Otherwise, 0 will be returned for valid packet or -1 for parsing failure.

getPacket

public java.net.DatagramPacket getPacket()

getAddress

public java.net.InetAddress getAddress()

getPort

public int getPort()

getContent

public java.lang.String getContent(int type)

getPacketInfo

public long getPacketInfo(int type,
                          int i)

getPacketType

public int getPacketType()

getSid

public long getSid()

getTimestamp

public long getTimestamp()

getLatestTime

public long getLatestTime()

getCount

public long getCount()

getRefCount

public int getRefCount()

setRefCount

public void setRefCount(int refCount)

getName

public java.lang.String getName()

getUri

public java.lang.String getUri()

getRole

public int getRole()

setRole

public void setRole(int role)

getStatus

public int getStatus()

setStatus

public void setStatus(int status)

getData

public java.lang.String getData()

isInitialized

public boolean isInitialized()

getExtraURI

public java.lang.String getExtraURI()

setExtraURI

public void setExtraURI(java.lang.String u)

getExtraAddress

public java.net.InetAddress getExtraAddress()

setExtraAddress

public void setExtraAddress(java.net.InetAddress a)

getExtraPort

public int getExtraPort()

setExtraPort

public void setExtraPort(int port)

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object