lumis.portal.cluster.multiserver

Class DurableNAKACK

java.lang.Object

org.jgroups.stack.Protocol

org.jgroups.protocols.pbcast.NAKACK2

lumis.portal.cluster.multiserver.DurableNAKACK

All Implemented Interfaces:

org.jgroups.stack.DiagnosticsHandler.ProbeHandler

public class DurableNAKACK
extends org.jgroups.protocols.pbcast.NAKACK2

An extension for the JGroups pbcast.NAKACK implementation that adds support for IClusterTransmission.Flag.DURABLE transmissions.

Since:

4.1.0

Version:

$Revision: 23264 $ $Date: 2019-10-09 21:06:18 +0000 (Wed, 09 Oct 2019) $

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.protocols.pbcast.NAKACK2

org.jgroups.protocols.pbcast.NAKACK2.LastSeqnoResender, org.jgroups.protocols.pbcast.NAKACK2.RetransmitTask

Field Summary

Fields inherited from class org.jgroups.protocols.pbcast.NAKACK2

BATCH_ACCUMULATOR, become_server_queue, become_server_queue_size, digest_history, discard_delivered_msgs, dont_loopback_filter, DUMMY_OOB_MSG, is_server, is_trace, last_seqno_resender, leaving, local_addr, log_discard_msgs, log_not_found_msgs, max_rebroadcast_timeout, max_xmit_req_size, members, no_dummy_and_no_oob_delivered_msgs_and_no_dont_loopback_msgs, num_messages_received, num_messages_sent, NUM_REBROADCAST_MSGS, rebroadcast_digest, rebroadcast_digest_lock, rebroadcast_done, rebroadcast_lock, rebroadcasting, resend_last_seqno, resend_last_seqno_max_times, running, sends_can_block, stability_msgs, suppress_log_non_member, suppress_time_non_member_warnings, timer, use_mcast_xmit, use_mcast_xmit_req, view, xmit_from_random_member, xmit_interval, xmit_reqs_received, xmit_reqs_sent, xmit_rsps_received, xmit_rsps_sent, xmit_table, xmit_table_max_compaction_time, xmit_table_msgs_per_row, xmit_table_num_rows, xmit_table_resize_factor, xmit_task, xmit_task_map

Fields inherited from class org.jgroups.stack.Protocol

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

Constructor Summary

Constructors

Constructor and Description
DurableNAKACK()

Method Summary

Modifier and Type	Method and Description
Object	down(org.jgroups.Message message)
<T extends org.jgroups.stack.Protocol> T	getDownProtocol()
<T extends org.jgroups.stack.Protocol> T	setDownProtocol(org.jgroups.stack.Protocol prot)

Methods inherited from class org.jgroups.protocols.pbcast.NAKACK2

adjustReceivers, cancelRebroadcasting, checkForRebroadcasts, clearNonMemberCache, compact, createTable, deliver, deliverBatch, down, dumpXmitTablesNumCurrentRows, flushBecomeServerQueue, getBecomeServerQueueSizeActual, getCurrentSeqno, getDigest, getDigest, getLogDiscardMessages, getNonMemberMessages, getSizeOfAllMessages, getSizeOfAllMessagesInclHeaders, getWindow, getXmitRequestsReceived, getXmitRequestsSent, getXmitResponsesReceived, getXmitResponsesSent, getXmitTableCapacity, getXmitTableMissingMessages, getXmitTableNumCompactions, getXmitTableNumCurrentRows, getXmitTableNumMoves, getXmitTableNumPurges, getXmitTableNumResizes, getXmitTableUndeliveredMsgs, handleHighestSeqno, handleMessage, handleMessages, handleProbe, handleXmitReq, handleXmitRsp, init, isDiscardDeliveredMsgs, isGreaterThanOrEqual, isUseMcastXmit, isXmitFromRandomMember, isXmitTaskRunning, mergeDigest, msgFromXmitRsp, overwriteDigest, printDigestHistory, printMessages, printStabilityMessages, providedUpServices, queueMessage, rebroadcastMessages, removeAndDeliver, resendTaskRunning, reset, resetStats, retransmit, retransmit, retransmit, send, sendXmitRsp, setDigest, setDigest, setDiscardDeliveredMsgs, setLevel, setLogDiscardMessages, setLogNotFoundMessages, setResendLastSeqno, setResendLastSeqnoMaxTimes, setTimer, setUseMcastXmit, setUseMcastXmitReq, setXmitFromRandomMember, sizeOfAllMessages, stable, start, startRetransmitTask, stop, stopRetransmitTask, supportedKeys, triggerXmit, unknownMember, up, up, up

Methods inherited from class org.jgroups.stack.Protocol

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

Methods inherited from class java.lang.Object

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

Constructor Detail

DurableNAKACK

public DurableNAKACK()

Method Detail

down

public Object down(org.jgroups.Message message)

Overrides:

down in class org.jgroups.protocols.pbcast.NAKACK2

getDownProtocol

public <T extends org.jgroups.stack.Protocol> T getDownProtocol()

Overrides:

getDownProtocol in class org.jgroups.stack.Protocol

setDownProtocol

public <T extends org.jgroups.stack.Protocol> T setDownProtocol(org.jgroups.stack.Protocol prot)

Overrides:

setDownProtocol in class org.jgroups.stack.Protocol