Package lumis.portal.cluster.multiserver

Class 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 18:06:18 -0300 (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 Description
      DurableNAKACK()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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

    • 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