@Test public void doesNotLogIfWaitForLocksIsSlow() { flushLogsWithCall(LONG_DURATION, () -> profilingTimelockService.waitForLocks(WaitForLocksRequest.of( ImmutableSet.of(StringLockDescriptor.of("combination")), 123))); verifyLoggerNeverInvoked(); }
@Override public WaitForLocksResponse waitForLocks(WaitForLocksRequest request) { tryFlushLogs(); return delegate.waitForLocks(request); }
ProfilingTimelockService implements AutoCloseable, TimelockService { @Override public WaitForLocksResponse waitForLocks(WaitForLocksRequest request) { tryFlushLogs(); return delegate.waitForLocks(request); } }
ProfilingTimelockService implements AutoCloseable, TimelockService { @Override public WaitForLocksResponse waitForLocks(WaitForLocksRequest request) { tryFlushLogs(); return delegate.waitForLocks(request); } @VisibleForTesting  ProfilingTimelockService(
            Logger logger,
            TimelockService delegate,
            Supplier<Stopwatch> stopwatchSupplier,
            BooleanSupplier loggingPermissionSupplier); }
ProfilingTimelockService implements AutoCloseable, TimelockService { @Override public WaitForLocksResponse waitForLocks(WaitForLocksRequest request) { tryFlushLogs(); return delegate.waitForLocks(request); } @VisibleForTesting  ProfilingTimelockService(
            Logger logger,
            TimelockService delegate,
            Supplier<Stopwatch> stopwatchSupplier,
            BooleanSupplier loggingPermissionSupplier); static ProfilingTimelockService create(TimelockService delegate); @Override boolean isInitialized(); @Override long getFreshTimestamp(); @Override long getCommitTimestamp(long startTs, LockToken commitLocksToken); @Override TimestampRange getFreshTimestamps(int numTimestampsRequested); @Override LockImmutableTimestampResponse lockImmutableTimestamp(); @Override List<StartIdentifiedAtlasDbTransactionResponse> startIdentifiedAtlasDbTransactionBatch(int count); @Override long getImmutableTimestamp(); @Override LockResponse lock(LockRequest request); @Override WaitForLocksResponse waitForLocks(WaitForLocksRequest request); @Override Set<LockToken> refreshLockLeases(Set<LockToken> tokens); @Override Set<LockToken> unlock(Set<LockToken> tokens); @Override void tryUnlock(Set<LockToken> tokens); @Override long currentTimeMillis(); @Override void close(); }
ProfilingTimelockService implements AutoCloseable, TimelockService { @Override public WaitForLocksResponse waitForLocks(WaitForLocksRequest request) { tryFlushLogs(); return delegate.waitForLocks(request); } @VisibleForTesting  ProfilingTimelockService(
            Logger logger,
            TimelockService delegate,
            Supplier<Stopwatch> stopwatchSupplier,
            BooleanSupplier loggingPermissionSupplier); static ProfilingTimelockService create(TimelockService delegate); @Override boolean isInitialized(); @Override long getFreshTimestamp(); @Override long getCommitTimestamp(long startTs, LockToken commitLocksToken); @Override TimestampRange getFreshTimestamps(int numTimestampsRequested); @Override LockImmutableTimestampResponse lockImmutableTimestamp(); @Override List<StartIdentifiedAtlasDbTransactionResponse> startIdentifiedAtlasDbTransactionBatch(int count); @Override long getImmutableTimestamp(); @Override LockResponse lock(LockRequest request); @Override WaitForLocksResponse waitForLocks(WaitForLocksRequest request); @Override Set<LockToken> refreshLockLeases(Set<LockToken> tokens); @Override Set<LockToken> unlock(Set<LockToken> tokens); @Override void tryUnlock(Set<LockToken> tokens); @Override long currentTimeMillis(); @Override void close();  }