/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
D | InProcessChannelBuilder.java | 69 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()
|
D | InProcessServerBuilder.java | 119 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/ |
D | FakeClockTest.java | 130 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/ |
D | AbstractProfileConnector.java | 40 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()
|
D | CrossProfileSender.java | 227 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 …]
|
D | AbstractUserConnector.java | 100 @Nullable ScheduledExecutorService scheduledExecutorService; field in AbstractUserConnector.Builder 111 public Builder setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService) { in setScheduledExecutorService() argument 112 this.scheduledExecutorService = scheduledExecutorService; in setScheduledExecutorService()
|
D | CrossUserConnector.java | 46 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/ |
D | OtherProfileListenableFutureTest.java | 58 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 …]
|
D | OtherProfileAsyncTest.java | 70 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()
|
D | ProviderTest.java | 36 private final TestScheduledExecutorService scheduledExecutorService = field in ProviderTest 40 TestProfileConnector.create(context, scheduledExecutorService); 42 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
|
D | ManualConnectionManagementTest.java | 42 private final TestScheduledExecutorService scheduledExecutorService = field in ManualConnectionManagementTest 45 TestProfileConnector.create(context, scheduledExecutorService); 47 new RobolectricTestUtilities(testProfileConnector, scheduledExecutorService);
|
D | CrossUserTest.java | 46 private final TestScheduledExecutorService scheduledExecutorService = field in CrossUserTest 49 TestCrossUserConnector.create(context, scheduledExecutorService); 51 new RobolectricTestUtilities(testCrossUserConnector, scheduledExecutorService);
|
D | CrossProfileInterfaceTest.java | 52 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/ |
D | InProcessServerBuilderTest.java | 75 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()
|
D | InProcessChannelBuilderTest.java | 51 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/ |
D | CrossProfileSenderTest.java | 56 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()
|
D | RobolectricTestUtilities.java | 77 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()
|
D | PermissionsTest.java | 38 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/ |
D | CronetChannelBuilder.java | 78 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/ |
D | CronetChannelBuilderTest.java | 100 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/ |
D | OkHttpChannelBuilderTest.java | 152 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/ |
D | AndroidConnectivityHandler.java | 58 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/ |
D | TestProfileConnectorWithCustomServiceClass.java | 28 Context context, ScheduledExecutorService scheduledExecutorService) { in create() argument 30 .setScheduledExecutorService(scheduledExecutorService) in create()
|
D | DirectBootAwareConnector.java | 33 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/ |
D | TestCrossUserConnector.java | 33 Context context, ScheduledExecutorService scheduledExecutorService) { in create() argument 35 .setScheduledExecutorService(scheduledExecutorService) in create()
|