public boolean isConsensusPipesTransmissionCompleted(List<String> consensusPipeNames) {
    return consensusPipeNames.stream()
        .noneMatch(
            pipeName ->
                replicateProgressManager.getSyncLagForSpecificConsensusPipe(
                        thisNode.getGroupId(), new ConsensusPipeName(pipeName))
                    > 0);
  }
Wait for the user written data up to firstCheck to be replicated
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java