org.jgroups.protocols

Class UNICAST

java.lang.Object

org.jgroups.stack.Protocol

org.jgroups.protocols.UNICAST

All Implemented Interfaces:

AgeOutCache.Handler<Address>

Deprecated.

Will be removed in 4.0

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

Reliable unicast layer. Uses acknowledgement scheme similar to TCP to provide lossless transmission of unicast messages (for reliable multicast see NAKACK layer). When a message is sent to a peer for the first time, we add the pair to the hashtable (peer address is the key). All messages sent to that peer will be added to hashtable.peer_addr.sent_msgs. When we receive a message from a peer for the first time, another entry will be created and added to the hashtable (unless already existing). Msgs will then be added to hashtable.peer_addr.received_msgs.

This layer is used to reliably transmit point-to-point messages, that is, either messages sent to a single receiver (vs. messages multicast to a group) or for example replies to a multicast message. The sender uses an AckSenderWindow which retransmits messages for which it hasn't received an ACK, the receiver uses AckReceiverWindow which keeps track of the lowest seqno received so far, and keeps messages in order.

Messages in both AckSenderWindows and AckReceiverWindows will be removed. A message will be removed from AckSenderWindow when an ACK has been received for it and messages will be removed from AckReceiverWindow whenever a message is received: the new message is added and then we try to remove as many messages as possible (until we stop at a gap, or there are no more messages).

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	UNICAST.ConnectionReaper Deprecated.
protected static class	UNICAST.ReceiverEntry Deprecated.
protected class	UNICAST.RetransmitTask Deprecated. Retransmitter task which periodically (every xmit_interval ms) looks at all the retransmit (send) tables and re-sends messages for which we haven't received an ack yet
protected class	UNICAST.SenderEntry Deprecated.
static class	UNICAST.UnicastHeader 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 short	last_conn_id Deprecated.
protected Address	local_addr Deprecated.
protected int	max_msg_batch_size Deprecated.
protected long	max_retransmit_time Deprecated.
protected java.util.List<Address>	members Deprecated.
protected long	num_acks_received Deprecated.
protected long	num_acks_sent Deprecated.
protected long	num_msgs_received Deprecated.
protected long	num_msgs_sent Deprecated.
protected long	num_xmits Deprecated.
protected java.util.concurrent.ConcurrentMap<Address,UNICAST.ReceiverEntry>	recv_table Deprecated.
protected java.util.concurrent.locks.ReentrantLock	recv_table_lock Deprecated.
protected boolean	running Deprecated.
protected int	segment_capacity Deprecated.
protected java.util.concurrent.ConcurrentMap<Address,UNICAST.SenderEntry>	send_table Deprecated.
protected int[]	timeout Deprecated.
protected TimeScheduler	timer Deprecated.
protected long	xmit_interval 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

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
UNICAST() Deprecated.

Method Summary

Modifier and Type	Method and Description
java.lang.Object	down(Event evt) Deprecated. An event is to be sent down the stack.
java.util.Map<java.lang.String,java.lang.Object>	dumpStats() Deprecated.
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.
long	getNumAcksReceived() Deprecated.
long	getNumAcksSent() Deprecated.
int	getNumberOfMessagesInReceiveWindows() Deprecated.
int	getNumConnections() Deprecated.
long	getNumMessagesReceived() Deprecated.
long	getNumMessagesSent() Deprecated.
int	getNumReceiveConnections() Deprecated.
int	getNumSendConnections() Deprecated.
int	getNumUnackedMessages() Deprecated. The number of messages in all Entry.sent_msgs tables (haven't received an ACK yet)
long	getNumXmits() Deprecated.
protected UNICAST.ReceiverEntry	getOrCreateReceiverEntry(Address sender, long seqno, short conn_id) Deprecated.
protected UNICAST.ReceiverEntry	getReceiverEntry(Address sender, long seqno, boolean first, short conn_id) Deprecated.
int[]	getTimeout() Deprecated.
long	getXmitTableMissingMessages() Deprecated.
int	getXmitTableNumCompactions() Deprecated.
int	getXmitTableNumMoves() Deprecated.
int	getXmitTableNumPurges() Deprecated.
int	getXmitTableNumResizes() Deprecated.
long	getXmitTableUndeliveredMessages() Deprecated.
protected void	handleAckReceived(Address sender, long seqno, short conn_id) Deprecated.
protected void	handleBatchReceived(Address sender, java.util.Map<java.lang.Short,java.util.List<Message>> map) Deprecated.
protected void	handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg, Event evt) Deprecated. Check whether the hashtable 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	handleUpEvent(Address sender, UNICAST.UnicastHeader hdr) Deprecated.
boolean	hasSendConnectionTo(Address dest) Deprecated. Used for testing only
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 int	removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing, Table<Message> win, Address sender) Deprecated. Try to remove as many messages as possible from the table as 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(Message msg) Deprecated. Called by AckSenderWindow to resend messages for which no ACK has been received yet
protected void	sendAck(Address dst, long seqno, short conn_id) Deprecated.
protected void	sendRequestForFirstSeqno(Address dest, long seqno_received) Deprecated.
void	setMaxMessageBatchSize(int size) Deprecated.
void	setMaxRetransmitTime(long max_retransmit_time) Deprecated.
void	setTimeout(int[] val) Deprecated.
void	start() Deprecated. This method is called on a Channel.connect(String).
protected void	startConnectionReaper() Deprecated.
protected void	startRetransmitTask() Deprecated.
void	stop() Deprecated. This method is called on a Channel.disconnect().
protected void	stopConnectionReaper() Deprecated.
protected void	stopRetransmitTask() 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, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, init, 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.

