@Test public void closeWithoutInitTest() throws Exception { refreshState(false, true); compactor = getCompactor(state.log, DISK_IO_SCHEDULER); compactor.close(0); }
void close(long waitTimeSecs) throws InterruptedException { isActive = false; if (waitTimeSecs > 0 && !runningLatch.await(waitTimeSecs, TimeUnit.SECONDS)) { logger.error("Compactor did not shutdown within {} seconds for {}", waitTimeSecs, storeId); } logger.trace("Closed BlobStoreCompactor for {}", storeId); }
BlobStoreCompactor { void close(long waitTimeSecs) throws InterruptedException { isActive = false; if (waitTimeSecs > 0 && !runningLatch.await(waitTimeSecs, TimeUnit.SECONDS)) { logger.error("Compactor did not shutdown within {} seconds for {}", waitTimeSecs, storeId); } logger.trace("Closed BlobStoreCompactor for {}", storeId); } }
BlobStoreCompactor { void close(long waitTimeSecs) throws InterruptedException { isActive = false; if (waitTimeSecs > 0 && !runningLatch.await(waitTimeSecs, TimeUnit.SECONDS)) { logger.error("Compactor did not shutdown within {} seconds for {}", waitTimeSecs, storeId); } logger.trace("Closed BlobStoreCompactor for {}", storeId); } BlobStoreCompactor(String dataDir, String storeId, StoreKeyFactory storeKeyFactory, StoreConfig config,
      StoreMetrics srcMetrics, StoreMetrics tgtMetrics, DiskIOScheduler diskIOScheduler,
      DiskSpaceAllocator diskSpaceAllocator, Log srcLog, Time time, UUID sessionId, UUID incarnationId,
      AccountService accountService); }
BlobStoreCompactor { void close(long waitTimeSecs) throws InterruptedException { isActive = false; if (waitTimeSecs > 0 && !runningLatch.await(waitTimeSecs, TimeUnit.SECONDS)) { logger.error("Compactor did not shutdown within {} seconds for {}", waitTimeSecs, storeId); } logger.trace("Closed BlobStoreCompactor for {}", storeId); } BlobStoreCompactor(String dataDir, String storeId, StoreKeyFactory storeKeyFactory, StoreConfig config,
      StoreMetrics srcMetrics, StoreMetrics tgtMetrics, DiskIOScheduler diskIOScheduler,
      DiskSpaceAllocator diskSpaceAllocator, Log srcLog, Time time, UUID sessionId, UUID incarnationId,
      AccountService accountService);  }
BlobStoreCompactor { void close(long waitTimeSecs) throws InterruptedException { isActive = false; if (waitTimeSecs > 0 && !runningLatch.await(waitTimeSecs, TimeUnit.SECONDS)) { logger.error("Compactor did not shutdown within {} seconds for {}", waitTimeSecs, storeId); } logger.trace("Closed BlobStoreCompactor for {}", storeId); } BlobStoreCompactor(String dataDir, String storeId, StoreKeyFactory storeKeyFactory, StoreConfig config,
      StoreMetrics srcMetrics, StoreMetrics tgtMetrics, DiskIOScheduler diskIOScheduler,
      DiskSpaceAllocator diskSpaceAllocator, Log srcLog, Time time, UUID sessionId, UUID incarnationId,
      AccountService accountService);   }