| /external/grpc-grpc-java/context/src/test/java/io/grpc/ |
| D | DeadlineTest.java | 21 import static io.grpc.testing.DeadlineSubject.deadline;
66 Deadline d = Deadline.after(0, TimeUnit.SECONDS); in defaultTickerIsSystemTicker()
68 Deadline reference = Deadline.after(0, TimeUnit.SECONDS, ticker); in defaultTickerIsSystemTicker()
70 assertAbout(deadline()).that(d).isWithin(1, TimeUnit.SECONDS).of(reference); in defaultTickerIsSystemTicker()
75 Deadline d1 = Deadline.after(1, TimeUnit.MINUTES, ticker); in minimum()
76 Deadline d2 = Deadline.after(2, TimeUnit.MINUTES, ticker); in minimum()
77 Deadline d3 = Deadline.after(3, TimeUnit.MINUTES, ticker); in minimum()
88 Deadline d = Deadline.after(10, TimeUnit.DAYS, ticker); in timeCanOverflow()
90 assertTrue(Deadline.after(0, TimeUnit.DAYS, ticker).isBefore(d)); in timeCanOverflow()
100 Deadline d = Deadline.after(-10, TimeUnit.DAYS, ticker); in timeCanUnderflow()
[all …]
|
| /external/googleapis/google/ads/googleads/v14/ |
| D | googleads_v14.yaml | 133 deadline: 60.0
135 deadline: 600.0
137 deadline: 600.0
139 deadline: 60.0
141 deadline: 60.0
143 deadline: 60.0
145 deadline: 60.0
147 deadline: 60.0
149 deadline: 60.0
151 deadline: 60.0
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_alarm_test.cc | 70 QUICHE_DCHECK(deadline().IsInitialized()); in SetImpl()
75 QUICHE_DCHECK(!deadline().IsInitialized()); in CancelImpl()
117 QuicTime deadline = QuicTime::Zero() + QuicTime::Delta::FromSeconds(7); in TEST_F() local
118 alarm_.Set(deadline); in TEST_F()
121 EXPECT_EQ(deadline, alarm_.deadline()); in TEST_F()
125 QuicTime deadline = QuicTime::Zero() + QuicTime::Delta::FromSeconds(7); in TEST_F() local
126 alarm_.Set(deadline); in TEST_F()
130 EXPECT_EQ(QuicTime::Zero(), alarm_.deadline()); in TEST_F()
134 QuicTime deadline = QuicTime::Zero() + QuicTime::Delta::FromSeconds(7); in TEST_F() local
135 alarm_.Set(deadline); in TEST_F()
[all …]
|
| D | quic_ping_manager_test.cc | 65 alarm_->deadline() - clock_.ApproximateNow()); in TEST_F()
72 // Verify the deadline is set slightly less than 15 seconds in the future, in TEST_F()
76 alarm_->deadline() - clock_.ApproximateNow()); in TEST_F()
106 alarm_->deadline() - clock_.ApproximateNow()); in TEST_F()
113 // The deadline is set slightly less than 10 seconds in the future, because in TEST_F()
117 alarm_->deadline() - clock_.ApproximateNow()); in TEST_F()
149 alarm_->deadline() - clock_.ApproximateNow()); in TEST_F()
158 alarm_->deadline() - clock_.ApproximateNow()); in TEST_F()
170 alarm_->deadline() - clock_.ApproximateNow()); in TEST_F()
189 alarm_->deadline() - clock_.ApproximateNow()); in TEST_F()
[all …]
|
| D | quic_idle_network_detector_test.cc | 62 alarm_->deadline()); in TEST_F()
81 alarm_->deadline()); in TEST_F()
96 alarm_->deadline()); in TEST_F()
105 alarm_->deadline()); in TEST_F()
128 alarm_->deadline()); in TEST_F()
135 alarm_->deadline()); in TEST_F()
140 // Verify network deadline does not extend. in TEST_F()
142 alarm_->deadline()); in TEST_F()
158 const QuicTime deadline = alarm_->deadline(); in TEST_F() local
159 EXPECT_EQ(clock_.Now() + QuicTime::Delta::FromSeconds(30), deadline); in TEST_F()
[all …]
|
| /external/grpc-grpc-java/context/src/main/java/io/grpc/ |
| D | Deadline.java | 26 * An absolute point in time, generally for tracking when a task should be completed. A deadline is
32 * However, a timeout can be converted to a {@code Deadline} at the start of the operation and then
35 public final class Deadline implements Comparable<Deadline> { class
57 * Create a deadline that will expire at the specified offset based on the {@link #getSystemTicker
60 * <p>If the given offset is extraordinarily long, say 100 years, the actual deadline created
65 * @return A new deadline.
67 public static Deadline after(long duration, TimeUnit units) { in after()
72 * Create a deadline that will expire at the specified offset based on the given {@link Ticker}.
74 * <p>If the given offset is extraordinarily long, say 100 years, the actual deadline created
88 * @param ticker Where this deadline refer the current time
[all …]
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _server.py | 70 deadline, argument
78 rpc, self._time, deadline
91 self, method_descriptor, handler, invocation_metadata, request, deadline argument
98 deadline,
102 self, method_descriptor, handler, invocation_metadata, request, deadline argument
109 deadline,
113 self, method_descriptor, handler, invocation_metadata, deadline argument
120 deadline,
124 self, method_descriptor, handler, invocation_metadata, deadline argument
131 deadline,
[all …]
|
| /external/cronet/net/quic/ |
| D | quic_chromium_alarm_factory_test.cc | 42 // Set the deadline 1µs in the future. in TEST_F()
45 quic::QuicTime deadline = clock_.Now() + kDelta; in TEST_F() local
46 alarm->Set(deadline); in TEST_F()
48 EXPECT_EQ(alarm->deadline(), deadline); in TEST_F()
64 quic::QuicTime deadline = clock_.Now() + kDelta; in TEST_F() local
65 alarm->Set(deadline); in TEST_F()
67 EXPECT_EQ(alarm->deadline(), deadline); in TEST_F()
87 // Set the deadline 1µs in the future. in TEST_F()
90 quic::QuicTime deadline = clock_.Now() + kDelta; in TEST_F() local
91 alarm->Set(deadline); in TEST_F()
[all …]
|
| /external/googleapis/grafeas/v1/ |
| D | grafeas_v1.yaml | 20 deadline: 30.0
22 deadline: 30.0
24 deadline: 30.0
26 deadline: 30.0
28 deadline: 30.0
30 deadline: 30.0
32 deadline: 30.0
34 deadline: 30.0
36 deadline: 30.0
38 deadline: 30.0
[all …]
|
| /external/python/python-api-core/google/api_core/ |
| D | timeout.py | 64 # If specified, must be in seconds. If none, deadline is not used in the
107 def _exponential_timeout_generator(initial, maximum, multiplier, deadline): argument
114 deadline (float): The overall deadline across all invocations.
119 if deadline is not None:
121 seconds=deadline
134 # The remaining time before the deadline is reached.
156 deadline (Optional[float]): The overall deadline across all
158 timeout from pushing the overall execution time over the deadline.
161 be adjusted to accomodate an overall deadline.
169 deadline=_DEFAULT_DEADLINE, argument
[all …]
|
| D | retry_async.py | 49 my_retry = retry_async.AsyncRetry(deadline=60)
73 async def retry_target(target, predicate, sleep_generator, deadline, on_error=None): argument
87 deadline (float): How long to keep retrying the target. The last sleep
89 ``deadline`` (and not considerably beyond it).
98 google.api_core.RetryError: If the deadline is exceeded while retrying.
103 (datetime_helpers.utcnow() + datetime.timedelta(seconds=deadline))
104 if deadline
135 "Deadline of {:.1f}s exceeded while calling {}".format(
136 deadline, target
168 deadline (float): How long to keep retrying in seconds. The last sleep
[all …]
|
| D | retry.py | 19 used, the retry is limited by a `deadline`. The deadline is the maxmimum amount
52 my_retry = retry.Retry(deadline=60)
150 def retry_target(target, predicate, sleep_generator, deadline, on_error=None): argument
164 deadline (float): How long to keep retrying the target. The last sleep
166 ``deadline`` (and not considerably beyond it).
175 google.api_core.RetryError: If the deadline is exceeded while retrying.
179 if deadline is not None:
181 seconds=deadline
206 "Deadline of {:.1f}s exceeded while calling {}".format(
207 deadline, target
[all …]
|
| /external/pigweed/pw_sync/ |
| D | binary_semaphore_facade_test.cc | 38 pw_chrono_SystemClock_TimePoint deadline);
129 SystemClock::time_point deadline = in TEST() local
131 EXPECT_TRUE(semaphore.try_acquire_until(deadline)); in TEST()
132 EXPECT_LT(SystemClock::now(), deadline); in TEST()
139 SystemClock::time_point deadline = in TEST() local
141 EXPECT_FALSE(semaphore.try_acquire_until(deadline)); in TEST()
142 EXPECT_GE(SystemClock::now(), deadline); in TEST()
149 SystemClock::time_point deadline = in TEST() local
152 EXPECT_LT(SystemClock::now(), deadline); in TEST()
160 SystemClock::time_point deadline = in TEST() local
[all …]
|
| D | counting_semaphore_facade_test.cc | 44 pw_chrono_SystemClock_TimePoint deadline);
148 SystemClock::time_point deadline = in TEST() local
150 EXPECT_TRUE(semaphore.try_acquire_until(deadline)); in TEST()
151 EXPECT_LT(SystemClock::now(), deadline); in TEST()
158 SystemClock::time_point deadline = in TEST() local
160 EXPECT_FALSE(semaphore.try_acquire_until(deadline)); in TEST()
161 EXPECT_GE(SystemClock::now(), deadline); in TEST()
168 SystemClock::time_point deadline = in TEST() local
171 EXPECT_LT(SystemClock::now(), deadline); in TEST()
178 SystemClock::time_point deadline = in TEST() local
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 19 #include "src/core/ext/filters/deadline/deadline_filter.h"
47 // A fire-and-forget class representing a pending deadline timer.
51 TimerState(grpc_deadline_state* deadline_state, Timestamp deadline) in TimerState() argument
55 grpc_timer_init(&timer_, deadline, &closure_); in TimerState()
87 error = grpc_error_set_int(GRPC_ERROR_CREATE("Deadline Exceeded"), in TimerCallback()
95 "deadline exceeded -- sending cancel_stream op"); in TimerCallback()
120 // Starts the deadline timer.
124 grpc_core::Timestamp deadline) { in start_timer_if_needed() argument
125 if (deadline == grpc_core::Timestamp::InfFuture()) return; in start_timer_if_needed()
129 deadline); in start_timer_if_needed()
[all …]
|
| /external/googleapis/google/example/library/ |
| D | library_example_v1.yaml | 21 deadline: 10.0
23 deadline: 10.0
25 deadline: 10.0
27 deadline: 10.0
29 deadline: 10.0
31 deadline: 10.0
33 deadline: 10.0
35 deadline: 10.0
37 deadline: 10.0
39 deadline: 10.0
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 19 #include "src/core/ext/filters/deadline/deadline_filter.h"
50 // A fire-and-forget class representing a pending deadline timer.
54 TimerState(grpc_deadline_state* deadline_state, Timestamp deadline) in TimerState() argument
58 grpc_timer_init(&timer_, deadline, &closure_); in TimerState()
90 error = grpc_error_set_int(GRPC_ERROR_CREATE("Deadline Exceeded"), in TimerCallback()
98 "deadline exceeded -- sending cancel_stream op"); in TimerCallback()
123 // Starts the deadline timer.
127 grpc_core::Timestamp deadline) { in start_timer_if_needed() argument
128 if (deadline == grpc_core::Timestamp::InfFuture()) return; in start_timer_if_needed()
132 deadline); in start_timer_if_needed()
[all …]
|
| /external/grpc-grpc-java/context/src/testFixtures/java/io/grpc/testing/ |
| D | DeadlineSubject.java | 27 import io.grpc.Deadline;
32 /** Propositions for {@link Deadline} subjects. */
36 private static final Subject.Factory<DeadlineSubject, Deadline> deadlineFactory =
39 public static Subject.Factory<DeadlineSubject, Deadline> deadline() { in deadline() method in DeadlineSubject
43 private final Deadline actual;
46 private DeadlineSubject(FailureMetadata metadata, Deadline subject) { in DeadlineSubject()
52 * Prepares for a check that the subject is deadline within the given tolerance of an
59 public void of(Deadline expected) { in isWithin()
60 Deadline actual = DeadlineSubject.this.actual; in isWithin()
81 * A partially specified proposition about an approximate relationship to a {@code deadline}
[all …]
|
| /external/pigweed/pw_thread/ |
| D | sleep_facade_test.cc | 84 SystemClock::time_point deadline = in TEST() local
86 sleep_until(deadline); in TEST()
87 EXPECT_GE(SystemClock::now(), deadline); in TEST()
95 SystemClock::time_point deadline = in TEST() local
98 EXPECT_LT(SystemClock::now(), deadline); in TEST()
106 SystemClock::time_point deadline = in TEST() local
109 EXPECT_LT(SystemClock::now(), deadline); in TEST()
152 pw_chrono_SystemClock_TimePoint deadline; in TEST() local
153 deadline.duration_since_epoch.ticks = in TEST()
156 pw_this_thread_CallSleepUntil(deadline); in TEST()
[all …]
|
| /external/googleapis/google/cloud/automl/v1/ |
| D | automl_v1.yaml | 57 deadline: 5.0
59 deadline: 20.0
61 deadline: 20.0
63 deadline: 20.0
65 deadline: 20.0
67 deadline: 50.0
69 deadline: 50.0
71 deadline: 50.0
73 deadline: 20.0
75 deadline: 60.0
[all …]
|
| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | active_call_spec.rb | 61 @server.shutdown_and_notify(deadline)
71 @pass_through, deadline)
85 want = %w(cancelled?, deadline, each_remote_read, metadata, \
97 want = %w(cancelled?, deadline, metadata, shutdown, \
109 want = %w(deadline)
123 @pass_through, deadline)
134 @pass_through, deadline,
148 client_call = ActiveCall.new(call, marshal, @pass_through, deadline)
160 @pass_through, deadline,
175 @pass_through, deadline)
[all …]
|
| /external/grpc-grpc/src/php/tests/unit_tests/ |
| D | EndToEndTest.php | 43 $deadline = Grpc\Timeval::infFuture();
47 $deadline);
91 $deadline = Grpc\Timeval::infFuture();
96 $deadline);
137 $deadline = Grpc\Timeval::infFuture();
144 $deadline);
201 $deadline = Grpc\Timeval::infFuture();
208 $deadline);
220 $deadline = Grpc\Timeval::infFuture();
227 $deadline);
[all …]
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/deadline/ |
| D | DeadlineClient.java | 17 package io.grpc.examples.deadline;
38 * <p>This is based off the client in the helloworld example with some deadline logic added.
82 // The server takes 500ms to process the call, so setting a deadline further in the future we in main()
84 logger.info("Calling server with a generous deadline, expected to work"); in main()
85 client.greet("deadline client", 1000); in main()
87 // A smaller deadline will result in us getting a DEADLINE_EXCEEDED error. in main()
89 "Calling server with an unrealistic (300ms) deadline, expecting a DEADLINE_EXCEEDED"); in main()
90 client.greet("deadline client", 300); in main()
95 // an increased deadline we should get a successful response. in main()
96 logger.info("Calling server with propagation and a generous deadline, expected to work"); in main()
[all …]
|
| /external/cronet/base/threading/ |
| D | hang_watcher.h | 83 // Will be true if the object actually set a deadline and false if not.
89 // The deadline set by the previous WatchHangsInScope created on this
106 // HangWatchStates for deadline overruns. This happens at a regular interval on
290 base::TimeTicks deadline; member
302 // 1. If any deadline in |watch_states| is before
323 // Return the highest deadline included in this snapshot. Can only be called
418 // Threadsafe class that manages a deadline of type TimeTicks alongside hang
420 // underlying TimeTicks deadline. This enables setting the flags on thread T1 in
421 // a way that's resilient to concurrent deadline or flag changes from thread T2.
422 // Flags can be queried separately from the deadline and users of this class
[all …]
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | completion_queue.pyx.pxi | 18 cdef grpc_event _next(grpc_completion_queue *c_completion_queue, deadline) except *: argument
24 if deadline is None:
27 c_deadline = _timespec_from_time(deadline)
61 cdef grpc_event c_event = _next(latent_event_arg.c_completion_queue, latent_event_arg.deadline)
64 cdef _latent_event(grpc_completion_queue *c_completion_queue, object deadline): argument
69 latent_event_arg.deadline = deadline
103 def _internal_poll(self, deadline): argument
104 return self._interpret_event(_next(self.c_completion_queue, deadline))
108 def poll(self, deadline=None): argument
111 return g_gevent_threadpool.apply(CompletionQueue._internal_poll, (self, deadline))
[all …]
|