@Test public void testBoundedAdd() throws IOException { ConcurrentBoundedWorkUnitList list = new ConcurrentBoundedWorkUnitList(10, new AllEqualComparator<FileSet<CopyEntity>>(), 1); Assert.assertTrue(addFiles(list, "fs", 6)); Assert.assertFalse(list.hasRejectedFileSet()); Assert.assertFalse(addFiles(list, "fs", 5)); Assert.assertTrue(list.hasRejectedFileSet()); Assert.assertTrue(addFiles(list, "fs", 4)); Assert.assertFalse(addFiles(list, "fs", 1)); }
public boolean hasRejectedFileSet() { return this.rejectedFileSet; }
ConcurrentBoundedWorkUnitList { public boolean hasRejectedFileSet() { return this.rejectedFileSet; } }
ConcurrentBoundedWorkUnitList { public boolean hasRejectedFileSet() { return this.rejectedFileSet; } @Builder  ConcurrentBoundedWorkUnitList(int maxSize, final Comparator<FileSet<CopyEntity>> comparator,
      double strictLimitMultiplier); }
ConcurrentBoundedWorkUnitList { public boolean hasRejectedFileSet() { return this.rejectedFileSet; } @Builder  ConcurrentBoundedWorkUnitList(int maxSize, final Comparator<FileSet<CopyEntity>> comparator,
      double strictLimitMultiplier); boolean addFileSet(FileSet<CopyEntity> fileSet, List<WorkUnit> workUnits); boolean hasRejectedFileSet(); synchronized boolean isFull(); List<WorkUnit> getWorkUnits(); Map<FileSet<CopyEntity>, List<WorkUnit>> getRawWorkUnitMap(); }
ConcurrentBoundedWorkUnitList { public boolean hasRejectedFileSet() { return this.rejectedFileSet; } @Builder  ConcurrentBoundedWorkUnitList(int maxSize, final Comparator<FileSet<CopyEntity>> comparator,
      double strictLimitMultiplier); boolean addFileSet(FileSet<CopyEntity> fileSet, List<WorkUnit> workUnits); boolean hasRejectedFileSet(); synchronized boolean isFull(); List<WorkUnit> getWorkUnits(); Map<FileSet<CopyEntity>, List<WorkUnit>> getRawWorkUnitMap();  }