Home
last modified time | relevance | path

Searched refs:scheduledExecutorService (Results 1 – 25 of 59) 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
52 if (builder.scheduledExecutorService == null) { in AbstractProfileConnector()
53 scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(); in AbstractProfileConnector()
56 scheduledExecutorService = builder.scheduledExecutorService; in AbstractProfileConnector()
79 scheduledExecutorService.shutdownNow(); in finalize()
114 scheduledExecutorService, in crossProfileSender()
245 @Nullable ScheduledExecutorService scheduledExecutorService; field in AbstractProfileConnector.Builder
257 public Builder setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService) { in setScheduledExecutorService() argument
258 this.scheduledExecutorService = scheduledExecutorService; in setScheduledExecutorService()
DCrossProfileSender.java165 sender.scheduledExecutorService.execute(sender::maybeScheduleAutomaticDisconnection); in onException()
201 private final ScheduledExecutorService scheduledExecutorService; field in CrossProfileSender
231 scheduledExecutorService.execute(
238 scheduledExecutorService.execute(
246 scheduledExecutorService.execute(
269 scheduledExecutorService.execute(
295 sender.scheduledExecutorService.execute(sender::checkAvailability);
315 ScheduledExecutorService scheduledExecutorService, in CrossProfileSender() argument
322 || scheduledExecutorService == null) { in CrossProfileSender()
330 this.scheduledExecutorService = scheduledExecutorService; in CrossProfileSender()
[all …]
DAbstractUserConnector.java37 private final ScheduledExecutorService scheduledExecutorService; field in AbstractUserConnector
93 if (builder.scheduledExecutorService == null) { in AbstractUserConnector()
94 scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(); in AbstractUserConnector()
96 scheduledExecutorService = builder.scheduledExecutorService; in AbstractUserConnector()
174 scheduledExecutorService, in userConnection()
273 @Nullable ScheduledExecutorService scheduledExecutorService; field in AbstractUserConnector.Builder
283 public Builder setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService) { in setScheduledExecutorService() argument
284 this.scheduledExecutorService = scheduledExecutorService; in setScheduledExecutorService()
/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/shared/src/main/java/com/google/android/enterprise/connectedapps/testapp/crossuser/
DAppCrossUserConnector.java33 Context context, ScheduledExecutorService scheduledExecutorService) { in create() argument
35 .setScheduledExecutorService(scheduledExecutorService) in create()
41 ScheduledExecutorService scheduledExecutorService, in create() argument
45 .setScheduledExecutorService(scheduledExecutorService) in create()
/external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/
DCrossProfileSenderTest.java59 private final TestScheduledExecutorService scheduledExecutorService = field in CrossProfileSenderTest
62 new RobolectricTestUtilities(context, scheduledExecutorService);
74 scheduledExecutorService, in setUp()
97 scheduledExecutorService, in construct_nullContext_throwsNullPointerException()
112 scheduledExecutorService, in construct_nullConnectedAppsServiceClassName_throwsNullPointerException()
127 scheduledExecutorService, in construct_nullConnectionListener_throwsNullPointerException()
142 scheduledExecutorService, in construct_nullAvailabilityListener_throwsNullPointerException()
157 scheduledExecutorService, in construct_nullBindingConfig_throwsNullPointerException()
187 scheduledExecutorService, in construct_nullAvailabilityRestrictions_throwsNullPointerException()
469 scheduledExecutorService, in createMultipleSenders_workProfileBecomesAvailable_callsAvailabilityListenerForEachSender()
[all …]
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()
363 if (scheduledExecutorService != null) { in advanceTimeBySeconds()
365 scheduledExecutorService.advanceTimeBy(1, SECONDS); in advanceTimeBySeconds()
DUserConnectorTest.java71 private final TestScheduledExecutorService scheduledExecutorService = field in UserConnectorTest
74 new RobolectricTestUtilities(context, scheduledExecutorService);
90 AppCrossUserConnector.create(context, scheduledExecutorService); in defaultBinder_works()
103 AppCrossUserConnector.create(context, scheduledExecutorService, TestBinder::new); in testBinderFactory_isUsed_tryBindCallsIncremented()
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/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/robotests/
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);
DOtherProfileListenableFutureTest.java57 private final TestScheduledExecutorService scheduledExecutorService = field in OtherProfileListenableFutureTest
60 TestProfileConnector.create(context, scheduledExecutorService);
62 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
151 scheduledExecutorService.advanceTimeBy(10, TimeUnit.MINUTES); in other_listenableFuture_doesNotTimeout()
DCrossProfileServiceTest.java48 private final TestScheduledExecutorService scheduledExecutorService = field in CrossProfileServiceTest
51 TestProfileConnector.create(context, scheduledExecutorService);
53 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
DAvailabilityListenerTest.java46 private final TestScheduledExecutorService scheduledExecutorService = field in AvailabilityListenerTest
49 TestProfileConnector.create(context, scheduledExecutorService);
51 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
DCrossProfileInterfaceTest.java52 private final TestScheduledExecutorService scheduledExecutorService = field in CrossProfileInterfaceTest
55 TestProfileConnector.create(context, scheduledExecutorService);
57 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
/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()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpChannelBuilder.java152 private ScheduledExecutorService scheduledExecutorService; field in OkHttpChannelBuilder
388 public final OkHttpChannelBuilder scheduledExecutorService( in scheduledExecutorService() method in OkHttpChannelBuilder
389 ScheduledExecutorService scheduledExecutorService) { in scheduledExecutorService() argument
390 this.scheduledExecutorService = in scheduledExecutorService()
391 checkNotNull(scheduledExecutorService, "scheduledExecutorService"); in scheduledExecutorService()
399 return new OkHttpTransportFactory(transportExecutor, scheduledExecutorService, in buildTransportFactory()

123