@Override
  public List<ReplicaId> getInProgressReplicaIdsForDisk(DiskId diskId) {
    lock.lock();
    List<ReplicaId> inProgressReplicasForDisk =
        inProgressReplicas.stream().filter(replicaId -> replicaId.getDiskId() == diskId).collect(Collectors.toList());
    lock.unlock();
    return inProgressReplicasForDisk;
  }
Returns the in-progress replicas for the disk
@param diskId the {@link DiskId} for which the list of partitions are in progress.
@return {@link List<ReplicaId>} replica ids for disk
ambry-prioritization/src/main/java/com/github/ambry/replica/prioritization/FileCopyDisruptionBasedPrioritizationManager.java