Home
last modified time | relevance | path

Searched refs:scheduledExecutorService (Results 1 – 25 of 56) sorted by relevance

123

/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessChannelBuilder.java69 private ScheduledExecutorService scheduledExecutorService; field in InProcessChannelBuilder
141 public InProcessChannelBuilder scheduledExecutorService( in scheduledExecutorService() method in InProcessChannelBuilder
142 ScheduledExecutorService scheduledExecutorService) { in scheduledExecutorService() argument
143 this.scheduledExecutorService = in scheduledExecutorService()
144 checkNotNull(scheduledExecutorService, "scheduledExecutorService"); in scheduledExecutorService()
151 return new InProcessClientTransportFactory(name, scheduledExecutorService); in buildTransportFactory()
164 String name, @Nullable ScheduledExecutorService scheduledExecutorService) { in InProcessClientTransportFactory() argument
166 useSharedTimer = scheduledExecutorService == null; in InProcessClientTransportFactory()
168 ? SharedResourceHolder.get(GrpcUtil.TIMER_SERVICE) : scheduledExecutorService; in InProcessClientTransportFactory()
DInProcessServerBuilder.java119 public InProcessServerBuilder scheduledExecutorService( in scheduledExecutorService() method in InProcessServerBuilder
120 ScheduledExecutorService scheduledExecutorService) { in scheduledExecutorService() argument
122 checkNotNull(scheduledExecutorService, "scheduledExecutorService")); in scheduledExecutorService()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DFakeClockTest.java130 ScheduledExecutorService scheduledExecutorService = fakeClock.getScheduledExecutorService(); in testPendingAndDueTasks() local
132 scheduledExecutorService.schedule(newRunnable(), 200L, TimeUnit.NANOSECONDS); in testPendingAndDueTasks()
133 scheduledExecutorService.execute(newRunnable()); in testPendingAndDueTasks()
134 scheduledExecutorService.schedule(newRunnable(), 0L, TimeUnit.NANOSECONDS); in testPendingAndDueTasks()
135 scheduledExecutorService.schedule(newRunnable(), 80L, TimeUnit.NANOSECONDS); in testPendingAndDueTasks()
136 scheduledExecutorService.schedule(newRunnable(), 90L, TimeUnit.NANOSECONDS); in testPendingAndDueTasks()
137 scheduledExecutorService.schedule(newRunnable(), 100L, TimeUnit.NANOSECONDS); in testPendingAndDueTasks()
138 scheduledExecutorService.schedule(newRunnable(), 110L, TimeUnit.NANOSECONDS); in testPendingAndDueTasks()
139 scheduledExecutorService.schedule(newRunnable(), 120L, TimeUnit.NANOSECONDS); in testPendingAndDueTasks()
164 ScheduledExecutorService scheduledExecutorService = fakeClock.getScheduledExecutorService(); in testTaskFilter() local
[all …]
/external/connectedappssdk/sdk/src/main/java/com/google/android/enterprise/connectedapps/
DAbstractProfileConnector.java40 private final ScheduledExecutorService scheduledExecutorService; field in AbstractProfileConnector
51 if (builder.scheduledExecutorService == null) { in AbstractProfileConnector()
52 scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(); in AbstractProfileConnector()
54 scheduledExecutorService = builder.scheduledExecutorService; in AbstractProfileConnector()
111 scheduledExecutorService, in crossProfileSender()
214 @Nullable ScheduledExecutorService scheduledExecutorService; field in AbstractProfileConnector.Builder
226 public Builder setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService) { in setScheduledExecutorService() argument
227 this.scheduledExecutorService = scheduledExecutorService; in setScheduledExecutorService()
DCrossProfileSender.java227 private final ScheduledExecutorService scheduledExecutorService; field in CrossProfileSender
263 ScheduledExecutorService scheduledExecutorService, in CrossProfileSender() argument
270 || scheduledExecutorService == null) { in CrossProfileSender()
278 this.scheduledExecutorService = scheduledExecutorService; in CrossProfileSender()
295 scheduledExecutorService.execute(
312 scheduledExecutorService.execute(
354 scheduledExecutorService.schedule( in maybeScheduleAutomaticDisconnection()
529 scheduledExecutorService.execute(this::tryBind); in startTryBinding()
582 scheduledExecutorService.schedule(this::tryBind, bindRetryDelayMs, TimeUnit.MILLISECONDS); in scheduleBindAttempt()
707 scheduledExecutorService.execute(this::drainAsyncQueue); in tryMakeAsyncCalls()
[all …]
DAbstractUserConnector.java100 @Nullable ScheduledExecutorService scheduledExecutorService; field in AbstractUserConnector.Builder
111 public Builder setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService) { in setScheduledExecutorService() argument
112 this.scheduledExecutorService = scheduledExecutorService; in setScheduledExecutorService()
DCrossUserConnector.java46 public Builder setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService) { in setScheduledExecutorService() argument
47 implBuilder.setScheduledExecutorService(scheduledExecutorService); in setScheduledExecutorService()
/external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/robotests/
DOtherProfileListenableFutureTest.java58 private final TestScheduledExecutorService scheduledExecutorService = field in OtherProfileListenableFutureTest
61 TestProfileConnector.create(context, scheduledExecutorService);
63 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
152 scheduledExecutorService.advanceTimeBy(4, TimeUnit.SECONDS); in other_listenableFuture_timeoutSetOnMethod_doesNotTimeoutEarly()
164 scheduledExecutorService.advanceTimeBy(6, TimeUnit.SECONDS); in other_listenableFuture_timeoutSetOnMethod_timesOut()
176 scheduledExecutorService.advanceTimeBy(6, TimeUnit.SECONDS); in other_listenableFuture_timeoutSetOnType_doesNotTimeoutEarly()
188 scheduledExecutorService.advanceTimeBy(8, TimeUnit.SECONDS); in other_listenableFuture_timeoutSetOnType_timesOut()
200 scheduledExecutorService.advanceTimeBy( in other_listenableFuture_timeoutSetByDefault_doesNotTimeoutEarly()
213 scheduledExecutorService.advanceTimeBy( in other_listenableFuture_timeoutSetByDefault_timesOut()
228 scheduledExecutorService.advanceTimeBy(timeoutMillis - 1, TimeUnit.MILLISECONDS); in other_listenableFuture_timeoutSetByCaller_doesNotTimeoutEarly()
[all …]
DOtherProfileAsyncTest.java70 private final TestScheduledExecutorService scheduledExecutorService = field in OtherProfileAsyncTest
73 TestProfileConnector.create(context, scheduledExecutorService);
75 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
232 scheduledExecutorService.advanceTimeBy( in other_async_timeoutSetByDefault_doesNotTimeoutEarly()
245 scheduledExecutorService.advanceTimeBy( in other_async_timeoutSetByDefault_timesOut()
261 scheduledExecutorService.advanceTimeBy(timeoutMillis - 1, TimeUnit.MILLISECONDS); in other_async_timeoutSetByCaller_doesNotTimeoutEarly()
275 scheduledExecutorService.advanceTimeBy(timeoutMillis + 1, TimeUnit.MILLISECONDS); in other_async_timeoutSetByCaller_timesOut()
288 scheduledExecutorService.advanceTimeBy( in other_async_doesNotTimeoutAfterCompletion()
DProviderTest.java36 private final TestScheduledExecutorService scheduledExecutorService = field in ProviderTest
40 TestProfileConnector.create(context, scheduledExecutorService);
42 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
DManualConnectionManagementTest.java42 private final TestScheduledExecutorService scheduledExecutorService = field in ManualConnectionManagementTest
45 TestProfileConnector.create(context, scheduledExecutorService);
47 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
DCrossUserTest.java46 private final TestScheduledExecutorService scheduledExecutorService = field in CrossUserTest
49 TestCrossUserConnector.create(context, scheduledExecutorService);
51 new RobolectricTestUtilities(testCrossUserConnector, scheduledExecutorService);
DCrossProfileInterfaceTest.java52 private final TestScheduledExecutorService scheduledExecutorService = field in CrossProfileInterfaceTest
55 TestProfileConnector.create(context, scheduledExecutorService);
57 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
/external/grpc-grpc-java/core/src/test/java/io/grpc/inprocess/
DInProcessServerBuilderTest.java75 ScheduledExecutorService scheduledExecutorService = in scheduledExecutorService_custom() local
78 InProcessServerBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService); in scheduledExecutorService_custom()
85 assertSame(scheduledExecutorService, scheduledExecutorServicePool.getObject()); in scheduledExecutorService_custom()
87 scheduledExecutorServicePool.returnObject(scheduledExecutorService); in scheduledExecutorService_custom()
DInProcessChannelBuilderTest.java51 ScheduledExecutorService scheduledExecutorService = in scheduledExecutorService_custom() local
54 InProcessChannelBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService); in scheduledExecutorService_custom()
59 assertSame(scheduledExecutorService, clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_custom()
/external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/
DCrossProfileSenderTest.java56 private final TestScheduledExecutorService scheduledExecutorService = field in CrossProfileSenderTest
59 new RobolectricTestUtilities(context, scheduledExecutorService);
71 scheduledExecutorService, in setUp()
94 scheduledExecutorService, in construct_nullContext_throwsNullPointerException()
109 scheduledExecutorService, in construct_nullConnectedAppsServiceClassName_throwsNullPointerException()
124 scheduledExecutorService, in construct_nullConnectionListener_throwsNullPointerException()
139 scheduledExecutorService, in construct_nullAvailabilityListener_throwsNullPointerException()
154 scheduledExecutorService, in construct_nullBindingConfig_throwsNullPointerException()
184 scheduledExecutorService, in construct_nullAvailabilityRestrictions_throwsNullPointerException()
487 scheduledExecutorService, in initWithDpcBinding()
DRobolectricTestUtilities.java77 private final TestScheduledExecutorService scheduledExecutorService; field in RobolectricTestUtilities
90 ProfileConnector connector, TestScheduledExecutorService scheduledExecutorService) { in RobolectricTestUtilities() argument
91 this((Application) connector.applicationContext(), scheduledExecutorService); in RobolectricTestUtilities() local
96 Application context, TestScheduledExecutorService scheduledExecutorService) { in RobolectricTestUtilities() argument
103 this.scheduledExecutorService = scheduledExecutorService; in RobolectricTestUtilities()
350 if (scheduledExecutorService != null) { in advanceTimeBySeconds()
352 scheduledExecutorService.advanceTimeBy(1, SECONDS); in advanceTimeBySeconds()
DPermissionsTest.java38 private final TestScheduledExecutorService scheduledExecutorService = field in PermissionsTest
41 TestProfileConnector.create(context, scheduledExecutorService);
44 new RobolectricTestUtilities(connector, scheduledExecutorService);
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetChannelBuilder.java78 private ScheduledExecutorService scheduledExecutorService; field in CronetChannelBuilder
178 public final CronetChannelBuilder scheduledExecutorService( in scheduledExecutorService() method in CronetChannelBuilder
179 ScheduledExecutorService scheduledExecutorService) { in scheduledExecutorService() argument
180 this.scheduledExecutorService = in scheduledExecutorService()
181 checkNotNull(scheduledExecutorService, "scheduledExecutorService"); in scheduledExecutorService()
191 scheduledExecutorService, in buildTransportFactory()
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetChannelBuilderTest.java100 ScheduledExecutorService scheduledExecutorService = mock(ScheduledExecutorService.class); in scheduledExecutorService_custom() local
102 CronetChannelBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService); in scheduledExecutorService_custom()
106 assertSame(scheduledExecutorService, clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_custom()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpChannelBuilderTest.java152 ScheduledExecutorService scheduledExecutorService = in scheduledExecutorService_custom() local
155 OkHttpChannelBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService); in scheduledExecutorService_custom()
160 assertSame(scheduledExecutorService, clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_custom()
/external/downloader/src/main/java/com/google/android/downloader/
DAndroidConnectivityHandler.java58 private final ScheduledExecutorService scheduledExecutorService; field in AndroidConnectivityHandler
76 Context context, ScheduledExecutorService scheduledExecutorService, long timeoutMillis) { in AndroidConnectivityHandler() argument
83 this.scheduledExecutorService = scheduledExecutorService; in AndroidConnectivityHandler()
102 return Futures.withTimeout(futureTask, timeoutMillis, MILLISECONDS, scheduledExecutorService); in checkConnectivity()
/external/connectedappssdk/tests/shared/src/main/java/com/google/android/enterprise/connectedapps/testapp/connector/
DTestProfileConnectorWithCustomServiceClass.java28 Context context, ScheduledExecutorService scheduledExecutorService) { in create() argument
30 .setScheduledExecutorService(scheduledExecutorService) in create()
DDirectBootAwareConnector.java33 Context context, ScheduledExecutorService scheduledExecutorService) { in create() argument
35 .setScheduledExecutorService(scheduledExecutorService) in create()
/external/connectedappssdk/tests/shared/src/main/java/com/google/android/enterprise/connectedapps/testapp/crossuser/
DTestCrossUserConnector.java33 Context context, ScheduledExecutorService scheduledExecutorService) { in create() argument
35 .setScheduledExecutorService(scheduledExecutorService) in create()

123