diff --git a/src/main/java/io/hops/metadata/hdfs/dal/OngoingSubTreeOpsDataAccess.java b/src/main/java/io/hops/metadata/hdfs/dal/OngoingSubTreeOpsDataAccess.java index 448a8d1f..5a438c4d 100644 --- a/src/main/java/io/hops/metadata/hdfs/dal/OngoingSubTreeOpsDataAccess.java +++ b/src/main/java/io/hops/metadata/hdfs/dal/OngoingSubTreeOpsDataAccess.java @@ -30,6 +30,12 @@ public interface OngoingSubTreeOpsDataAccess extends EntityDataAccess { Collection allOpsToRecoverAsync() throws StorageException; + Collection allDeadOperations(long[] aliveNNIDs, long time) throws StorageException; + + Collection allSlowActiveOperations(long[] aliveNNIDs, long time) throws StorageException; + + long getLockTime(long inodeID) throws StorageException; + //only for testing Collection allOps() throws StorageException;