diff options
author | Valerij Fredriksen <valerijf@verizonmedia.com> | 2020-06-26 09:00:15 +0200 |
---|---|---|
committer | Valerij Fredriksen <valerijf@verizonmedia.com> | 2020-06-26 09:00:15 +0200 |
commit | 22141cff2b94755a2f973ef221c3ccb3e34c6b74 (patch) | |
tree | de88f5c54a5ba40d4c21d5c5c20432070e10c33f /node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/task/util/file/FileFinder.java | |
parent | dd5396dbf99b414b480eb32f7f26014f7f064bf4 (diff) |
Use mutable integer instead
Diffstat (limited to 'node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/task/util/file/FileFinder.java')
-rw-r--r-- | node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/task/util/file/FileFinder.java | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/task/util/file/FileFinder.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/task/util/file/FileFinder.java index 65606f85d84..52900e35fe2 100644 --- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/task/util/file/FileFinder.java +++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/task/util/file/FileFinder.java @@ -1,6 +1,7 @@ // Copyright 2018 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.vespa.hosted.node.admin.task.util.file; +import com.yahoo.lang.MutableInteger; import com.yahoo.vespa.hosted.node.admin.component.TaskContext; import java.io.IOException; @@ -111,18 +112,18 @@ public class FileFinder { */ public boolean deleteRecursively(TaskContext context) { final int maxNumberOfDeletedPathsToLog = 20; - int[] numDeleted = { 0 }; + MutableInteger numDeleted = new MutableInteger(0); List<Path> deletedPaths = new ArrayList<>(); try { forEach(attributes -> { if (attributes.unixPath().deleteRecursively()) { - if (numDeleted[0]++ <= maxNumberOfDeletedPathsToLog) deletedPaths.add(attributes.path()); + if (numDeleted.next() <= maxNumberOfDeletedPathsToLog) deletedPaths.add(attributes.path()); } }); } finally { - if (numDeleted[0] > maxNumberOfDeletedPathsToLog) { - context.log(logger, "Deleted " + numDeleted[0] + " paths under " + basePath); + if (numDeleted.get() > maxNumberOfDeletedPathsToLog) { + context.log(logger, "Deleted " + numDeleted.get() + " paths under " + basePath); } else if (deletedPaths.size() > 0) { List<Path> paths = deletedPaths.stream() .map(basePath::relativize) |