org.jgroups.protocols

Class UNICAST2

java.lang.Object

org.jgroups.stack.Protocol

org.jgroups.protocols.UNICAST2

All Implemented Interfaces:

AgeOutCache.Handler<Address>

Deprecated.

Will be removed in 4.0

@Deprecated
public class UNICAST2
extends Protocol
implements AgeOutCache.Handler<Address>

Reliable unicast layer. Implemented with negative acks. Every sender keeps its messages in an AckSenderWindow. A receiver stores incoming messages in a NakReceiverWindow, and asks the sender for retransmission if a gap is detected. Every now and then (stable_interval), a timer task sends a STABLE message to all senders, including the highest received and delivered seqnos. A sender purges messages lower than highest delivered and asks the STABLE sender for messages it might have missed (smaller than highest received). A STABLE message can also be sent when a receiver has received more than max_bytes from a given sender.

The advantage of this protocol over UNICAST is that it doesn't send acks for every message. Instead, it sends 'acks' after receiving max_bytes and/ or periodically (stable_interval).

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	UNICAST2.ConnectionReaper Deprecated.
protected class	UNICAST2.ReceiverEntry Deprecated.
protected class	UNICAST2.RetransmitTask Deprecated. Retransmitter task which periodically (every xmit_interval ms) looks at all the retransmit tables and sends retransmit request to all members from which we have missing messages
protected class	UNICAST2.SenderEntry Deprecated.
static class	UNICAST2.Unicast2Header Deprecated. The following types and fields are serialized:

Field Summary

Fields

Modifier and Type	Field and Description
protected AgeOutCache<Address>	cache Deprecated.
protected long	conn_expiry_timeout Deprecated.
protected java.util.concurrent.Future<?>	connection_reaper Deprecated.
static long	DEFAULT_FIRST_SEQNO Deprecated.
protected static Filter<Message>	dont_loopback_filter Deprecated.
protected int	exponential_backoff Deprecated.
protected short	last_conn_id Deprecated.
protected Address	local_addr Deprecated.
protected boolean	log_not_found_msgs Deprecated.
protected long	max_bytes Deprecated.
protected int	max_msg_batch_size Deprecated.
protected long	max_retransmit_time Deprecated.
protected int	max_stable_msgs Deprecated.
protected java.util.List<Address>	members Deprecated.
protected int	num_messages_received Deprecated.
protected int	num_messages_sent Deprecated.
protected java.util.concurrent.ConcurrentMap<Address,UNICAST2.ReceiverEntry>	recv_table Deprecated.
protected java.util.concurrent.locks.ReentrantLock	recv_table_lock Deprecated.
protected boolean	running Deprecated.
protected java.util.concurrent.ConcurrentMap<Address,UNICAST2.SenderEntry>	send_table Deprecated.
protected long	stable_interval Deprecated.
protected java.util.concurrent.Future<?>	stable_task_future Deprecated.
protected int[]	timeout Deprecated.
protected TimeScheduler	timer Deprecated.
protected boolean	use_range_based_retransmitter Deprecated.
protected long	xmit_interval Deprecated.
protected java.util.concurrent.atomic.AtomicLong	xmit_reqs_received Deprecated.
protected java.util.concurrent.atomic.AtomicLong	xmit_reqs_sent Deprecated.
protected java.util.concurrent.atomic.AtomicLong	xmit_rsps_sent Deprecated.
protected boolean	xmit_table_automatic_purging Deprecated.
protected long	xmit_table_max_compaction_time Deprecated.
protected int	xmit_table_msgs_per_row Deprecated.
protected int	xmit_table_num_rows Deprecated.
protected double	xmit_table_resize_factor Deprecated.
protected java.util.concurrent.Future<?>	xmit_task Deprecated. RetransmitTask running every xmit_interval ms
protected java.util.Map<Address,java.lang.Long>	xmit_task_map Deprecated. Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/browse/JGRP-1539)

Fields inherited from class org.jgroups.stack.Protocol

after_creation_hook, down_prot, ergonomics, id, log, name, stack, stats, up_prot

Constructor Summary

Constructors

Constructor and Description
UNICAST2() Deprecated.

Method Summary

