| /external/grpc-grpc-java/context/src/test/java/io/grpc/ |
| D | DeadlineTest.java | 64 Deadline d = Deadline.after(0, TimeUnit.SECONDS); in defaultTickerIsSystemTicker()
66 Deadline reference = Deadline.after(0, TimeUnit.SECONDS, ticker); in defaultTickerIsSystemTicker()
74 Deadline d = Deadline.after(10, TimeUnit.DAYS, ticker); in timeCanOverflow()
76 assertTrue(Deadline.after(0, TimeUnit.DAYS, ticker).isBefore(d)); in timeCanOverflow()
86 Deadline d = Deadline.after(-10, TimeUnit.DAYS, ticker); in timeCanUnderflow()
88 assertTrue(d.isBefore(Deadline.after(0, TimeUnit.DAYS, ticker))); in timeCanUnderflow()
94 Deadline d = Deadline.after(-300 * 365, TimeUnit.DAYS, ticker); in deadlineClamps()
95 Deadline d2 = Deadline.after(300 * 365, TimeUnit.DAYS, ticker); in deadlineClamps()
98 Deadline d3 = Deadline.after(-200 * 365, TimeUnit.DAYS, ticker); in deadlineClamps()
106 Deadline deadline = Deadline.after(0, TimeUnit.SECONDS, ticker); in immediateDeadlineIsExpired()
[all …]
|
| D | ContextTest.java | 592 final Deadline sooner = Deadline.after(100, TimeUnit.MILLISECONDS); in earlierParentDeadlineTakesPrecedenceOverLaterChildDeadline()
593 final Deadline later = Deadline.after(1, TimeUnit.MINUTES); in earlierParentDeadlineTakesPrecedenceOverLaterChildDeadline()
620 Deadline sooner = Deadline.after(1, TimeUnit.HOURS); in earlierChldDeadlineTakesPrecedenceOverLaterParentDeadline()
621 Deadline later = Deadline.after(1, TimeUnit.DAYS); in earlierChldDeadlineTakesPrecedenceOverLaterParentDeadline()
630 Deadline deadline = Deadline.after(1, TimeUnit.HOURS); in forkingContextDoesNotCarryDeadline()
638 Deadline deadline = Deadline.after(1, TimeUnit.HOURS); in cancellationDoesNotExpireDeadline()
646 Context base = Context.current().withDeadline(Deadline.after(1, TimeUnit.SECONDS), scheduler); in absoluteDeadlineTriggersAndPropagates()
661 Context base = Context.current().withDeadline(Deadline.after(1, TimeUnit.SECONDS), scheduler); in relativeDeadlineTriggersAndPropagates()
676 Context base = Context.current().withDeadline(Deadline.after(2, TimeUnit.SECONDS), scheduler); in innerDeadlineCompletesBeforeOuter()
677 Context child = base.withDeadline(Deadline.after(1, TimeUnit.SECONDS), scheduler); in innerDeadlineCompletesBeforeOuter()
[all …]
|
| /external/grpc-grpc-java/context/src/main/java/io/grpc/ |
| D | Deadline.java | 33 public final class Deadline implements Comparable<Deadline> { class
46 public static Deadline after(long duration, TimeUnit units) { in after()
51 static Deadline after(long duration, TimeUnit units, Ticker ticker) { in after()
53 return new Deadline(ticker, units.toNanos(duration), true); in after()
60 private Deadline(Ticker ticker, long offset, boolean baseInstantAlreadyExpired) { in Deadline() method in Deadline
64 private Deadline(Ticker ticker, long baseInstant, long offset, in Deadline() method in Deadline
91 public boolean isBefore(Deadline other) { in isBefore()
99 public Deadline minimum(Deadline other) { in minimum()
109 public Deadline offset(long offset, TimeUnit units) { in offset()
114 return new Deadline(ticker, deadlineNanos, units.toNanos(offset), isExpired()); in offset()
[all …]
|
| D | Context.java | 271 return withDeadline(Deadline.after(duration, unit), scheduler); in withDeadlineAfter()
299 public CancellableContext withDeadline(Deadline deadline, in withDeadline()
450 public Deadline getDeadline() { in getDeadline()
695 private final Deadline deadline;
716 private CancellableContext(Context parent, Deadline deadline,
719 Deadline parentDeadline = parent.getDeadline();
842 public Deadline getDeadline() {
|
| /external/grpc-grpc-java/context/src/test/java/io/grpc/testing/ |
| D | DeadlineSubject.java | 27 import io.grpc.Deadline;
36 public final class DeadlineSubject extends ComparableSubject<DeadlineSubject, Deadline> {
37 private static final Subject.Factory<DeadlineSubject, Deadline> deadlineFactory =
40 public static Subject.Factory<DeadlineSubject, Deadline> deadline() { in deadline()
44 private DeadlineSubject(FailureMetadata metadata, Deadline subject) { in DeadlineSubject()
56 public void of(Deadline expected) { in isWithin()
57 Deadline actual = actual(); in isWithin()
91 public abstract void of(Deadline expectedDeadline);
124 private static final class Factory implements Subject.Factory<DeadlineSubject, Deadline> {
126 public DeadlineSubject createSubject(FailureMetadata metadata, Deadline that) {
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | CallOptionsTest.java | 47 private final Deadline.Ticker ticker = new FakeTicker();
48 private final Deadline sampleDeadline = Deadline.after(1, NANOSECONDS, ticker);
100 allSet.withDeadline(Deadline.after(314, NANOSECONDS)).withDeadline(sampleDeadline))) in noStrayModifications()
111 Deadline deadline = Deadline.after(10, SECONDS); in mutation()
135 Deadline actual = CallOptions.DEFAULT.withDeadlineAfter(1, MINUTES).getDeadline(); in withDeadlineAfter()
136 Deadline expected = Deadline.after(1, MINUTES); in withDeadlineAfter()
234 private static class FakeTicker extends Deadline.Ticker {
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ClientCallImpl.java | 41 import io.grpc.Deadline;
233 Deadline effectiveDeadline = effectiveDeadline(); in start()
297 Deadline effectiveDeadline, @Nullable Deadline outerCallDeadline, in logIfContextNarrowedTimeout()
298 @Nullable Deadline callDeadline) { in logIfContextNarrowedTimeout()
341 private ScheduledFuture<?> startDeadlineTimer(Deadline deadline) { in startDeadlineTimer()
349 private Deadline effectiveDeadline() { in effectiveDeadline()
355 private static Deadline min(@Nullable Deadline deadline0, @Nullable Deadline deadline1) { in min()
560 Deadline deadline = effectiveDeadline(); in closed()
|
| D | ClientStream.java | 20 import io.grpc.Deadline;
94 void setDeadline(@Nonnull Deadline deadline); in setDeadline()
|
| D | NoopClientStream.java | 21 import io.grpc.Deadline;
85 public void setDeadline(@Nonnull Deadline deadline) {} in setDeadline()
|
| D | ForwardingClientStream.java | 22 import io.grpc.Deadline;
101 public void setDeadline(Deadline deadline) { in setDeadline()
|
| D | ServiceConfigInterceptor.java | 31 import io.grpc.Deadline;
366 Deadline newDeadline = Deadline.after(info.timeoutNanos, TimeUnit.NANOSECONDS); in interceptCall()
367 Deadline existingDeadline = callOptions.getDeadline(); in interceptCall()
|
| /external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/ |
| D | SafeMethodCachingInterceptor.java | 11 import io.grpc.Deadline;
69 private final Deadline maxAgeDeadline;
71 public Value(MessageLite response, Deadline maxAgeDeadline) { in Value()
185 private Deadline deadline;
219 deadline = Deadline.after(maxAge, TimeUnit.SECONDS);
221 deadline = Deadline.after(defaultMaxAge, TimeUnit.SECONDS);
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | CallOptionsTest.cs | 40 Assert.AreEqual(deadline, options.WithDeadline(deadline).Deadline.Value); in WithMethods()
60 Assert.IsNull(options.Deadline); in WithMethods()
72 Assert.AreEqual(DateTime.MaxValue, new CallOptions().Normalize().Deadline.Value); in Normalize()
77 …reEqual(deadline, new CallOptions(propagationToken: propagationToken1).Normalize().Deadline.Value); in Normalize()
|
| D | ContextPropagationTest.cs | 111 Assert.IsTrue(context.Deadline < deadline.AddMinutes(1)); in PropagateDeadline()
112 Assert.IsTrue(context.Deadline > deadline.AddMinutes(-1)); in PropagateDeadline()
140 Assert.AreEqual(DateTime.MaxValue, context.Deadline); in SuppressDeadlinePropagation()
|
| D | TimeoutsTest.cs | 62 Assert.AreEqual(DateTime.MaxValue, context.Deadline); in InfiniteDeadline()
83 … Assert.IsTrue(Math.Abs((clientDeadline - context.Deadline).TotalMilliseconds) < 5000); in DeadlineTransferredToServer()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/ |
| D | StubConfigTest.java | 31 import io.grpc.Deadline;
71 Deadline deadline = Deadline.after(2, NANOSECONDS); in testConfigureDeadline()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ClientCallImplTest.java | 49 import io.grpc.Deadline;
693 ArgumentCaptor<Deadline> deadlineCaptor = ArgumentCaptor.forClass(Deadline.class); in contextDeadlineShouldBePropagatedToStream()
718 ArgumentCaptor<Deadline> deadlineCaptor = ArgumentCaptor.forClass(Deadline.class); in contextDeadlineShouldOverrideLargerCallOptionsDeadline()
743 ArgumentCaptor<Deadline> deadlineCaptor = ArgumentCaptor.forClass(Deadline.class); in contextDeadlineShouldNotOverrideSmallerCallOptionsDeadline()
762 ArgumentCaptor<Deadline> deadlineCaptor = ArgumentCaptor.forClass(Deadline.class); in callOptionsDeadlineShouldBePropagatedToStream()
780 verify(stream, never()).setDeadline(any(Deadline.class)); in noDeadlineShouldBePropagatedToStream()
791 baseCallOptions.withDeadline(Deadline.after(1, TimeUnit.SECONDS)), in expiredDeadlineCancelsStream_CallOptions()
839 baseCallOptions.withDeadline(Deadline.after(1, TimeUnit.SECONDS)), in streamCancelAbortsDeadlineTimer()
|
| D | ServiceConfigInterceptorTest.java | 27 import io.grpc.Deadline;
245 Deadline existingDeadline = Deadline.after(1000, TimeUnit.NANOSECONDS); in nearerDeadlineKept_existing()
263 Deadline existingDeadline = Deadline.after(1234567890, TimeUnit.NANOSECONDS); in nearerDeadlineKept_new()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | ContextPropagationToken.cs | 47 & ~ContextPropagationFlags.Deadline & ~ContextPropagationFlags.Cancellation;
150 Deadline = 1, enumerator
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | CallOptions.java | 49 private Deadline deadline;
121 public CallOptions withDeadline(@Nullable Deadline deadline) { in withDeadline()
132 return withDeadline(Deadline.after(duration, unit)); in withDeadlineAfter()
139 public Deadline getDeadline() { in getDeadline()
|
| /external/syzkaller/vendor/golang.org/x/net/context/ |
| D | pre_go17.go | 20 func (*emptyCtx) Deadline() (deadline time.Time, ok bool) { func
205 if cur, ok := parent.Deadline(); ok && cur.Before(deadline) {
239 func (c *timerCtx) Deadline() (deadline time.Time, ok bool) { func
|
| D | pre_go19.go | 19 Deadline() (deadline time.Time, ok bool) methodSpec
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | CascadingTest.java | 29 import io.grpc.Deadline;
187 final SettableFuture<Deadline> finalDeadline = SettableFuture.create(); in testDeadlinePropagation()
215 Deadline initialDeadline = Deadline.after(1, TimeUnit.MINUTES); in testDeadlinePropagation()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | AbstractStub.java | 26 import io.grpc.Deadline;
113 public final S withDeadline(@Nullable Deadline deadline) { in withDeadline()
|
| /external/u-boot/doc/driver-model/ |
| D | MIGRATION.txt | 13 Deadline: 2018.05
30 Deadline: 2018.09
|