Repository: incubator-nifi Updated Branches: refs/heads/NIFI-731 4b5ba3c4e -> 94b4eddb0
NIFI-731: Deleted unused method Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/1677db62 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/1677db62 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/1677db62 Branch: refs/heads/NIFI-731 Commit: 1677db6261c2c77df15c2e46a54d7428fc91fc57 Parents: 4b5ba3c Author: Mark Payne <marka...@hotmail.com> Authored: Tue Jun 30 11:38:41 2015 -0400 Committer: Mark Payne <marka...@hotmail.com> Committed: Tue Jun 30 11:38:41 2015 -0400 ---------------------------------------------------------------------- .../repository/FileSystemRepository.java | 41 -------------------- 1 file changed, 41 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/1677db62/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/FileSystemRepository.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/FileSystemRepository.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/FileSystemRepository.java index 864058c..c3f03db 100644 --- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/FileSystemRepository.java +++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/FileSystemRepository.java @@ -805,47 +805,6 @@ public class FileSystemRepository implements ContentRepository { contentClaimManager.purge(); } - // private class BinDestructableClaims implements Runnable { - // - // @Override - // public void run() { - // try { - // // Get all of the Destructable Claims and bin them based on their Container. We do this - // // because the Container generally maps to a physical partition on the disk, so we want a few - // // different threads hitting the different partitions but don't want multiple threads hitting - // // the same partition. - // final List<ContentClaim> toDestroy = new ArrayList<>(); - // while (true) { - // toDestroy.clear(); - // contentClaimManager.drainDestructableClaims(toDestroy, 10000); - // if (toDestroy.isEmpty()) { - // return; - // } - // - // for (final ContentClaim claim : toDestroy) { - // final String container = claim.getContainer(); - // final BlockingQueue<ContentClaim> claimQueue = reclaimable.get(container); - // - // try { - // while (true) { - // if (claimQueue.offer(claim, 10, TimeUnit.MINUTES)) { - // break; - // } else { - // LOG.warn("Failed to clean up {} because old claims aren't being cleaned up fast enough. " - // + "This Content Claim will remain in the Content Repository until NiFi is restarted, at which point it will be cleaned up", claim); - // } - // } - // } catch (final InterruptedException ie) { - // LOG.warn("Failed to clean up {} because thread was interrupted", claim); - // } - // } - // } - // } catch (final Throwable t) { - // LOG.error("Failed to cleanup content claims due to {}", t); - // } - // } - // } - public static Path getArchivePath(final Path contentClaimPath) { final Path sectionPath = contentClaimPath.getParent(); final String claimId = contentClaimPath.toFile().getName();
