Searched refs:timeoutTask (Results 1 – 6 of 6) sorted by relevance
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/timers/ |
| D | ApiCallTimeoutTracker.java | 29 private final TimeoutTask timeoutTask; field in ApiCallTimeoutTracker
34 this.timeoutTask = Validate.paramNotNull(timeout, "timeoutTask"); in ApiCallTimeoutTracker()
40 return timeoutTask.hasExecuted(); in hasExecuted()
53 timeoutTask.cancel(); in cancel()
58 timeoutTask.abortable(abortable); in abortable()
|
| D | TimerUtils.java | 54 TimeoutTask timeoutTask = new AsyncTimeoutTask(completableFuture, exceptionSupplier); in timeAsyncTaskIfNeeded() local
57 timeoutExecutor.schedule(timeoutTask, in timeAsyncTaskIfNeeded()
60 TimeoutTracker timeoutTracker = new ApiCallTimeoutTracker(timeoutTask, scheduledFuture); in timeAsyncTaskIfNeeded()
82 SyncTimeoutTask timeoutTask = new SyncTimeoutTask(threadToInterrupt); in timeSyncTaskIfNeeded() local
85 timeoutExecutor.schedule(timeoutTask, in timeSyncTaskIfNeeded()
88 return new ApiCallTimeoutTracker(timeoutTask, scheduledFuture); in timeSyncTaskIfNeeded()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/utils/ |
| D | BetterFixedChannelPool.java | 74 private final Runnable timeoutTask; field in BetterFixedChannelPool
97 timeoutTask = null; in BetterFixedChannelPool()
107 timeoutTask = new TimeoutTask() { in BetterFixedChannelPool()
116 timeoutTask = new TimeoutTask() { in BetterFixedChannelPool()
196 if (timeoutTask != null) { in acquire0()
197 … task.timeoutFuture = executor.schedule(timeoutTask, acquireTimeoutNanos, TimeUnit.NANOSECONDS); in acquire0()
|
| /external/nist-sip/java/gov/nist/javax/sip/clientauthutils/ |
| D | CredentialsCache.java | 83 TimeoutTask timeoutTask = new TimeoutTask( callId,user); in cacheAuthorizationHeader() local
85 this.timer.schedule(timeoutTask, cacheTime*1000); in cacheAuthorizationHeader()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | HealthCheckedChannelPoolTest.java | 173 ArgumentCaptor<Runnable> timeoutTask = ArgumentCaptor.forClass(Runnable.class); in slowAcquireTimesOut() local
174 Mockito.verify(eventLoopGroup).schedule(timeoutTask.capture(), anyLong(), any()); in slowAcquireTimesOut()
175 timeoutTask.getValue().run(); in slowAcquireTimesOut()
|
| /external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/ |
| D | XdsClientImplTestBase.java | 3641 ScheduledTask timeoutTask = in startResourceWatcher() local
3643 assertThat(timeoutTask.getDelay(TimeUnit.SECONDS)) in startResourceWatcher()
|