max_msg_batch_size

protected int max_msg_batch_size

Deprecated.

conn_expiry_timeout

protected long conn_expiry_timeout

Deprecated.

segment_capacity

@Deprecated
protected int segment_capacity

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.

max_retransmit_time

protected long max_retransmit_time

Deprecated.

xmit_interval

protected long xmit_interval

Deprecated.

num_msgs_sent

protected long num_msgs_sent

Deprecated.

num_msgs_received

protected long num_msgs_received

Deprecated.

num_acks_sent

protected long num_acks_sent

Deprecated.

num_acks_received

protected long num_acks_received

Deprecated.

num_xmits

protected long num_xmits

Deprecated.

send_table

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

Deprecated.

recv_table

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

Deprecated.

recv_table_lock

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

Deprecated.

xmit_task

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

Deprecated.

RetransmitTask running every xmit_interval ms

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.

connection_reaper

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

Deprecated.

Constructor Detail

UNICAST

public UNICAST()

Deprecated.

Method Detail

getTimeout

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.

isConnectionReaperRunning

public boolean isConnectionReaperRunning()

Deprecated.

getNumSendConnections

public int getNumSendConnections()

Deprecated.

getNumReceiveConnections

public int getNumReceiveConnections()

Deprecated.

getNumConnections

public int getNumConnections()

Deprecated.

printConnections

public java.lang.String printConnections()

Deprecated.

getNumMessagesSent

public long getNumMessagesSent()

Deprecated.

getNumMessagesReceived

public long getNumMessagesReceived()

Deprecated.

getNumAcksSent

public long getNumAcksSent()

Deprecated.

getNumAcksReceived

public long getNumAcksReceived()

Deprecated.

getNumXmits

public long getNumXmits()

Deprecated.

getMaxRetransmitTime

public long getMaxRetransmitTime()

Deprecated.

setMaxRetransmitTime

public void setMaxRetransmitTime(long max_retransmit_time)

Deprecated.

isXmitTaskRunning

public boolean isXmitTaskRunning()

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

getNumUnackedMessages

public int getNumUnackedMessages()

Deprecated.

The number of messages in all Entry.sent_msgs tables (haven't received an ACK yet)

getNumberOfMessagesInReceiveWindows

public int getNumberOfMessagesInReceiveWindows()

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.

resetStats

public void resetStats()

Deprecated.

Overrides:

resetStats in class Protocol

dumpStats

public java.util.Map<java.lang.String,java.lang.Object> dumpStats()

Deprecated.

Overrides:

dumpStats in class Protocol

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

handleUpEvent

protected void handleUpEvent(Address sender,
                             UNICAST.UnicastHeader hdr)

Deprecated.

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

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(Message msg)

Deprecated.

Called by AckSenderWindow to resend messages for which no ACK has been received yet

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 void handleDataReceived(Address sender,
                                  long seqno,
                                  short conn_id,
                                  boolean first,
                                  Message msg,
                                  Event evt)

Deprecated.

Check whether the hashtable 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.

removeAndDeliver

protected int removeAndDeliver(java.util.concurrent.atomic.AtomicBoolean processing,
                               Table<Message> win,
                               Address sender)

Deprecated.

Try to remove as many messages as possible from the table as pass them up. Prevents concurrent passing up of messages by different threads (http://jira.jboss.com/jira/browse/JGRP-198); 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 in the order in which they were sent

getReceiverEntry

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

Deprecated.

getOrCreateReceiverEntry

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

Deprecated.

handleAckReceived

protected void handleAckReceived(Address sender,
                                 long seqno,
                                 short conn_id)

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.

sendAck

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

Deprecated.

startConnectionReaper

protected void startConnectionReaper()

Deprecated.

stopConnectionReaper

protected void stopConnectionReaper()

Deprecated.

getNewConnectionId

protected short getNewConnectionId()

Deprecated.

sendRequestForFirstSeqno

protected void sendRequestForFirstSeqno(Address dest,
                                        long seqno_received)

Deprecated.

reapIdleConnections

public void reapIdleConnections()

Deprecated.

printMessageList

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

Deprecated.