Modifier and Type	Method and Description
boolean	connectionEstablished(Address target) Deprecated. Is the send connection to target established
java.lang.Object	down(Event evt) Deprecated. An event is to be sent down the stack.
void	expired(Address key) Deprecated. Called by AgeOutCache, to removed expired connections
AgeOutCache<Address>	getAgeOutCache() Deprecated.
int	getAgeOutCacheSize() Deprecated.
java.lang.String	getLocalAddress() Deprecated.
long	getMaxRetransmitTime() Deprecated.
java.lang.String	getMembers() Deprecated.
protected short	getNewConnectionId() Deprecated.
int	getNumConnections() Deprecated.
int	getNumReceiveConnections() Deprecated.
int	getNumSendConnections() Deprecated.
protected UNICAST2.ReceiverEntry	getOrCreateReceiverEntry(Address sender, long seqno, short conn_id) Deprecated.
protected UNICAST2.ReceiverEntry	getReceiverEntry(Address sender, long seqno, boolean first, short conn_id) Deprecated.
int[]	getTimeout() Deprecated.
TimeScheduler	getTimer() Deprecated.
long	getXmitTableMissingMessages() Deprecated.
int	getXmitTableNumCompactions() Deprecated.
int	getXmitTableNumMoves() Deprecated.
int	getXmitTableNumPurges() Deprecated.
int	getXmitTableNumResizes() Deprecated.
long	getXmitTableUndeliveredMessages() Deprecated.
protected void	handleBatchReceived(Address sender, java.util.Map<java.lang.Short,java.util.List<Message>> map) Deprecated.
protected boolean	handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg, Event evt) Deprecated. Check whether the hashmap contains an entry e for sender (create if not).
protected void	handleResendingOfFirstMessage(Address sender, long seqno) Deprecated. We need to resend our first message with our conn_id
protected void	handleXmitRequest(Address sender, SeqnoList missing) Deprecated.
boolean	hasSendConnectionTo(Address dest) Deprecated. Used for testing only
void	init() Deprecated. Called after instance has been created (null constructor) and before protocol is started.
boolean	isConnectionReaperRunning() Deprecated.
boolean	isXmitTaskRunning() Deprecated.
java.lang.String	printAgeOutCache() Deprecated.
java.lang.String	printConnections() Deprecated.
protected java.lang.String	printMessageList(java.util.List<Message> list) Deprecated.
java.lang.String	printReceiveWindowMessages() Deprecated.
java.lang.String	printSendWindowMessages() Deprecated.
void	reapIdleConnections() Deprecated.
void	removeAllConnections() Deprecated. This method is public only so it can be invoked by unit testing, but should not otherwise be used !
protected void	removeAndPassUp(Table<Message> win, Address sender) Deprecated. Try to remove as many messages as possible and pass them up.
void	removeConnection(Address mbr) Deprecated. Removes and resets from connection table (which is already locked).
void	removeReceiveConnection(Address mbr) Deprecated.
void	removeSendConnection(Address mbr) Deprecated.
void	resetStats() Deprecated.
void	retransmit(SeqnoList missing, Address sender) Deprecated.
protected void	sendAck(Address dest, long seqno, short conn_id) Deprecated.
protected void	sendRequestForFirstSeqno(Address dest, long seqno_received) Deprecated.
protected void	sendStableMessage(Address dest, short conn_id, long hd, long hr) Deprecated.
void	sendStableMessages() Deprecated.
void	setMaxMessageBatchSize(int size) Deprecated.
void	setMaxRetransmitTime(long max_retransmit_time) Deprecated.
void	setTimeout(int[] val) Deprecated.
void	setTimer(TimeScheduler timer) Deprecated. Only used for unit tests, don't use !
protected void	stable(Address sender, short conn_id, long hd, long hr) Deprecated. Purge all messages in window for local_addr, which are <= low.
void	start() Deprecated. This method is called on a Channel.connect(String).
protected void	startConnectionReaper() Deprecated.
protected void	startRetransmitTask() Deprecated.
protected void	startStableTask() Deprecated.
void	stop() Deprecated. This method is called on a Channel.disconnect().
protected void	stopConnectionReaper() Deprecated.
protected void	stopRetransmitTask() Deprecated.
protected void	stopStableTask() Deprecated.
void	triggerXmit() Deprecated.
java.lang.Object	up(Event evt) Deprecated. An event was received from the layer below.
void	up(MessageBatch batch) Deprecated. Sends up a multiple messages in a MessageBatch.

Methods inherited from class org.jgroups.stack.Protocol

