| /third_party/grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _server.py | 70 invocation_metadata, deadline): argument
76 rpc, self._time, deadline)
86 invocation_metadata, request, deadline): argument
88 invocation_metadata, deadline)
91 invocation_metadata, request, deadline): argument
93 invocation_metadata, deadline)
96 invocation_metadata, deadline): argument
98 invocation_metadata, deadline)
101 invocation_metadata, deadline): argument
103 handler, invocation_metadata, deadline)
[all …]
|
| /third_party/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 …]
|
| /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 …]
|
| /third_party/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);
194 $deadline = Grpc\Timeval::infFuture();
201 $deadline);
213 $deadline = Grpc\Timeval::infFuture();
220 $deadline);
[all …]
|
| /third_party/grpc/include/grpcpp/ |
| D | alarm_impl.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);
|
| 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);
|
| /third_party/grpc/src/ruby/spec/generic/ |
| D | active_call_spec.rb | 61 @server.shutdown_and_notify(deadline)
71 @pass_through, deadline)
114 @pass_through, deadline)
125 @pass_through, deadline,
139 client_call = ActiveCall.new(call, marshal, @pass_through, deadline)
151 @pass_through, deadline,
166 @pass_through, deadline)
181 @pass_through, deadline,
198 deadline,
227 deadline)
[all …]
|
| /third_party/wayland_standard/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 …]
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_timer.cc | 76 for (grpc_millis deadline = start; deadline != end; deadline += increment) { in BM_TimerBatch() local
77 TimerClosure* timer_closure = &timer_closures[deadline % kTimerCount]; in BM_TimerBatch()
82 grpc_timer_init(&timer_closure->timer, deadline, &timer_closure->closure); in BM_TimerBatch()
88 for (grpc_millis deadline = start; deadline != end; deadline += increment) { in BM_TimerBatch() local
89 TimerClosure* timer_closure = &timer_closures[deadline % kTimerCount]; in BM_TimerBatch()
|
| D | bm_cq_multiple_threads.cc | 73 grpc_millis deadline) { in pollset_work() argument
74 if (deadline == 0) { in pollset_work()
129 gpr_timespec deadline = gpr_time_0(GPR_CLOCK_MONOTONIC); in teardown() local
130 while (grpc_completion_queue_next(g_cq, deadline, nullptr).type != in teardown()
160 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_Cq_Throughput() local
171 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
181 GPR_ASSERT(grpc_completion_queue_next(g_cq, deadline, nullptr).type == in BM_Cq_Throughput()
194 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/ |
| D | CallOptions.cs | 32 DateTime? deadline; field
48 …public CallOptions(Metadata headers = null, DateTime? deadline = null, CancellationToken cancellat… in CallOptions()
52 this.deadline = deadline; in CallOptions()
73 get { return deadline; }
149 public CallOptions WithDeadline(DateTime deadline) in WithDeadline()
152 newOptions.deadline = deadline; in WithDeadline()
|
| /third_party/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 …]
|
| /third_party/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 …onToken1 = new ContextPropagationTokenImpl(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 …r propagationToken2 = new ContextPropagationTokenImpl(CallSafeHandle.NullInstance, deadline, token, in Normalize()
|
| /third_party/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()
91 gpr_timespec deadline; in grpc_rb_server_free_internal() local
97 deadline = gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in grpc_rb_server_free_internal()
100 grpc_rb_server_maybe_shutdown_and_notify(svr, deadline); in grpc_rb_server_free_internal()
206 gpr_timespec deadline; in grpc_rb_server_request_call() local
235 deadline = gpr_convert_clock_type(st.details.deadline, GPR_CLOCK_REALTIME); in grpc_rb_server_request_call()
239 rb_funcall(rb_cTime, id_at, 2, INT2NUM(deadline.tv_sec), in grpc_rb_server_request_call()
240 INT2NUM(deadline.tv_nsec / 1000)), in grpc_rb_server_request_call()
261 gpr_timespec deadline; in grpc_rb_server_shutdown_and_notify() local
[all …]
|
| D | rb_completion_queue.c | 44 gpr_timespec deadline; in grpc_rb_completion_queue_pluck_no_gil() local
46 deadline = gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), increment); in grpc_rb_completion_queue_pluck_no_gil()
48 next_call->cq, next_call->tag, deadline, NULL); in grpc_rb_completion_queue_pluck_no_gil()
50 gpr_time_cmp(deadline, next_call->timeout) > 0) { in grpc_rb_completion_queue_pluck_no_gil()
75 gpr_timespec deadline, void* reserved) { in rb_completion_queue_pluck() argument
79 next_call.timeout = deadline; in rb_completion_queue_pluck()
|
| /third_party/grpc/src/cpp/common/ |
| D | alarm.cc | 50 void Set(::grpc::CompletionQueue* cq, gpr_timespec deadline, void* tag) { in Set() argument
74 grpc_timer_init(&timer_, grpc_timespec_to_millis_round_up(deadline), in Set()
77 void Set(gpr_timespec deadline, std::function<void(bool)> f) { in Set() argument
97 grpc_timer_init(&timer_, grpc_timespec_to_millis_round_up(deadline), in Set()
135 void Alarm::SetInternal(::grpc::CompletionQueue* cq, gpr_timespec deadline, in SetInternal() argument
142 static_cast<internal::AlarmImpl*>(alarm_)->Set(cq, deadline, tag); in SetInternal()
145 void Alarm::SetInternal(gpr_timespec deadline, std::function<void(bool)> f) { in SetInternal() argument
151 static_cast<internal::AlarmImpl*>(alarm_)->Set(deadline, std::move(f)); in SetInternal()
|
| /third_party/grpc/src/csharp/Grpc.Core.Testing/ |
| D | TestServerCallContext.cs | 34 …public static ServerCallContext Create(string method, string host, DateTime deadline, Metadata req… in Create() argument
38 …return new TestingServerCallContext(method, host, deadline, requestHeaders, cancellationToken, pee… in Create()
46 private readonly DateTime deadline; field in Grpc.Core.Testing.TestServerCallContext.TestingServerCallContext
58 …public TestingServerCallContext(string method, string host, DateTime deadline, Metadata requestHea… in TestingServerCallContext() argument
64 this.deadline = deadline; in TestingServerCallContext()
83 protected override DateTime DeadlineCore => deadline;
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | timer_heap.cc | 39 if (first[parent]->deadline <= t->deadline) break; in adjust_upwards()
57 uint32_t next_i = right_child < length && first[left_child]->deadline > in adjust_downwards()
58 first[right_child]->deadline in adjust_downwards()
61 if (t->deadline <= first[next_i]->deadline) break; in adjust_downwards()
85 if (heap->timers[parent]->deadline > timer->deadline) { in note_changed_priority()
|
| D | iocp_windows.cc | 46 static DWORD deadline_to_millis_timeout(grpc_millis deadline) { in deadline_to_millis_timeout() argument
47 if (deadline == GRPC_MILLIS_INF_FUTURE) { in deadline_to_millis_timeout()
51 if (deadline < now) return 0; in deadline_to_millis_timeout()
52 grpc_millis timeout = deadline - now; in deadline_to_millis_timeout()
54 return static_cast<DWORD>(deadline - now); in deadline_to_millis_timeout()
57 grpc_iocp_work_status grpc_iocp_work(grpc_millis deadline) { in grpc_iocp_work() argument
68 deadline_to_millis_timeout(deadline)); in grpc_iocp_work()
|
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | DefaultServerCallContext.cs | 35 private readonly DateTime deadline; field in Grpc.Core.DefaultServerCallContext
48 … DefaultServerCallContext(CallSafeHandle callHandle, string method, string host, DateTime deadline, in DefaultServerCallContext() argument
54 this.deadline = deadline; in DefaultServerCallContext()
64 … return new ContextPropagationTokenImpl(callHandle, deadline, cancellationToken, options); in CreatePropagationTokenCore()
78 protected override DateTime DeadlineCore => deadline;
|
| D | ServerRpcNew.cs | 33 readonly Timespec deadline; field
36 …erver server, CallSafeHandle call, string method, string host, Timespec deadline, Metadata request… in ServerRpcNew()
42 this.deadline = deadline; in ServerRpcNew()
82 return this.deadline;
|
| D | ContextPropagationTokenImpl.cs | 49 readonly DateTime deadline; field in Grpc.Core.Internal.ContextPropagationTokenImpl
53 …internal ContextPropagationTokenImpl(CallSafeHandle parentCall, DateTime deadline, CancellationTok… in ContextPropagationTokenImpl() argument
56 this.deadline = deadline; in ContextPropagationTokenImpl()
79 return this.deadline;
|
| /third_party/grpc/src/cpp/util/ |
| D | time_cc.cc | 33 system_clock::duration deadline = from.time_since_epoch(); in Timepoint2Timespec() local
34 seconds secs = duration_cast<seconds>(deadline); in Timepoint2Timespec()
41 nanoseconds nsecs = duration_cast<nanoseconds>(deadline - secs); in Timepoint2Timespec()
49 high_resolution_clock::duration deadline = from.time_since_epoch(); in TimepointHR2Timespec() local
50 seconds secs = duration_cast<seconds>(deadline); in TimepointHR2Timespec()
57 nanoseconds nsecs = duration_cast<nanoseconds>(deadline - secs); in TimepointHR2Timespec()
|
| /third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | TestGrpc.cs | 275 ….Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in EmptyCall() argument
277 return EmptyCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCall()
297 ….Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in EmptyCallAsync() argument
299 return EmptyCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCallAsync()
319 …equest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in UnaryCall() argument
321 return UnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCall()
341 …equest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in UnaryCallAsync() argument
343 return UnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCallAsync()
365 …equest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::S… in CacheableUnaryCall() argument
367 … return CacheableUnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CacheableUnaryCall()
[all …]
|
| /third_party/grpc/src/php/tests/MemoryLeakTest/ |
| D | MemoryLeakTest.php | 40 $deadline = $now->add(new Grpc\Timeval(10000));
42 $deadline)) {
70 $deadline = $now->add(new Grpc\Timeval(100*1000)); variable
72 $state = $channel->watchConnectivityState(1, $deadline);
76 unset($deadline);
|