org.apache.ignite.internal.util.nio

Class GridNioRecoveryDescriptor

java.lang.Object

org.apache.ignite.internal.util.nio.GridNioRecoveryDescriptor

Deprecated.

@Deprecated
public class GridNioRecoveryDescriptor
extends Object

Recovery information for single node.

Constructor Summary

Constructors

Constructor and Description
GridNioRecoveryDescriptor(boolean pairedConnections, int queueLimit, ClusterNode node, IgniteLogger log) Deprecated.

Method Summary

Methods

Modifier and Type	Method and Description
long	acked() Deprecated.
void	ackReceived(long rcvCnt) Deprecated.
boolean	add(SessionWriteRequest req) Deprecated.
boolean	connected() Deprecated.
Long	handshakeIndex() Deprecated.
long	incrementConnectCount() Deprecated.
long	lastAcknowledged() Deprecated.
void	lastAcknowledged(long lastAck) Deprecated.
Deque<SessionWriteRequest>	messagesRequests() Deprecated.
ClusterNode	node() Deprecated.
boolean	nodeAlive(ClusterNode node) Deprecated.
void	onConnected() Deprecated.
void	onHandshake(long rcvCnt) Deprecated.
boolean	onNodeLeft() Deprecated. Node left callback.
long	onReceived() Deprecated. Increments received messages counter.
boolean	pairedConnections() Deprecated.
int	queueLimit() Deprecated.
long	received() Deprecated.
void	release() Deprecated.
boolean	reserve() Deprecated.
int	reserveCount() Deprecated.
boolean	reserved() Deprecated.
long	sent() Deprecated.
String	toString() Deprecated.
boolean	tryReserve(long id, IgniteInClosure<Boolean> c) Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridNioRecoveryDescriptor

public GridNioRecoveryDescriptor(boolean pairedConnections,
                         int queueLimit,
                         ClusterNode node,
                         IgniteLogger log)

Deprecated.

Parameters:

pairedConnections - True if in/out connections pair is used for communication with node.

queueLimit - Maximum size of unacknowledged messages queue.

node - Node.

log - Logger.

Method Detail

pairedConnections

public boolean pairedConnections()

Deprecated.

Returns:

True if in/out connections pair is used for communication with node.

incrementConnectCount

public long incrementConnectCount()

Deprecated.

Returns:

Connect count.

node

public ClusterNode node()

Deprecated.

Returns:

Node.

onReceived

public long onReceived()

Deprecated.

Increments received messages counter.

Returns:

Number of received messages.

received

public long received()

Deprecated.

Returns:

Number of received messages.

sent

public long sent()

Deprecated.

Returns:

Number of sent messages.

lastAcknowledged

public void lastAcknowledged(long lastAck)

Deprecated.

Parameters:

lastAck - Last acknowledged message.

lastAcknowledged

public long lastAcknowledged()

Deprecated.

Returns:

Last acknowledged message.

queueLimit

public int queueLimit()

Deprecated.

Returns:

Maximum size of unacknowledged messages queue.

add

public boolean add(SessionWriteRequest req)

Deprecated.

Parameters:

req - Write request.

Returns:

False if queue limit is exceeded.

ackReceived

public void ackReceived(long rcvCnt)

Deprecated.

Parameters:

rcvCnt - Number of messages received by remote node.

acked

public long acked()

Deprecated.

Returns:

Last acked message by remote node.

onNodeLeft

public boolean onNodeLeft()

Deprecated.

Node left callback.

Returns:

False if descriptor is reserved.

messagesRequests

public Deque<SessionWriteRequest> messagesRequests()

Deprecated.

Returns:

Requests for unacknowledged messages.

nodeAlive

public boolean nodeAlive(@Nullable
                ClusterNode node)

Deprecated.

Parameters:

node - Node.

Returns:

True if node is not null and has the same order as initial remtoe node.

reserve

public boolean reserve()
                throws InterruptedException

Deprecated.

Returns:

True if reserved.

Throws:

InterruptedException - If interrupted.

onHandshake

public void onHandshake(long rcvCnt)

Deprecated.

Parameters:

rcvCnt - Number of messages received by remote node.

onConnected

public void onConnected()

Deprecated.

connected

public boolean connected()

Deprecated.

Returns:

Connected flag.

reserved

public boolean reserved()

Deprecated.

Returns:

Reserved flag.

handshakeIndex

public Long handshakeIndex()

Deprecated.

Returns:

Current handshake index.

release

public void release()

Deprecated.

tryReserve

public boolean tryReserve(long id,
                 IgniteInClosure<Boolean> c)

Deprecated.

Parameters:

id - Handshake ID.

c - Closure to run on reserve.

Returns:

True if reserved.

reserveCount

public int reserveCount()

Deprecated.

Returns:

Number of descriptor reservations.

toString

public String toString()

Deprecated.

Overrides:

toString in class Object