accept, afterCreationHook, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_FIRST_SEQNO

public static final long DEFAULT_FIRST_SEQNO

Deprecated.

See Also:

Constant Field Values

timeout

@Deprecated
protected int[] timeout

Deprecated.

exponential_backoff

@Deprecated
protected int exponential_backoff

Deprecated.

The first value (in milliseconds) to use in the exponential backoff retransmission mechanism. Only enabled if the value is > 0

max_msg_batch_size

protected int max_msg_batch_size

Deprecated.

max_bytes

protected long max_bytes

Deprecated.

stable_interval

protected long stable_interval

Deprecated.

max_stable_msgs

protected int max_stable_msgs

Deprecated.

xmit_table_num_rows

protected int xmit_table_num_rows

Deprecated.

xmit_table_msgs_per_row

protected int xmit_table_msgs_per_row

Deprecated.

xmit_table_resize_factor

protected double xmit_table_resize_factor

Deprecated.

xmit_table_max_compaction_time

protected long xmit_table_max_compaction_time

Deprecated.

xmit_table_automatic_purging

@Deprecated
protected boolean xmit_table_automatic_purging

Deprecated.

use_range_based_retransmitter

protected boolean use_range_based_retransmitter

Deprecated.

log_not_found_msgs

protected boolean log_not_found_msgs

Deprecated.

conn_expiry_timeout

protected long conn_expiry_timeout

Deprecated.

max_retransmit_time

protected long max_retransmit_time

Deprecated.

xmit_interval

protected long xmit_interval

Deprecated.

num_messages_sent

protected int num_messages_sent

Deprecated.

num_messages_received

protected int num_messages_received

Deprecated.

send_table

protected final java.util.concurrent.ConcurrentMap<Address,UNICAST2.SenderEntry> send_table

Deprecated.

recv_table

protected final java.util.concurrent.ConcurrentMap<Address,UNICAST2.ReceiverEntry> recv_table

Deprecated.

xmit_task

protected java.util.concurrent.Future<?> xmit_task

Deprecated.

RetransmitTask running every xmit_interval ms

xmit_task_map

protected final java.util.Map<Address,java.lang.Long> xmit_task_map

Deprecated.

Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.jboss.org/browse/JGRP-1539)

recv_table_lock

protected final java.util.concurrent.locks.ReentrantLock recv_table_lock

Deprecated.

members

protected volatile java.util.List<Address> members

Deprecated.

local_addr

protected Address local_addr

Deprecated.

timer

protected TimeScheduler timer

Deprecated.

running

protected volatile boolean running

Deprecated.

last_conn_id

protected short last_conn_id

Deprecated.

cache

protected AgeOutCache<Address> cache

Deprecated.

stable_task_future

protected java.util.concurrent.Future<?> stable_task_future

Deprecated.

connection_reaper

protected java.util.concurrent.Future<?> connection_reaper

Deprecated.

dont_loopback_filter

protected static final Filter<Message> dont_loopback_filter

Deprecated.

xmit_reqs_received

protected final java.util.concurrent.atomic.AtomicLong xmit_reqs_received

Deprecated.

xmit_reqs_sent

protected final java.util.concurrent.atomic.AtomicLong xmit_reqs_sent

Deprecated.

xmit_rsps_sent

protected final java.util.concurrent.atomic.AtomicLong xmit_rsps_sent

Deprecated.

Constructor Detail

UNICAST2

public UNICAST2()

Deprecated.

Method Detail

getTimeout

@Deprecated
public int[] getTimeout()

Deprecated.

setTimeout

@Deprecated
public void setTimeout(int[] val)

Deprecated.

setMaxMessageBatchSize

public void setMaxMessageBatchSize(int size)

Deprecated.

getLocalAddress

public java.lang.String getLocalAddress()

Deprecated.

getMembers

public java.lang.String getMembers()

Deprecated.

getNumSendConnections

public int getNumSendConnections()

Deprecated.

getNumReceiveConnections

public int getNumReceiveConnections()

Deprecated.

getNumConnections

public int getNumConnections()

Deprecated.

printConnections

public java.lang.String printConnections()

Deprecated.

connectionEstablished

public boolean connectionEstablished(Address target)

Deprecated.

Is the send connection to target established

isConnectionReaperRunning

public boolean isConnectionReaperRunning()

