Home
last modified time | relevance | path

Searched full:deadline (Results 1 – 25 of 3912) sorted by relevance

12345678910>>...157

/aosp_15_r20/external/grpc-grpc-java/context/src/test/java/io/grpc/
H A DDeadlineTest.java21 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 …]
/aosp_15_r20/external/googleapis/google/ads/googleads/v14/
H A Dgoogleads_v14.yaml133 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 …]
/aosp_15_r20/external/grpc-grpc-java/context/src/main/java/io/grpc/
H A DDeadline.java26 * 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 …]
/aosp_15_r20/prebuilts/tools/common/m2/repository/io/grpc/grpc-context/1.0.3/
HDgrpc-context-1.0.3.jar ... io.grpc.Context parent io.grpc.Deadline deadline java.util.concurrent.ScheduledExecutorService scheduler public ...
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/
H A Dquic_alarm_test.cc70 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 …]
H A Dquic_ping_manager_test.cc65 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 …]
/aosp_15_r20/external/cronet/net/quic/
H A Dquic_chromium_alarm_factory_test.cc42 // 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 …]
/aosp_15_r20/external/grpc-grpc/src/core/ext/filters/deadline/
H A Ddeadline_filter.cc19 #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 …]
/aosp_15_r20/prebuilts/tools/common/google-api-java-client/1.31.3/libs/
HDgrpc-context-1.27.2.jarMETA-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...
/aosp_15_r20/prebuilts/tools/common/google-api-java-client/1.33.2/libs/
HDgrpc-context-1.27.2.jarMETA-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc19 #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 …]
/aosp_15_r20/external/cronet/base/threading/
H A Dhang_watcher.h83 // 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
291 base::TimeTicks deadline; member
303 // 1. If any deadline in |watch_states| is before
324 // Return the highest deadline included in this snapshot. Can only be called
419 // Threadsafe class that manages a deadline of type TimeTicks alongside hang
421 // underlying TimeTicks deadline. This enables setting the flags on thread T1 in
422 // a way that's resilient to concurrent deadline or flag changes from thread T2.
423 // Flags can be queried separately from the deadline and users of this class
[all …]
/aosp_15_r20/external/pigweed/pw_sync/
H A Dbinary_semaphore_facade_test.cc38 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 …]
H A Dcounting_semaphore_facade_test.cc44 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 …]
/aosp_15_r20/external/grpc-grpc/src/ruby/spec/generic/
H A Dactive_call_spec.rb61 @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 …]
/aosp_15_r20/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
H A D_server.py70 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 …]
/aosp_15_r20/packages/services/Car/tests/BugReportApp/libs/
Dgrpc-context-1.19.0.jar ... abstract int size () } io/grpc/Deadline$SystemTicker.class Deadline.java package io.
/aosp_15_r20/external/grpc-grpc/src/php/tests/unit_tests/
H A DEndToEndTest.php43 $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 …]
/aosp_15_r20/external/python/python-api-core/google/api_core/
Dretry.py19 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 …]
Dretry_async.py49 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 …]
Dtimeout.py64 # 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 …]
/aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/context/grpc-java-context/android_common_apex33/javac/
Dgrpc-java-context.jar ... Deadline deadline private void setUpDeadlineCancellation (io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService) io ...
/aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/context/grpc-java-context/android_common_apex10000/javac/
Dgrpc-java-context.jar ... Deadline deadline private void setUpDeadlineCancellation (io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService) io ...
/aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/context/grpc-java-context/android_common_apex34/javac/
Dgrpc-java-context.jar ... Deadline deadline private void setUpDeadlineCancellation (io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService) io ...
/aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/context/grpc-java-context/android_common_apex30/javac/
Dgrpc-java-context.jar ... Deadline deadline private void setUpDeadlineCancellation (io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService) io ...

12345678910>>...157