public class LogicalLink extends java.lang.Object implements Link.Receiver
Modifier and Type | Class and Description |
---|---|
class |
LogicalLink.AllLinksDown |
class |
LogicalLink.NoLinksAvailable |
static interface |
LogicalLink.Receiver |
Constructor and Description |
---|
LogicalLink() |
LogicalLink(LogicalLink.Receiver r) |
Modifier and Type | Method and Description |
---|---|
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
|
public LogicalLink(LogicalLink.Receiver r)
public LogicalLink()
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
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)
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.