Deprecated.

getXmitTableUndeliveredMessages

public long getXmitTableUndeliveredMessages()

Deprecated.

getXmitTableMissingMessages

public long getXmitTableMissingMessages()

Deprecated.

getXmitTableNumCompactions

public int getXmitTableNumCompactions()

Deprecated.

getXmitTableNumMoves

public int getXmitTableNumMoves()

Deprecated.

getXmitTableNumResizes

public int getXmitTableNumResizes()

Deprecated.

getXmitTableNumPurges

public int getXmitTableNumPurges()

Deprecated.

printReceiveWindowMessages

public java.lang.String printReceiveWindowMessages()

Deprecated.

printSendWindowMessages

public java.lang.String printSendWindowMessages()

Deprecated.

isXmitTaskRunning

public boolean isXmitTaskRunning()

Deprecated.

getMaxRetransmitTime

public long getMaxRetransmitTime()

Deprecated.

setMaxRetransmitTime

public void setMaxRetransmitTime(long max_retransmit_time)

Deprecated.

getAgeOutCacheSize

public int getAgeOutCacheSize()

Deprecated.

printAgeOutCache

public java.lang.String printAgeOutCache()

Deprecated.

getAgeOutCache

public AgeOutCache<Address> getAgeOutCache()

Deprecated.

hasSendConnectionTo

public boolean hasSendConnectionTo(Address dest)

Deprecated.

Used for testing only

resetStats

public void resetStats()

Deprecated.

Overrides:

resetStats in class Protocol

getTimer

public TimeScheduler getTimer()

Deprecated.

setTimer

public void setTimer(TimeScheduler timer)

Deprecated.

Only used for unit tests, don't use !

Parameters:

timer -

init

public void init()
          throws java.lang.Exception

Deprecated.

Description copied from class: Protocol

Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.

Overrides:

init in class Protocol

Throws:

java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the channel constructor will throw an exception

start

public void start()
           throws java.lang.Exception

Deprecated.

Description copied from class: Protocol

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.

Overrides:

start in class Protocol

Throws:

java.lang.Exception - Thrown if protocol cannot be started successfully. This will cause the ProtocolStack to fail, so Channel.connect(String) will throw an exception

stop

public void stop()

Deprecated.

Description copied from class: Protocol

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

Overrides:

stop in class Protocol

up

public java.lang.Object up(Event evt)

Deprecated.

Description copied from class: Protocol

An event was received from the layer below. Usually the current layer will want to examine the event type and - depending on its type - perform some computation (e.g. removing headers from a MSG event type, or updating the internal membership list when receiving a VIEW_CHANGE event). Finally the event is either a) discarded, or b) an event is sent down the stack using down_prot.down() or c) the event (or another event) is sent up the stack using up_prot.up().

Overrides:

up in class Protocol

up

public void up(MessageBatch batch)

Deprecated.

Description copied from class: Protocol

Sends up a multiple messages in a MessageBatch. The sender of the batch is always the same, and so is the destination (null == multicast messages). Messages in a batch can be OOB messages, regular messages, or mixed messages, although the transport itself will create initial MessageBatches that contain only either OOB or regular messages.

The default processing below sends messages up the stack individually, based on a matching criteria (calling Protocol.accept(org.jgroups.Message)), and - if true - calls Protocol.up(org.jgroups.Event) for that message and removes the message. If the batch is not empty, it is passed up, or else it is dropped.

Subclasses should check if there are any messages destined for them (e.g. using MessageBatch.getMatchingMessages(short,boolean)), then possibly remove and process them and finally pass the batch up to the next protocol. Protocols can also modify messages in place, e.g. ENCRYPT could decrypt all encrypted messages in the batch, not remove them, and pass the batch up when done.

Overrides:

up in class Protocol

Parameters:

batch - The message batch

down

public java.lang.Object down(Event evt)

Deprecated.

Description copied from class: Protocol

An event is to be sent down the stack. The layer may want to examine its type and perform some action on it, depending on the event's type. If the event is a message MSG, then the layer may need to add a header to it (or do nothing at all) before sending it down the stack using down_prot.down(). In case of a GET_ADDRESS event (which tries to retrieve the stack's address from one of the bottom layers), the layer may need to send a new response event back up the stack using up_prot.up().

Overrides:

down in class Protocol

stable

