test_class.declarator: LOG = LoggerFactory.getLogger(UploadStagingCacheTest.class)
test_class.modifier: private static final
test_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(UploadStagingCacheTest.class);
test_class.type: Logger
test_class.var_name: LOG
test_class.declarator: ID_PREFIX = "12345"
test_class.modifier: private static final
test_class.original_string: private static final String ID_PREFIX = "12345";
test_class.type: String
test_class.var_name: ID_PREFIX
test_class.declarator: folder = new TemporaryFolder(new File("target"))
test_class.modifier: @Rule
      public
test_class.original_string: @Rule
      public TemporaryFolder folder = new TemporaryFolder(new File("target"));
test_class.type: TemporaryFolder
test_class.var_name: folder
test_class.declarator: closer = Closer.create()
test_class.modifier: private final
test_class.original_string: private final Closer closer = Closer.create();
test_class.type: Closer
test_class.var_name: closer
test_class.declarator: uploader
test_class.modifier: private
test_class.original_string: private TestStagingUploader uploader;
test_class.type: TestStagingUploader
test_class.var_name: uploader
test_class.declarator: root
test_class.modifier: private
test_class.original_string: private File root;
test_class.type: File
test_class.var_name: root
test_class.declarator: taskLatch
test_class.modifier: private
test_class.original_string: private CountDownLatch taskLatch;
test_class.type: CountDownLatch
test_class.var_name: taskLatch
test_class.declarator: callbackLatch
test_class.modifier: private
test_class.original_string: private CountDownLatch callbackLatch;
test_class.type: CountDownLatch
test_class.var_name: callbackLatch
test_class.declarator: afterExecuteLatch
test_class.modifier: private
test_class.original_string: private CountDownLatch afterExecuteLatch;
test_class.type: CountDownLatch
test_class.var_name: afterExecuteLatch
test_class.declarator: executor
test_class.modifier: private
test_class.original_string: private TestExecutor executor;
test_class.type: TestExecutor
test_class.var_name: executor
test_class.declarator: stagingCache
test_class.modifier: private
test_class.original_string: private UploadStagingCache stagingCache;
test_class.type: UploadStagingCache
test_class.var_name: stagingCache
test_class.declarator: statsProvider
test_class.modifier: private
test_class.original_string: private StatisticsProvider statsProvider;
test_class.type: StatisticsProvider
test_class.var_name: statsProvider
test_class.declarator: removeExecutor
test_class.modifier: private
test_class.original_string: private ScheduledExecutorService removeExecutor;
test_class.type: ScheduledExecutorService
test_class.var_name: removeExecutor
test_class.file: oak-blob-plugins/src/test/java/org/apache/jackrabbit/oak/plugins/blob/UploadStagingCacheTest.java
test_class.identifier: UploadStagingCacheTest
test_class.superclass: extends AbstractDataStoreCacheTest
test_case.body: @Test
      public void testGetAllIdentifiers() throws Exception {
          // add load
          List<ListenableFuture<Integer>> futures = put(folder);
  
          // Check getAllIdentifiers
          Iterator<String> idsIter = stagingCache.getAllIdentifiers();
          assertEquals(ID_PREFIX + 0, Iterators.getOnlyElement(idsIter));
  
          //start
          taskLatch.countDown();
          callbackLatch.countDown();
          assertFuture(futures, 0);
  
          assertCacheStats(stagingCache, 0, 0, 1, 1);
  
          // Should not return anything
          idsIter = stagingCache.getAllIdentifiers();
          assertEquals(0, Iterators.size(idsIter));
      }
