| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | AbstractStub.java | 123 public final S withDeadlineAfter(long duration, TimeUnit unit) { in withDeadlineAfter() method in AbstractStub
124 return build(channel, callOptions.withDeadlineAfter(duration, unit)); in withDeadlineAfter()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ClientCallImplTest.java | 656 CallOptions callOptions = baseCallOptions.withDeadlineAfter(0, TimeUnit.SECONDS); in deadlineExceededBeforeCallStarted()
678 .withDeadlineAfter(1000, TimeUnit.MILLISECONDS, deadlineCancellationExecutor); in contextDeadlineShouldBePropagatedToStream()
702 .withDeadlineAfter(1000, TimeUnit.MILLISECONDS, deadlineCancellationExecutor); in contextDeadlineShouldOverrideLargerCallOptionsDeadline()
705 CallOptions callOpts = baseCallOptions.withDeadlineAfter(2000, TimeUnit.MILLISECONDS); in contextDeadlineShouldOverrideLargerCallOptionsDeadline()
727 .withDeadlineAfter(2000, TimeUnit.MILLISECONDS, deadlineCancellationExecutor); in contextDeadlineShouldNotOverrideSmallerCallOptionsDeadline()
730 CallOptions callOpts = baseCallOptions.withDeadlineAfter(1000, TimeUnit.MILLISECONDS); in contextDeadlineShouldNotOverrideSmallerCallOptionsDeadline()
751 CallOptions callOpts = baseCallOptions.withDeadlineAfter(1000, TimeUnit.MILLISECONDS); in callOptionsDeadlineShouldBePropagatedToStream()
810 .withDeadlineAfter(1, TimeUnit.SECONDS, deadlineCancellationExecutor); in expiredDeadlineCancelsStream_Context()
|
| D | ManagedChannelImplTest.java | 302 channel.newCall(method, CallOptions.DEFAULT.withDeadlineAfter(0, TimeUnit.NANOSECONDS)); in immediateDeadlineExceeded()
2789 CallOptions.DEFAULT.withDeadlineAfter(5, TimeUnit.SECONDS)); in badServiceConfigIsRecoverable()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | CallOptionsTest.java | 134 public void withDeadlineAfter() { in withDeadlineAfter() method in CallOptionsTest
135 Deadline actual = CallOptions.DEFAULT.withDeadlineAfter(1, MINUTES).getDeadline(); in withDeadlineAfter()
|
| D | ClientInterceptorsTest.java | 217 final CallOptions initialCallOptions = CallOptions.DEFAULT.withDeadlineAfter(100, NANOSECONDS); in callOptions()
218 final CallOptions newCallOptions = initialCallOptions.withDeadlineAfter(300, NANOSECONDS); in callOptions()
|
| D | ContextsTest.java | 218 .withDeadlineAfter(100, TimeUnit.NANOSECONDS, fakeClock.getScheduledExecutorService()); in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/ |
| D | StubConfigTest.java | 90 stub = stub.withDeadlineAfter(2, NANOSECONDS); in testStubCallOptionsPopulatedToNewCall()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | AbstractInteropTest.java | 1054 blockingStub.withDeadlineAfter(configuredTimeoutMinutes, TimeUnit.MINUTES); in sendsTimeoutHeader()
1070 .withDeadlineAfter(10, TimeUnit.SECONDS) in deadlineNotExceeded()
1082 blockingStub.withDeadlineAfter(10, TimeUnit.MILLISECONDS); in deadlineExceeded()
1125 .withDeadlineAfter(30, TimeUnit.MILLISECONDS) in deadlineExceededServerStreaming()
1150 .withDeadlineAfter(-10, TimeUnit.SECONDS) in deadlineInPast()
1173 .withDeadlineAfter(-10, TimeUnit.SECONDS) in deadlineInPast()
1601 asyncStub.withDeadlineAfter(1, TimeUnit.MILLISECONDS); in timeoutOnSleepingServer()
1765 blockingStub.withDeadlineAfter(5, TimeUnit.SECONDS); in obtainRemoteClientAddr()
1775 blockingStub.withDeadlineAfter(5, TimeUnit.SECONDS); in obtainLocalClientAddr()
1785 blockingStub.withDeadlineAfter(5, TimeUnit.SECONDS); in assertX500SubjectDn()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | CallOptions.java | 131 public CallOptions withDeadlineAfter(long duration, TimeUnit unit) { in withDeadlineAfter() method in CallOptions
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | BinlogHelperTest.java | 932 .withDeadlineAfter(1, TimeUnit.SECONDS, Executors.newSingleThreadScheduledExecutor()) in serverDeadlineLogged()
990 CallOptions.DEFAULT.withDeadlineAfter(1, TimeUnit.SECONDS), in clientDeadlineLogged_deadlineSetViaCallOption()
1043 CallOptions.DEFAULT.withDeadlineAfter(1, TimeUnit.SECONDS), in clientDeadlineLogged_deadlineSetViaContext()
1295 CallOptions.DEFAULT.withDeadlineAfter(1, TimeUnit.SECONDS), in clientInterceptor_trailersOnlyResponseLogsPeerAddress()
|
| /external/grpc-grpc-java/context/src/main/java/io/grpc/ |
| D | Context.java | 269 public CancellableContext withDeadlineAfter(long duration, TimeUnit unit, in withDeadlineAfter() method in Context
|
| /external/grpc-grpc-java/context/src/test/java/io/grpc/ |
| D | ContextTest.java | 586 Context.ROOT.withDeadlineAfter(1, TimeUnit.SECONDS, scheduler); in contextWithDeadlineHasDeadline()
750 Context.CancellableContext context = parent.withDeadlineAfter(0, TimeUnit.SECONDS, scheduler); in expiredDeadlineShouldCancelContextImmediately()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerImpl.java | 508 Context.CancellableContext context = baseContext.withDeadlineAfter( in createContext()
|