protected void stable(Address sender,
                      short conn_id,
                      long hd,
                      long hr)

Deprecated.

Purge all messages in window for local_addr, which are <= low. Check if the window's highest received message is > high: if true, retransmit all messages from high - win.high to sender

Parameters:

sender -

hd - Highest delivered seqno

hr - Highest received seqno

sendStableMessages

public void sendStableMessages()

Deprecated.

sendStableMessage

protected void sendStableMessage(Address dest,
                                 short conn_id,
                                 long hd,
                                 long hr)

Deprecated.

startStableTask

protected void startStableTask()

Deprecated.

stopStableTask

protected void stopStableTask()

Deprecated.

startConnectionReaper

protected void startConnectionReaper()

Deprecated.

stopConnectionReaper

protected void stopConnectionReaper()

Deprecated.

removeConnection

public void removeConnection(Address mbr)

Deprecated.

Removes and resets from connection table (which is already locked). Returns true if member was found, otherwise false. This method is public only so it can be invoked by unit testing, but should not otherwise be used !

removeSendConnection

public void removeSendConnection(Address mbr)

Deprecated.

removeReceiveConnection

public void removeReceiveConnection(Address mbr)

Deprecated.

removeAllConnections

public void removeAllConnections()

Deprecated.

This method is public only so it can be invoked by unit testing, but should not otherwise be used !

retransmit

public void retransmit(SeqnoList missing,
                       Address sender)

Deprecated.

expired

public void expired(Address key)

Deprecated.

Called by AgeOutCache, to removed expired connections

Specified by:

expired in interface AgeOutCache.Handler<Address>

Parameters:

key -

handleDataReceived

protected boolean handleDataReceived(Address sender,
                                     long seqno,
                                     short conn_id,
                                     boolean first,
                                     Message msg,
                                     Event evt)

Deprecated.

Check whether the hashmap contains an entry e for sender (create if not). If e.received_msgs is null and first is true: create a new AckReceiverWindow(seqno) and add message. Set e.received_msgs to the new window. Else just add the message.

handleBatchReceived

protected void handleBatchReceived(Address sender,
                                   java.util.Map<java.lang.Short,java.util.List<Message>> map)

Deprecated.

printMessageList

protected java.lang.String printMessageList(java.util.List<Message> list)

Deprecated.

removeAndPassUp

protected void removeAndPassUp(Table<Message> win,
                               Address sender)

Deprecated.

Try to remove as many messages as possible and pass them up. Prevents concurrent passing up of messages by different threads (http://jira.jboss.com/jira/browse/JGRP-198); this is all the more important once we have a concurrent stack (http://jira.jboss.com/jira/browse/JGRP-181), where lots of threads can come up to this point concurrently, but only 1 is allowed to pass at a time.

We *can* deliver messages from *different* senders concurrently, e.g. reception of P1, Q1, P2, Q2 can result in delivery of P1, Q1, Q2, P2: FIFO (implemented by UNICAST) says messages need to be delivered only in the order in which they were sent by their senders

getReceiverEntry

protected UNICAST2.ReceiverEntry getReceiverEntry(Address sender,
                                                  long seqno,
                                                  boolean first,
                                                  short conn_id)

Deprecated.

getOrCreateReceiverEntry

protected UNICAST2.ReceiverEntry getOrCreateReceiverEntry(Address sender,
                                                          long seqno,
                                                          short conn_id)

Deprecated.

handleXmitRequest

protected void handleXmitRequest(Address sender,
                                 SeqnoList missing)

Deprecated.

handleResendingOfFirstMessage

protected void handleResendingOfFirstMessage(Address sender,
                                             long seqno)

Deprecated.

We need to resend our first message with our conn_id

Parameters:

sender -

seqno - Resend the non null messages in the range [lowest .. seqno]

startRetransmitTask

protected void startRetransmitTask()

Deprecated.

stopRetransmitTask

protected void stopRetransmitTask()

Deprecated.

getNewConnectionId

protected short getNewConnectionId()

Deprecated.

sendRequestForFirstSeqno

protected void sendRequestForFirstSeqno(Address dest,
                                        long seqno_received)

Deprecated.

sendAck

protected void sendAck(Address dest,
                       long seqno,
                       short conn_id)

Deprecated.

reapIdleConnections

public void reapIdleConnections()

Deprecated.

triggerXmit

public void triggerXmit()

Deprecated.