test_case.class_method_signature: UploadStagingCacheTest.testGetAllIdentifiers()
test_case.full_signature: @Test public void testGetAllIdentifiers()
test_case.identifier: testGetAllIdentifiers
test_case.invocations: put getAllIdentifiers assertEquals getOnlyElement countDown countDown assertFuture assertCacheStats getAllIdentifiers assertEquals size
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testGetAllIdentifiers()
focal_class.declarator: LOG = LoggerFactory.getLogger(UploadStagingCache.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(UploadStagingCache.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: UPLOAD_STAGING_DIR = "upload"
focal_class.modifier: protected static final
focal_class.original_string: protected static final String UPLOAD_STAGING_DIR = "upload";
focal_class.type: String
focal_class.var_name: UPLOAD_STAGING_DIR
focal_class.declarator: memWeigher = new Weigher<String, File>() {
          @Override public int weigh(String key, File value) {
              return (StringUtils.estimateMemoryUsage(key) +
                  StringUtils.estimateMemoryUsage(value.getAbsolutePath()) + 48);
          }}
focal_class.modifier: private final
focal_class.original_string: private final Weigher<String, File> memWeigher = new Weigher<String, File>() {
          @Override public int weigh(String key, File value) {
              return (StringUtils.estimateMemoryUsage(key) +
                  StringUtils.estimateMemoryUsage(value.getAbsolutePath()) + 48);
          }};
focal_class.type: Weigher<String, File>
focal_class.var_name: memWeigher
focal_class.declarator: size
focal_class.modifier: private
focal_class.original_string: private long size;
focal_class.type: long
focal_class.var_name: size
focal_class.declarator: currentSize
focal_class.modifier: private
focal_class.original_string: private AtomicLong currentSize;
focal_class.type: AtomicLong
focal_class.var_name: currentSize
focal_class.declarator: executor
focal_class.modifier: private
focal_class.original_string: private ListeningExecutorService executor;
focal_class.type: ListeningExecutorService
focal_class.var_name: executor
focal_class.declarator: scheduledExecutor
focal_class.modifier: private
focal_class.original_string: private ScheduledExecutorService scheduledExecutor;
focal_class.type: ScheduledExecutorService
focal_class.var_name: scheduledExecutor
focal_class.declarator: map
focal_class.modifier: private
focal_class.original_string: private ConcurrentMap<String, File> map;
focal_class.type: ConcurrentMap<String, File>
focal_class.var_name: map
focal_class.declarator: attic
focal_class.modifier: private
focal_class.original_string: private ConcurrentMap<String, File> attic;
focal_class.type: ConcurrentMap<String, File>
focal_class.var_name: attic
focal_class.declarator: uploadCacheSpace
focal_class.modifier: private
focal_class.original_string: private File uploadCacheSpace;
focal_class.type: File
focal_class.var_name: uploadCacheSpace
focal_class.declarator: uploader
focal_class.modifier: private
focal_class.original_string: private StagingUploader uploader;
focal_class.type: StagingUploader
focal_class.var_name: uploader
focal_class.declarator: cacheStats
focal_class.modifier: private
focal_class.original_string: private StagingCacheStats cacheStats;
focal_class.type: StagingCacheStats
focal_class.var_name: cacheStats
focal_class.declarator: downloadCache
focal_class.modifier: @Nullable
      private
focal_class.original_string: @Nullable
      private FileCache downloadCache;
focal_class.type: FileCache
focal_class.var_name: downloadCache
focal_class.declarator: statsExecutor
focal_class.modifier: private
focal_class.original_string: private ScheduledExecutorService statsExecutor;
focal_class.type: ScheduledExecutorService
focal_class.var_name: statsExecutor
focal_class.declarator: retryQueue
focal_class.modifier: private
focal_class.original_string: private LinkedBlockingQueue<String> retryQueue;
focal_class.type: LinkedBlockingQueue<String>
focal_class.var_name: retryQueue
focal_class.file: oak-blob-plugins/src/main/java/org/apache/jackrabbit/oak/plugins/blob/UploadStagingCache.java
focal_class.identifier: UploadStagingCache
focal_class.interfaces: implements Closeable
focal_class.class_method_signature: UploadStagingCache.UploadStagingCache(File dir, File home, int uploadThreads, long size /* bytes */,
          StagingUploader uploader, @Nullable FileCache cache, StatisticsProvider statisticsProvider,
          @Nullable ListeningExecutorService executor,
          @Nullable ScheduledExecutorService scheduledExecutor,
          int purgeInterval /* secs */, int retryInterval /* secs */)
focal_class.full_signature: private  UploadStagingCache(File dir, File home, int uploadThreads, long size /* bytes */,
          StagingUploader uploader, @Nullable FileCache cache, StatisticsProvider statisticsProvider,
          @Nullable ListeningExecutorService executor,
          @Nullable ScheduledExecutorService scheduledExecutor,
          int purgeInterval /* secs */, int retryInterval /* secs */)
focal_class.identifier: UploadStagingCache
focal_class.modifiers: private
focal_class.parameters: (File dir, File home, int uploadThreads, long size /* bytes */,
          StagingUploader uploader, @Nullable FileCache cache, StatisticsProvider statisticsProvider,
          @Nullable ListeningExecutorService executor,
          @Nullable ScheduledExecutorService scheduledExecutor,
          int purgeInterval /* secs */, int retryInterval /* secs */)
focal_class.signature:  UploadStagingCache(File dir, File home, int uploadThreads, long size /* bytes */,
          StagingUploader uploader, @Nullable FileCache cache, StatisticsProvider statisticsProvider,
          @Nullable ListeningExecutorService executor,
          @Nullable ScheduledExecutorService scheduledExecutor,
          int purgeInterval /* secs */, int retryInterval /* secs */)
focal_class.class_method_signature: UploadStagingCache.UploadStagingCache()
focal_class.full_signature: private  UploadStagingCache()
focal_class.identifier: UploadStagingCache
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.signature:  UploadStagingCache()
focal_class.class_method_signature: UploadStagingCache.build(File dir, File home, int uploadThreads, long size
          /* bytes */, StagingUploader uploader, @Nullable FileCache cache,
          StatisticsProvider statisticsProvider, @Nullable ListeningExecutorService executor,
          @Nullable ScheduledExecutorService scheduledExecutor, int purgeInterval /* secs */,
          int retryInterval /* secs */)
focal_class.full_signature: public static UploadStagingCache build(File dir, File home, int uploadThreads, long size
          /* bytes */, StagingUploader uploader, @Nullable FileCache cache,
          StatisticsProvider statisticsProvider, @Nullable ListeningExecutorService executor,
          @Nullable ScheduledExecutorService scheduledExecutor, int purgeInterval /* secs */,
          int retryInterval /* secs */)
focal_class.identifier: build
focal_class.modifiers: public static
focal_class.parameters: (File dir, File home, int uploadThreads, long size
          /* bytes */, StagingUploader uploader, @Nullable FileCache cache,
          StatisticsProvider statisticsProvider, @Nullable ListeningExecutorService executor,
          @Nullable ScheduledExecutorService scheduledExecutor, int purgeInterval /* secs */,
          int retryInterval /* secs */)
focal_class.return: UploadStagingCache
focal_class.signature: UploadStagingCache build(File dir, File home, int uploadThreads, long size
          /* bytes */, StagingUploader uploader, @Nullable FileCache cache,
          StatisticsProvider statisticsProvider, @Nullable ListeningExecutorService executor,
          @Nullable ScheduledExecutorService scheduledExecutor, int purgeInterval /* secs */,
          int retryInterval /* secs */)
focal_class.class_method_signature: UploadStagingCache.build(File home, File rootPath)
focal_class.full_signature: private void build(File home, File rootPath)
focal_class.identifier: build
focal_class.modifiers: private
focal_class.parameters: (File home, File rootPath)
focal_class.return: void
focal_class.signature: void build(File home, File rootPath)
focal_class.class_method_signature: UploadStagingCache.put(String id, File input)
focal_class.full_signature: public Optional<SettableFuture<Integer>> put(String id, File input)
focal_class.identifier: put
focal_class.modifiers: public
focal_class.parameters: (String id, File input)
focal_class.return: Optional<SettableFuture<Integer>>
focal_class.signature: Optional<SettableFuture<Integer>> put(String id, File input)
focal_class.class_method_signature: UploadStagingCache.putOptionalDisregardingSize(String id, File input,
          boolean ignoreSize)
focal_class.full_signature: private Optional<SettableFuture<Integer>> putOptionalDisregardingSize(String id, File input,
          boolean ignoreSize)
focal_class.identifier: putOptionalDisregardingSize
focal_class.modifiers: private
focal_class.parameters: (String id, File input,
          boolean ignoreSize)
focal_class.return: Optional<SettableFuture<Integer>>
focal_class.signature: Optional<SettableFuture<Integer>> putOptionalDisregardingSize(String id, File input,
          boolean ignoreSize)
focal_class.class_method_signature: UploadStagingCache.existsOrNotExistsMoveFile(File source, File destination, AtomicLong currentSize,
          long length)
focal_class.full_signature: private synchronized boolean existsOrNotExistsMoveFile(File source, File destination, AtomicLong currentSize,
          long length)
focal_class.identifier: existsOrNotExistsMoveFile
focal_class.modifiers: private synchronized
focal_class.parameters: (File source, File destination, AtomicLong currentSize,
          long length)
focal_class.return: boolean
focal_class.signature: boolean existsOrNotExistsMoveFile(File source, File destination, AtomicLong currentSize,
          long length)
focal_class.class_method_signature: UploadStagingCache.stage(final String id, final File upload)
focal_class.full_signature: private SettableFuture<Integer> stage(final String id, final File upload)
focal_class.identifier: stage
focal_class.modifiers: private
focal_class.parameters: (final String id, final File upload)
focal_class.return: SettableFuture<Integer>
focal_class.signature: SettableFuture<Integer> stage(final String id, final File upload)
focal_class.class_method_signature: UploadStagingCache.invalidate(String key)
focal_class.full_signature: protected void invalidate(String key)
focal_class.identifier: invalidate
focal_class.modifiers: protected
focal_class.parameters: (String key)
focal_class.return: void
focal_class.signature: void invalidate(String key)
focal_class.class_method_signature: UploadStagingCache.getAllIdentifiers()
focal_class.full_signature: protected Iterator<String> getAllIdentifiers()
focal_class.identifier: getAllIdentifiers
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: Iterator<String>
focal_class.signature: Iterator<String> getAllIdentifiers()
focal_class.class_method_signature: UploadStagingCache.remove()
focal_class.full_signature: private void remove()
focal_class.identifier: remove
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void remove()
focal_class.class_method_signature: UploadStagingCache.deleteInternal(String key, File toBeDeleted)
focal_class.full_signature: private void deleteInternal(String key, File toBeDeleted)
focal_class.identifier: deleteInternal
focal_class.modifiers: private
focal_class.parameters: (String key, File toBeDeleted)
focal_class.return: void
focal_class.signature: void deleteInternal(String key, File toBeDeleted)
focal_class.class_method_signature: UploadStagingCache.getIfPresent(String key)
focal_class.full_signature: @Nullable public File getIfPresent(String key)
focal_class.identifier: getIfPresent
focal_class.modifiers: @Nullable public
focal_class.parameters: (String key)
focal_class.return: File
focal_class.signature: File getIfPresent(String key)
focal_class.class_method_signature: UploadStagingCache.getStats()
focal_class.full_signature: public DataStoreCacheStatsMBean getStats()
focal_class.identifier: getStats
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: DataStoreCacheStatsMBean
focal_class.signature: DataStoreCacheStatsMBean getStats()
focal_class.class_method_signature: UploadStagingCache.close()
focal_class.full_signature: @Override public void close()
focal_class.identifier: close
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.class_method_signature: UploadStagingCache.setDownloadCache(@Nullable FileCache downloadCache)
focal_class.full_signature: protected void setDownloadCache(@Nullable FileCache downloadCache)
focal_class.identifier: setDownloadCache
focal_class.modifiers: protected
focal_class.parameters: (@Nullable FileCache downloadCache)
focal_class.return: void
focal_class.signature: void setDownloadCache(@Nullable FileCache downloadCache)
focal_method.body: protected Iterator<String> getAllIdentifiers() {
          return map.keySet().iterator();
      }
focal_method.class_method_signature: UploadStagingCache.getAllIdentifiers()
focal_method.full_signature: protected Iterator<String> getAllIdentifiers()
focal_method.identifier: getAllIdentifiers
focal_method.invocations: iterator keySet
focal_method.modifiers: protected
focal_method.parameters: ()
focal_method.return: Iterator<String>
focal_method.signature: Iterator<String> getAllIdentifiers()