org.jgroups.protocols
Class WANPIPE
- LogicalLink.Receiver
Logical point-to-point link. Uses multiple physical links to provide a reliable transport. For example,
if there are 2 physical links over different networks, and one of them fails, the WAN pipe will still be
able to send traffic over the other link. Currently traffic is sent over the physical links round-robin,
but this will be made configurable in the future. Example: 70% over first link, 30% over second, or
packets are split and sent across both links (increasing the available bandwidth).
down_handler , down_prot , down_queue , down_thread , down_thread_prio , log , observer , props , stack , stats , trace , up_handler , up_prot , up_queue , up_thread , up_thread_prio , warn |
void | down(Event evt) - Sent to destination(s) using the WAN pipe.
|
String | getName()
|
void | linkDown(InetAddress local, int local_port, InetAddress remote, int remote_port)
|
void | linkUp(InetAddress local, int local_port, InetAddress remote, int remote_port)
|
void | missedHeartbeat(InetAddress local, int local_port, InetAddress remote, int remote_port, int num_hbs)
|
void | receive(byte[] buf)
|
void | receivedHeartbeatAgain(InetAddress local, int local_port, InetAddress remote, int remote_port)
|
boolean | setProperties(Properties props) - Setup the Protocol instance acording to the configuration string
|
void | start() - This method is called on a
Channel.connect(String) .
|
void | stop() - This method is called on a
Channel.disconnect() .
|
String | toString()
|
destroy , down , downThreadEnabled , dumpStats , enableStats , getDownProtocol , getDownQueue , getName , getProperties , getUpProtocol , getUpQueue , handleSpecialDownEvent , init , isTrace , isWarn , passDown , passUp , printStats , providedDownServices , providedUpServices , receiveDownEvent , receiveUpEvent , requiredDownServices , requiredUpServices , resetStats , setDownProtocol , setObserver , setProperties , setPropertiesInternal , setProtocolStack , setTrace , setUpProtocol , setWarn , start , startDownHandler , startUpHandler , statsEnabled , stop , stopInternal , up , upThreadEnabled |
down
public void down(Event evt)
Sent to destination(s) using the WAN pipe. Send local messages directly back up the stack
- down in interface Protocol
linkDown
public void linkDown(InetAddress local,
int local_port,
InetAddress remote,
int remote_port)
- linkDown in interface LogicalLink.Receiver
linkUp
public void linkUp(InetAddress local,
int local_port,
InetAddress remote,
int remote_port)
- linkUp in interface LogicalLink.Receiver
missedHeartbeat
public void missedHeartbeat(InetAddress local,
int local_port,
InetAddress remote,
int remote_port,
int num_hbs)
- missedHeartbeat in interface LogicalLink.Receiver
setProperties
public boolean setProperties(Properties props)
Setup the Protocol instance acording to the configuration string
- setProperties in interface Protocol
start
public void start()
throws Exception
This method is called on a
Channel.connect(String)
. Starts work.
Protocols are connected and queues are ready to receive events.
Will be called
from bottom to top. This call will replace
the
START and
START_OK events.
- start in interface Protocol
stop
public void stop()
This method is called on a
Channel.disconnect()
. Stops work (e.g. by closing multicast socket).
Will be called
from top to bottom. This means that at the time of the method invocation the
neighbor protocol below is still working. This method will replace the
STOP,
STOP_OK,
CLEANUP and
CLEANUP_OK events. The ProtocolStack guarantees that
when this method is called all messages in the down queue will have been flushed
- stop in interface Protocol
toString
public String toString()
Copyright B) 1998-2005 Bela Ban. All Rights Reserved.