Package com.linkedin.davinci.blobtransfer

Class BlobTransferStatusTrackingManager

java.lang.Object
com.linkedin.davinci.blobtransfer.BlobTransferStatusTrackingManager
public class BlobTransferStatusTrackingManager extends Object
BlobTransferStatusTrackingManager is responsible for tracking and managing the status of blob transfers. It provides a centralized way to track ongoing transfers, request cancellations, and coordinate the shutdown of active channels and peer chains. Cancellation workflow: - Set status to TRANSFER_CANCEL_REQUESTED to prevent new peer attempts in the chain - Close any active network channel to abort ongoing data transfer - The entire chain of peer attempts will terminate early due to the cancellation status

  • Constructor Details

    • BlobTransferStatusTrackingManager

      public BlobTransferStatusTrackingManager(NettyFileTransferClient nettyClient)

  • Method Details

    • initialTransfer

      public void initialTransfer(String replicaId)

    • startedTransfer

      public void startedTransfer(String replicaId)

    • getTransferStatus

      public BlobTransferUtils.BlobTransferStatus getTransferStatus(String replicaId)

    • clearTransferStatusEnum

      public void clearTransferStatusEnum(String replicaId)

    • isBlobTransferInProgress

      public boolean isBlobTransferInProgress(String replicaId)

    • isBlobTransferCancelRequested

      public boolean isBlobTransferCancelRequested(String replicaId)

    • isBlobTransferCancelRequestSentBefore

      public boolean isBlobTransferCancelRequestSentBefore(String replicaId)

    • markTransferCancelled

      public void markTransferCancelled(String replicaId)

    • markTransferCompleted

      public void markTransferCompleted(String replicaId)

    • isTransferInFinalState

      public boolean isTransferInFinalState(String replicaId)

    • cancelTransfer

      public void cancelTransfer(String replicaId)