[TEST] Expand assert to mention which files are not deleted
Relates to
@@ -457,7 +457,18 @@ public final class NodeEnvironment implements Closeable {
IOUtils.rm(customLocation);
}
logger.trace("deleted shard {} directory, paths: [{}]", shardId, paths);
- assert FileSystemUtils.exists(paths) == false;
+ assert assertPathsDoNotExist(paths);
+ }
+
+ private static boolean assertPathsDoNotExist(final Path[] paths) {
+ Set<Path> existingPaths = new HashSet<>();
+ for (Path path : paths) {
+ if (FileSystemUtils.exists(paths)) {
+ existingPaths.add(path);
+ }
+ }
+ assert existingPaths.size() == 0 : "Paths exist that should have been deleted: " + existingPaths;
+ return existingPaths.size() == 0;
}
private boolean isShardLocked(ShardId id) {
