| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _server.py | 70 invocation_metadata, deadline): argument
76 rpc, self._time, deadline)
87 invocation_metadata, request, deadline): argument
90 invocation_metadata, deadline)
93 invocation_metadata, request, deadline): argument
96 invocation_metadata, deadline)
99 invocation_metadata, deadline): argument
102 invocation_metadata, deadline)
105 invocation_metadata, deadline): argument
108 invocation_metadata, deadline)
[all …]
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | sleep.rs | 21 pub fn sleep_until(deadline: Instant) -> Sleep { in sleep_until()
22 Sleep::new_timeout(deadline) in sleep_until()
62 Some(deadline) => sleep_until(deadline), in sleep()
160 deadline: Instant,
169 pub(crate) fn new_timeout(deadline: Instant) -> Sleep { in new_timeout()
171 let entry = TimerEntry::new(&handle, deadline); in new_timeout()
173 Sleep { deadline, entry } in new_timeout()
181 pub fn deadline(&self) -> Instant { in deadline() method
182 self.deadline in deadline()
219 pub fn reset(self: Pin<&mut Self>, deadline: Instant) { in reset()
[all …]
|
| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| D | client_stub.rb | 149 deadline: nil,
155 deadline: deadline,
226 deadline: nil,
232 deadline: deadline,
317 deadline: nil,
324 deadline: deadline,
439 deadline: nil,
446 deadline: deadline,
486 deadline: nil,
489 deadline = from_relative_time(@timeout) if deadline.nil?
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | mutex_nonprod.cc | 52 absl::Time LimitedDeadline(absl::Time deadline) { in LimitedDeadline() argument
53 deadline = std::max(absl::FromTimeT(0), deadline); in LimitedDeadline()
54 deadline = std::min(deadline, absl::FromTimeT(0x7fffffff)); in LimitedDeadline()
55 return deadline; in LimitedDeadline()
100 bool CondVarImpl::WaitWithDeadline(MutexImpl* mu, absl::Time deadline) { in WaitWithDeadline() argument
102 time_t when = ToTimeT(deadline); in WaitWithDeadline()
103 int64_t nanos = ToInt64Nanoseconds(deadline - absl::FromTimeT(when)); in WaitWithDeadline()
169 bool CondVarImpl::WaitWithDeadline(MutexImpl* mu, absl::Time deadline) { in WaitWithDeadline() argument
171 struct timespec ts = ToTimespec(deadline); in WaitWithDeadline()
188 bool MutexImpl::AwaitWithDeadline(const Condition& cond, absl::Time deadline) { in AwaitWithDeadline() argument
[all …]
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | mutex_nonprod.cc | 47 absl::Time LimitedDeadline(absl::Time deadline) { in LimitedDeadline() argument
48 deadline = std::max(absl::FromTimeT(0), deadline); in LimitedDeadline()
49 deadline = std::min(deadline, absl::FromTimeT(0x7fffffff)); in LimitedDeadline()
50 return deadline; in LimitedDeadline()
95 bool CondVarImpl::WaitWithDeadline(MutexImpl* mu, absl::Time deadline) { in WaitWithDeadline() argument
97 time_t when = ToTimeT(deadline); in WaitWithDeadline()
98 int64_t nanos = ToInt64Nanoseconds(deadline - absl::FromTimeT(when)); in WaitWithDeadline()
164 bool CondVarImpl::WaitWithDeadline(MutexImpl* mu, absl::Time deadline) { in WaitWithDeadline() argument
166 struct timespec ts = ToTimespec(deadline); in WaitWithDeadline()
183 bool MutexImpl::AwaitWithDeadline(const Condition& cond, absl::Time deadline) { in AwaitWithDeadline() argument
[all …]
|
| /external/abseil-cpp/absl/synchronization/internal/ |
| D | mutex_nonprod.cc | 47 absl::Time LimitedDeadline(absl::Time deadline) { in LimitedDeadline() argument
48 deadline = std::max(absl::FromTimeT(0), deadline); in LimitedDeadline()
49 deadline = std::min(deadline, absl::FromTimeT(0x7fffffff)); in LimitedDeadline()
50 return deadline; in LimitedDeadline()
95 bool CondVarImpl::WaitWithDeadline(MutexImpl* mu, absl::Time deadline) { in WaitWithDeadline() argument
97 time_t when = ToTimeT(deadline); in WaitWithDeadline()
98 int64_t nanos = ToInt64Nanoseconds(deadline - absl::FromTimeT(when)); in WaitWithDeadline()
164 bool CondVarImpl::WaitWithDeadline(MutexImpl* mu, absl::Time deadline) { in WaitWithDeadline() argument
166 struct timespec ts = ToTimespec(deadline); in WaitWithDeadline()
183 bool MutexImpl::AwaitWithDeadline(const Condition& cond, absl::Time deadline) { in AwaitWithDeadline() argument
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | CallOptions.cs | 33 DateTime? deadline; field
49 …public CallOptions(Metadata headers = null, DateTime? deadline = null, CancellationToken cancellat… in CallOptions()
53 this.deadline = deadline; in CallOptions()
74 get { return deadline; }
150 public CallOptions WithDeadline(DateTime deadline) in WithDeadline()
153 newOptions.deadline = deadline; in WithDeadline()
243 GrpcPreconditions.CheckArgument(!newOptions.deadline.HasValue, in Normalize()
245 newOptions.deadline = propagationToken.ParentDeadline; in Normalize()
256 newOptions.deadline = newOptions.deadline ?? DateTime.MaxValue; in Normalize()
|
| D | ServerCallContext.cs | 35 private readonly DateTime deadline; field in Grpc.Core.ServerCallContext
48 …Context(CallSafeHandle callHandle, string method, string host, DateTime deadline, Metadata request… in ServerCallContext() argument
50 …: this(callHandle, method, host, deadline, requestHeaders, cancellationToken, writeHeadersFunc, wr… in ServerCallContext()
55 …Context(CallSafeHandle callHandle, string method, string host, DateTime deadline, Metadata request… in ServerCallContext() argument
62 this.deadline = deadline; in ServerCallContext()
94 return new ContextPropagationToken(callHandle, deadline, cancellationToken, options); in CreatePropagationToken()
136 return this.deadline;
|
| /external/grpc-grpc/src/php/tests/unit_tests/ |
| D | EndToEndTest.php | 39 $deadline = Grpc\Timeval::infFuture();
43 $deadline);
87 $deadline = Grpc\Timeval::infFuture();
92 $deadline);
133 $deadline = Grpc\Timeval::infFuture();
140 $deadline);
196 $deadline = Grpc\Timeval::infFuture();
203 $deadline);
217 $deadline = Grpc\Timeval::infFuture();
224 $deadline);
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/ |
| D | alarm.h | 51 Alarm(::grpc::CompletionQueue* cq, const T& deadline, void* tag) : Alarm() { in Alarm() argument
52 SetInternal(cq, ::grpc::TimePoint<T>(deadline).raw_time(), tag); in Alarm()
60 void Set(::grpc::CompletionQueue* cq, const T& deadline, void* tag) { in Set() argument
61 SetInternal(cq, ::grpc::TimePoint<T>(deadline).raw_time(), tag); in Set()
85 void Set(const T& deadline, std::function<void(bool)> f) { in Set() argument
86 SetInternal(::grpc::TimePoint<T>(deadline).raw_time(), std::move(f)); in Set()
101 void Set(const T& deadline, std::function<void(bool)> f) { in Set() argument
102 alarm_->SetInternal(::grpc::TimePoint<T>(deadline).raw_time(), in Set()
116 void SetInternal(::grpc::CompletionQueue* cq, gpr_timespec deadline,
118 void SetInternal(gpr_timespec deadline, std::function<void(bool)> f);
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/ |
| D | alarm.h | 51 Alarm(::grpc::CompletionQueue* cq, const T& deadline, void* tag) : Alarm() { in Alarm() argument
52 SetInternal(cq, ::grpc::TimePoint<T>(deadline).raw_time(), tag); in Alarm()
60 void Set(::grpc::CompletionQueue* cq, const T& deadline, void* tag) { in Set() argument
61 SetInternal(cq, ::grpc::TimePoint<T>(deadline).raw_time(), tag); in Set()
85 void Set(const T& deadline, std::function<void(bool)> f) { in Set() argument
86 SetInternal(::grpc::TimePoint<T>(deadline).raw_time(), std::move(f)); in Set()
101 void Set(const T& deadline, std::function<void(bool)> f) { in Set() argument
102 alarm_->SetInternal(::grpc::TimePoint<T>(deadline).raw_time(), in Set()
116 void SetInternal(::grpc::CompletionQueue* cq, gpr_timespec deadline,
118 void SetInternal(gpr_timespec deadline, std::function<void(bool)> f);
|
| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | active_call_spec.rb | 51 @server.shutdown_and_notify(deadline)
60 @pass_through, deadline)
103 @pass_through, deadline)
114 @pass_through, deadline,
128 client_call = ActiveCall.new(call, marshal, @pass_through, deadline)
140 @pass_through, deadline,
155 @pass_through, deadline)
170 @pass_through, deadline,
187 deadline,
216 deadline)
[all …]
|
| /external/wayland/src/ |
| D | event-loop.c | 236 struct timespec deadline; member
260 set_timer(int timerfd, struct timespec deadline) { in set_timer() argument
265 its.it_value = deadline; in set_timer()
396 key = source->deadline; in heap_sift_down()
407 if (time_lt(other_child->deadline, child->deadline)) in heap_sift_down()
411 if (time_lt(child->deadline, key)) in heap_sift_down()
428 key = source->deadline; in heap_sift_up()
433 if (time_lt(key, parent->deadline)) in heap_sift_up()
453 source->deadline.tv_sec = 0; in wl_timer_heap_disarm()
454 source->deadline.tv_nsec = 0; in wl_timer_heap_disarm()
[all …]
|
| /external/pigweed/pw_sync/ |
| D | binary_semaphore_facade_test.cc | 102 const SystemClock::time_point deadline = in TEST() local
104 EXPECT_TRUE(semaphore.try_acquire_until(deadline)); in TEST()
105 EXPECT_LT(SystemClock::now(), deadline); in TEST()
108 EXPECT_FALSE(semaphore.try_acquire_until(deadline)); in TEST()
109 EXPECT_GE(SystemClock::now(), deadline); in TEST()
150 pw_chrono_SystemClock_TimePoint deadline; in TEST() local
151 deadline.duration_since_epoch = { in TEST()
156 pw_sync_BinarySemaphore_CallTryAcquireUntil(&semaphore, deadline)); in TEST()
158 deadline.duration_since_epoch.ticks); in TEST()
162 pw_sync_BinarySemaphore_CallTryAcquireUntil(&semaphore, deadline)); in TEST()
[all …]
|
| D | counting_semaphore_facade_test.cc | 120 const SystemClock::time_point deadline = in TEST() local
122 EXPECT_TRUE(semaphore.try_acquire_until(deadline)); in TEST()
123 EXPECT_LT(SystemClock::now(), deadline); in TEST()
126 EXPECT_FALSE(semaphore.try_acquire_until(deadline)); in TEST()
127 EXPECT_GE(SystemClock::now(), deadline); in TEST()
180 pw_chrono_SystemClock_TimePoint deadline; in TEST() local
181 deadline.duration_since_epoch = { in TEST()
186 pw_sync_CountingSemaphore_CallTryAcquireUntil(&semaphore, deadline)); in TEST()
188 deadline.duration_since_epoch.ticks); in TEST()
192 pw_sync_CountingSemaphore_CallTryAcquireUntil(&semaphore, deadline)); in TEST()
[all …]
|
| /external/grpc-grpc/include/grpcpp/ |
| D | alarm.h | 52 Alarm(CompletionQueue* cq, const T& deadline, void* tag) : Alarm() { in Alarm() argument
53 SetInternal(cq, TimePoint<T>(deadline).raw_time(), tag); in Alarm()
61 void Set(CompletionQueue* cq, const T& deadline, void* tag) { in Set() argument
62 SetInternal(cq, TimePoint<T>(deadline).raw_time(), tag); in Set()
92 void Set(const T& deadline, std::function<void(bool)> f) { in Set() argument
93 alarm_->SetInternal(TimePoint<T>(deadline).raw_time(), std::move(f)); in Set()
106 void SetInternal(CompletionQueue* cq, gpr_timespec deadline, void* tag);
107 void SetInternal(gpr_timespec deadline, std::function<void(bool)> f);
|
| /external/rust/crates/crossbeam-utils/src/sync/ |
| D | parker.rs | 141 pub fn park_deadline(&self, deadline: Instant) { in park_deadline()
142 self.unparker.inner.park(Some(deadline)) in park_deadline()
315 fn park(&self, deadline: Option<Instant>) { in park()
326 if let Some(deadline) = deadline { in park()
327 if deadline <= Instant::now() { in park()
353 m = match deadline { in park()
355 Some(deadline) => { in park()
357 if now < deadline { in park()
361 self.cvar.wait_timeout(m, deadline - now).unwrap().0 in park()
|
| /external/rust/crates/tokio/src/time/driver/wheel/ |
| D | mod.rs | 111 .map(|e| e.deadline >= self.elapsed) in insert()
141 self.next_expiration().map(|expiration| expiration.deadline) in poll_at()
153 if expiration.deadline > now { in poll()
161 Some(ref expiration) if expiration.deadline > now => return None, in poll()
165 self.set_elapsed(expiration.deadline); in poll()
188 deadline: self.elapsed, in next_expiration()
197 debug_assert!(self.no_expirations_before(level + 1, expiration.deadline)); in next_expiration()
209 self.next_expiration().map(|ex| ex.deadline) in next_expiration_time()
218 if e2.deadline < before { in no_expirations_before()
246 debug_assert_eq!(unsafe { item.cached_when() }, expiration.deadline); in process_expiration()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 41 TimerState(grpc_call_element* elem, grpc_millis deadline) : elem_(elem) { in TimerState() argument
46 grpc_timer_init(&timer_, deadline, &closure_); in TimerState()
116 grpc_millis deadline) { in start_timer_if_needed() argument
117 if (deadline == GRPC_MILLIS_INF_FUTURE) { in start_timer_if_needed()
124 deadline_state->arena->New<grpc_core::TimerState>(elem, deadline); in start_timer_if_needed()
162 start_timer_after_init_state(grpc_call_element* elem, grpc_millis deadline) in start_timer_after_init_state()
163 : elem(elem), deadline(deadline) {} in start_timer_after_init_state()
164 ~start_timer_after_init_state() { start_timer_if_needed(elem, deadline); } in ~start_timer_after_init_state()
168 grpc_millis deadline; member
192 grpc_millis deadline) in grpc_deadline_state() argument
[all …]
|
| /external/pigweed/pw_thread/ |
| D | sleep_facade_test.cc | 59 const SystemClock::time_point deadline = in TEST() local
61 sleep_until(deadline); in TEST()
62 EXPECT_GE(SystemClock::now(), deadline); in TEST()
80 pw_chrono_SystemClock_TimePoint deadline; in TEST() local
81 deadline.duration_since_epoch.ticks = in TEST()
84 pw_this_thread_CallSleepUntil(deadline); in TEST()
86 deadline.duration_since_epoch.ticks); in TEST()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | CallOptionsTest.cs | 39 var deadline = DateTime.UtcNow; in WithMethods()
40 Assert.AreEqual(deadline, options.WithDeadline(deadline).Deadline.Value); in WithMethods()
74 var deadline = DateTime.UtcNow; in Normalize()
75 …gationToken1 = new ContextPropagationToken(CallSafeHandle.NullInstance, deadline, CancellationToke… in Normalize()
77 …Assert.AreEqual(deadline, new CallOptions(propagationToken: propagationToken1).Normalize().Deadlin… in Normalize()
78 …Assert.Throws(typeof(ArgumentException), () => new CallOptions(deadline: deadline, propagationToke… in Normalize()
81 … var propagationToken2 = new ContextPropagationToken(CallSafeHandle.NullInstance, deadline, token, in Normalize()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | alarm.cc | 54 void Set(CompletionQueue* cq, gpr_timespec deadline, void* tag) { in Set() argument
71 grpc_timer_init(&timer_, grpc_timespec_to_millis_round_up(deadline), in Set()
74 void Set(gpr_timespec deadline, std::function<void(bool)> f) { in Set() argument
86 grpc_timer_init(&timer_, grpc_timespec_to_millis_round_up(deadline), in Set()
123 void Alarm::SetInternal(CompletionQueue* cq, gpr_timespec deadline, void* tag) { in SetInternal() argument
129 static_cast<internal::AlarmImpl*>(alarm_)->Set(cq, deadline, tag); in SetInternal()
132 void Alarm::SetInternal(gpr_timespec deadline, std::function<void(bool)> f) { in SetInternal() argument
138 static_cast<internal::AlarmImpl*>(alarm_)->Set(deadline, std::move(f)); in SetInternal()
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_server.c | 54 gpr_timespec deadline) { in grpc_rb_server_maybe_shutdown_and_notify() argument
61 ev = rb_completion_queue_pluck(server->queue, tag, deadline, NULL); in grpc_rb_server_maybe_shutdown_and_notify()
92 gpr_timespec deadline; in grpc_rb_server_free() local
98 deadline = gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in grpc_rb_server_free()
101 grpc_rb_server_maybe_shutdown_and_notify(svr, deadline); in grpc_rb_server_free()
202 gpr_timespec deadline; in grpc_rb_server_request_call() local
231 deadline = gpr_convert_clock_type(st.details.deadline, GPR_CLOCK_REALTIME); in grpc_rb_server_request_call()
235 rb_funcall(rb_cTime, id_at, 2, INT2NUM(deadline.tv_sec), in grpc_rb_server_request_call()
236 INT2NUM(deadline.tv_nsec / 1000)), in grpc_rb_server_request_call()
257 gpr_timespec deadline; in grpc_rb_server_shutdown_and_notify() local
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | TestGrpc.cs | 244 ….Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in EmptyCall() argument
246 return EmptyCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCall()
266 ….Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in EmptyCallAsync() argument
268 return EmptyCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCallAsync()
288 …equest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in UnaryCall() argument
290 return UnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCall()
310 …equest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in UnaryCallAsync() argument
312 return UnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCallAsync()
334 …equest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in CacheableUnaryCall() argument
336 … return CacheableUnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CacheableUnaryCall()
[all …]
|
| /external/libvpx/libvpx/test/ |
| D | codec_factory.h | 43 unsigned long deadline,
98 VP8Encoder(vpx_codec_enc_cfg_t cfg, unsigned long deadline, in VP8Encoder() argument
100 : Encoder(cfg, deadline, init_flags, stats) {} in VP8Encoder()
132 unsigned long deadline, in CreateEncoder() argument
136 return new VP8Encoder(cfg, deadline, init_flags, stats); in CreateEncoder()
139 (void)deadline; in CreateEncoder()
194 VP9Encoder(vpx_codec_enc_cfg_t cfg, unsigned long deadline, in VP9Encoder() argument
196 : Encoder(cfg, deadline, init_flags, stats) {} in VP9Encoder()
228 unsigned long deadline, in CreateEncoder() argument
232 return new VP9Encoder(cfg, deadline, init_flags, stats); in CreateEncoder()
[all …]
|