| /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 …]
|
| D | FakeClock.java | 51 private final ScheduledExecutorService scheduledExecutorService = new ScheduledExecutorImpl(); field in FakeClock
194 return scheduledExecutorService; in getScheduledExecutorService()
|
| D | RetriableStreamTest.java | 132 ScheduledExecutorService scheduledExecutorService, in RecordedRetriableStream() argument
138 scheduledExecutorService, in RecordedRetriableStream()
|
| /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/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/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpChannelBuilder.java | 152 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()
|
| /external/grpc-grpc-java/android/src/main/java/io/grpc/android/ |
| D | AndroidChannelBuilder.java | 156 public AndroidChannelBuilder scheduledExecutorService( in scheduledExecutorService() method in AndroidChannelBuilder
157 ScheduledExecutorService scheduledExecutorService) { in scheduledExecutorService() argument
161 .invoke(delegateBuilder, scheduledExecutorService); in scheduledExecutorService()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | RetriableStream.java | 64 private final ScheduledExecutorService scheduledExecutorService; field in RetriableStream
100 Executor callExecutor, ScheduledExecutorService scheduledExecutorService, in RetriableStream() argument
108 this.scheduledExecutorService = scheduledExecutorService; in RetriableStream()
597 scheduledRetry = scheduledExecutorService.schedule( in closed()
|
| /external/grpc-grpc-java/android/ |
| D | proguard-rules.txt | 3 …io.grpc.okhttp.OkHttpChannelBuilder scheduledExecutorService(java.util.concurrent.ScheduledExecuto…
|
| /external/grpc-grpc-java/android/src/test/java/io/grpc/android/ |
| D | AndroidChannelBuilderTest.java | 120 public void scheduledExecutorService() { in scheduledExecutorService() method in AndroidChannelBuilderTest
121 AndroidChannelBuilder.forTarget("target").scheduledExecutorService(new ScheduledExecutorImpl()); in scheduledExecutorService()
|