Class OutboundTransferTask

  • All Implemented Interfaces:

    public class OutboundTransferTask
    extends Object
    implements Runnable
    Outbound state transfer task. Pushes data segments to another cluster member on request. Instances of OutboundTransferTask are created and managed by StateTransferManagerImpl. There should be at most one such task per destination at any time.
    • Method Detail

      • getDestination

        public Address getDestination()
      • getSegments

        public IntSet getSegments()
      • getTopologyId

        public int getTopologyId()
      • run

        public void run()
        Specified by:
        run in interface Runnable
      • cancelSegments

        public void cancelSegments​(IntSet cancelledSegments)
        Cancel some of the segments. If all segments get cancelled then the whole task will be cancelled.
        cancelledSegments - segments to cancel.
      • cancel

        public void cancel()
        Cancel the whole task.
      • isCancelled

        public boolean isCancelled()
      • defaultMapEntryFromDataContainer

        public static InternalCacheEntry defaultMapEntryFromDataContainer​(InternalCacheEntry ice,
                                                                          org.infinispan.container.impl.InternalEntryFactory entryFactory)
      • defaultMapEntryFromStore

        public static InternalCacheEntry defaultMapEntryFromStore​(MarshalledEntry me,
                                                                  org.infinispan.container.impl.InternalEntryFactory entryFactory)