|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.javagroups.blocks.LogicalLink
Implements a logical point-to-point link between 2 entities consisting of a number of physical links. Traffic is routed over any of the physical link, according to policies. Examples are: send traffic over all links, round-robin, use first link for 70% of traffic, other links for the remaining 30%.
Nested Class Summary | |
---|---|
class |
LogicalLink.AllLinksDown
|
class |
LogicalLink.NoLinksAvailable
|
static interface |
LogicalLink.Receiver
|
Constructor Summary | |
---|---|
LogicalLink()
|
|
LogicalLink(LogicalLink.Receiver r)
|
Method Summary | |
---|---|
void |
addLink(java.lang.String local_addr,
int local_port,
java.lang.String remote_addr,
int remote_port)
|
void |
addLink(java.lang.String local_addr,
int local_port,
java.lang.String remote_addr,
int remote_port,
long timeout,
long hb_interval)
|
java.util.Vector |
getLinks()
|
void |
linkDown(java.net.InetAddress local,
int local_port,
java.net.InetAddress remote,
int remote_port)
One of the physical links went down |
void |
linkUp(java.net.InetAddress local,
int local_port,
java.net.InetAddress remote,
int remote_port)
One of the physical links came up |
static void |
main(java.lang.String[] args)
|
void |
missedHeartbeat(java.net.InetAddress local,
int local_port,
java.net.InetAddress remote,
int remote_port,
int num_missed_hbs)
Missed one or more heartbeats. |
int |
numberOfEstablishedLinks()
|
int |
numberOfLinks()
|
void |
receive(byte[] buf)
Receive a message from any of the physical links. |
void |
receivedHeartbeatAgain(java.net.InetAddress local,
int local_port,
java.net.InetAddress remote,
int remote_port)
Heartbeat came back again (before link was taken down) after missing some heartbeats |
void |
removeAllLinks()
|
boolean |
send(byte[] buf)
Send a message to the other side |
void |
setReceiver(LogicalLink.Receiver r)
|
void |
start()
Start all links |
void |
stop()
Stop all links |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public LogicalLink(LogicalLink.Receiver r)
public LogicalLink()
Method Detail |
public void addLink(java.lang.String local_addr, int local_port, java.lang.String remote_addr, int remote_port)
public void addLink(java.lang.String local_addr, int local_port, java.lang.String remote_addr, int remote_port, long timeout, long hb_interval)
public void removeAllLinks()
public java.util.Vector getLinks()
public int numberOfLinks()
public int numberOfEstablishedLinks()
public void start()
public void stop()
public boolean send(byte[] buf) throws LogicalLink.AllLinksDown, LogicalLink.NoLinksAvailable
LogicalLink.AllLinksDown
LogicalLink.NoLinksAvailable
public void setReceiver(LogicalLink.Receiver r)
public void receive(byte[] buf)
receive
in interface Link.Receiver
public void linkDown(java.net.InetAddress local, int local_port, java.net.InetAddress remote, int remote_port)
linkDown
in interface Link.Receiver
public void linkUp(java.net.InetAddress local, int local_port, java.net.InetAddress remote, int remote_port)
linkUp
in interface Link.Receiver
public void missedHeartbeat(java.net.InetAddress local, int local_port, java.net.InetAddress remote, int remote_port, int num_missed_hbs)
missedHeartbeat
in interface Link.Receiver
public void receivedHeartbeatAgain(java.net.InetAddress local, int local_port, java.net.InetAddress remote, int remote_port)
receivedHeartbeatAgain
in interface Link.Receiver
public static void main(java.lang.String[] args)
|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |