| /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/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/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/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/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/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/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/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 …]
|
| 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()
|
| /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/syzkaller/vendor/golang.org/x/net/context/ |
| D | pre_go17.go | 20 func (*emptyCtx) Deadline() (deadline time.Time, ok bool) {
204 func WithDeadline(parent Context, deadline time.Time) (Context, CancelFunc) {
205 if cur, ok := parent.Deadline(); ok && cur.Before(deadline) {
211 deadline: deadline,
214 d := deadline.Sub(time.Now())
236 deadline time.Time member
239 func (c *timerCtx) Deadline() (deadline time.Time, ok bool) {
240 return c.deadline, true
244 …return fmt.Sprintf("%v.WithDeadline(%s [%s])", c.cancelCtx.Context, c.deadline, c.deadline.Sub(tim…
|
| /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 …]
|
| /external/grpc-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()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_cq_multiple_threads.cc | 70 grpc_millis deadline) { in pollset_work() argument
71 if (deadline == 0) { in pollset_work()
122 gpr_timespec deadline = gpr_time_0(GPR_CLOCK_MONOTONIC); in teardown() local
123 while (grpc_completion_queue_next(g_cq, deadline, nullptr).type != in teardown()
153 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_Cq_Throughput() local
164 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
174 GPR_ASSERT(grpc_completion_queue_next(g_cq, deadline, nullptr).type == in BM_Cq_Throughput()
187 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | periodic_function.cc | 70 const int64 deadline = start + options_.startup_delay_micros; in RunLoop() local
71 options_.env->SleepForMicroseconds(deadline - start); in RunLoop()
85 const int64 deadline = begin + interval_micros_; in RunLoop() local
88 if (deadline > end) { in RunLoop()
91 << " to " << (deadline - end); in RunLoop()
93 options_.env->SleepForMicroseconds(deadline - end); in RunLoop()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | channel_interface.h | 67 void NotifyOnStateChange(grpc_connectivity_state last_observed, T deadline, in NotifyOnStateChange() argument
69 TimePoint<T> deadline_tp(deadline); in NotifyOnStateChange()
76 bool WaitForStateChange(grpc_connectivity_state last_observed, T deadline) { in WaitForStateChange() argument
77 TimePoint<T> deadline_tp(deadline); in WaitForStateChange()
83 bool WaitForConnected(T deadline) { in WaitForConnected() argument
86 if (!WaitForStateChange(state, deadline)) return false; in WaitForConnected()
118 gpr_timespec deadline,
121 gpr_timespec deadline) = 0;
|
| D | completion_queue.h | 188 NextStatus AsyncNext(void** tag, bool* ok, const T& deadline) { in AsyncNext() argument
189 TimePoint<T> deadline_tp(deadline); in AsyncNext()
207 NextStatus DoThenAsyncNext(F&& f, void** tag, bool* ok, const T& deadline) { in DoThenAsyncNext() argument
213 return AsyncNext(tag, ok, deadline); in DoThenAsyncNext()
295 NextStatus AsyncNextInternal(void** tag, bool* ok, gpr_timespec deadline);
300 auto deadline = in Pluck() local
303 cq_, tag, deadline, nullptr); in Pluck()
321 auto deadline = g_core_codegen_interface->gpr_time_0(GPR_CLOCK_REALTIME); in TryPluck() local
323 cq_, tag, deadline, nullptr); in TryPluck()
336 void TryPluck(internal::CompletionQueueTag* tag, gpr_timespec deadline) { in TryPluck() argument
[all …]
|
| /external/grpc-grpc/src/core/lib/http/ |
| D | httpcli.cc | 48 grpc_millis deadline; member
68 const char* host, grpc_millis deadline, in plaintext_handshake() argument
191 req->deadline, on_handshake_done); in on_connected()
213 &args, addr, req->deadline); in next_address()
230 grpc_millis deadline, grpc_closure* on_done, in internal_request_begin() argument
239 req->deadline = deadline; in internal_request_begin()
267 const grpc_httpcli_request* request, grpc_millis deadline, in grpc_httpcli_get() argument
270 if (g_get_override && g_get_override(request, deadline, on_done, response)) { in grpc_httpcli_get()
274 internal_request_begin(context, pollent, resource_quota, request, deadline, in grpc_httpcli_get()
285 grpc_millis deadline, grpc_closure* on_done, in grpc_httpcli_post() argument
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| 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;
|
| /external/grpc-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()
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 87 grpc_millis deadline) { in start_timer_if_needed() argument
88 if (deadline == GRPC_MILLIS_INF_FUTURE) { in start_timer_if_needed()
115 grpc_timer_init(&deadline_state->timer, deadline, closure); in start_timer_if_needed()
157 grpc_millis deadline; member
174 start_timer_if_needed(state->elem, state->deadline); in start_timer_after_init()
183 grpc_millis deadline) { in grpc_deadline_state_init() argument
190 if (deadline != GRPC_MILLIS_INF_FUTURE) { in grpc_deadline_state_init()
202 state->deadline = deadline; in grpc_deadline_state_init()
273 args->deadline); in init_call_elem()
296 start_timer_if_needed(elem, calld->recv_initial_metadata->deadline); in recv_initial_metadata_ready()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | timer_heap_test.cc | 39 elems[i].deadline = random_deadline(); in create_test_elements()
58 GPR_ASSERT(pq->timers[i]->deadline <= pq->timers[left_child]->deadline); in check_valid()
61 GPR_ASSERT(pq->timers[i]->deadline <= pq->timers[right_child]->deadline); in check_valid()
106 el->deadline = random_deadline(); in test1()
175 el->elem.deadline = random_deadline(); in test2()
211 min_deadline = &elems[i].elem.deadline; in test2()
213 if (elems[i].elem.deadline < *min_deadline) { in test2()
214 min_deadline = &elems[i].elem.deadline; in test2()
219 GPR_ASSERT(grpc_timer_heap_top(&pq)->deadline == *min_deadline); in test2()
|