@Test @RunWithCustomExecutor public void isRunningShouldReturnFalseWhenNoProcessStarted() { OfferSyncService instance = spy(new OfferSyncService(restoreOfferBackupService, distribution, 1000, 16, 1, 1, 1)); boolean isRunning = instance.isRunning(); assertThat(isRunning).isFalse(); }
public boolean isRunning() { OfferSyncProcess offerSyncProcess = lastOfferSyncService.get(); return offerSyncProcess != null && offerSyncProcess.isRunning(); }
OfferSyncService implements AutoCloseable { public boolean isRunning() { OfferSyncProcess offerSyncProcess = lastOfferSyncService.get(); return offerSyncProcess != null && offerSyncProcess.isRunning(); } }
OfferSyncService implements AutoCloseable { public boolean isRunning() { OfferSyncProcess offerSyncProcess = lastOfferSyncService.get(); return offerSyncProcess != null && offerSyncProcess.isRunning(); } OfferSyncService(StorageDistribution distribution, StorageConfiguration storageConfiguration); @VisibleForTesting  OfferSyncService(
        RestoreOfferBackupService restoreOfferBackupService,
        StorageDistribution distribution, int bulkSize, int offerSyncThreadPoolSize, int offerSyncNumberOfRetries,
        int offerSyncFirstAttemptWaitingTime, int offerSyncWaitingTime); }
OfferSyncService implements AutoCloseable { public boolean isRunning() { OfferSyncProcess offerSyncProcess = lastOfferSyncService.get(); return offerSyncProcess != null && offerSyncProcess.isRunning(); } OfferSyncService(StorageDistribution distribution, StorageConfiguration storageConfiguration); @VisibleForTesting  OfferSyncService(
        RestoreOfferBackupService restoreOfferBackupService,
        StorageDistribution distribution, int bulkSize, int offerSyncThreadPoolSize, int offerSyncNumberOfRetries,
        int offerSyncFirstAttemptWaitingTime, int offerSyncWaitingTime); boolean startSynchronization(String sourceOffer, String targetOffer, String strategyId,
        List<OfferPartialSyncItem> items); boolean startSynchronization(String sourceOffer, String targetOffer, String strategyId,
        DataCategory dataCategory, Long offset); boolean isRunning(); OfferSyncStatus getLastSynchronizationStatus(); @VisibleForTesting ExecutorService getExecutor(); @Override void close(); }
OfferSyncService implements AutoCloseable { public boolean isRunning() { OfferSyncProcess offerSyncProcess = lastOfferSyncService.get(); return offerSyncProcess != null && offerSyncProcess.isRunning(); } OfferSyncService(StorageDistribution distribution, StorageConfiguration storageConfiguration); @VisibleForTesting  OfferSyncService(
        RestoreOfferBackupService restoreOfferBackupService,
        StorageDistribution distribution, int bulkSize, int offerSyncThreadPoolSize, int offerSyncNumberOfRetries,
        int offerSyncFirstAttemptWaitingTime, int offerSyncWaitingTime); boolean startSynchronization(String sourceOffer, String targetOffer, String strategyId,
        List<OfferPartialSyncItem> items); boolean startSynchronization(String sourceOffer, String targetOffer, String strategyId,
        DataCategory dataCategory, Long offset); boolean isRunning(); OfferSyncStatus getLastSynchronizationStatus(); @VisibleForTesting ExecutorService getExecutor(); @Override void close();  }