| /external/grpc-grpc/src/ruby/spec/ |
| call_spec.rb | 174 @ch.create_call(nil, nil, 'dummy_method', nil, deadline)
177 def deadline method
|
| client_server_spec.rb | 23 def deadline method
38 @ch.create_call(nil, nil, '/method', nil, deadline)
553 @server.shutdown_and_notify(deadline)
587 @server.shutdown_and_notify(deadline)
|
| /external/grpc-grpc/test/distrib/php/ |
| distribtest.php | 24 $deadline = Grpc\Timeval::infFuture(); variable
27 $deadline);
|
| /external/grpc-grpc/src/ruby/spec/generic/ |
| active_call_spec.rb | 51 @server.shutdown_and_notify(deadline)
60 @pass_through, deadline)
65 want = %w(cancelled?, deadline, each_remote_read, metadata, \
77 want = %w(cancelled?, deadline, metadata, shutdown, \
89 want = %w(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)
669 def deadline method
[all...] |
| /external/grpc-grpc/src/core/lib/iomgr/ |
| timer_generic.h | 28 gpr_atm deadline; member in struct:grpc_timer
|
| /external/grpc-grpc/src/cpp/util/ |
| time_cc.cc | 33 system_clock::duration deadline = from.time_since_epoch(); local
34 seconds secs = duration_cast<seconds>(deadline);
41 nanoseconds nsecs = duration_cast<nanoseconds>(deadline - secs);
49 high_resolution_clock::duration deadline = from.time_since_epoch(); local
50 seconds secs = duration_cast<seconds>(deadline);
57 nanoseconds nsecs = duration_cast<nanoseconds>(deadline - secs);
|
| /external/grpc-grpc/test/core/end2end/ |
| cq_verifier_native.cc | 55 const gpr_timespec deadline = local
57 return grpc_completion_queue_next(v->cq, deadline, nullptr);
|
| connection_refused_test.cc | 86 gpr_timespec deadline = grpc_timeout_seconds_to_deadline(2); local
90 &host, deadline, nullptr);
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| periodic_function.cc | 70 const int64 deadline = start + options_.startup_delay_micros; local
71 options_.env->SleepForMicroseconds(deadline - start);
84 // The deadline is relative to when the last function started.
85 const int64 deadline = begin + interval_micros_; local
87 // We want to sleep until 'deadline'.
88 if (deadline > end) {
91 << " to " << (deadline - end);
93 options_.env->SleepForMicroseconds(deadline - end);
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| connector.h | 38 /** deadline for connection */
39 grpc_millis deadline; member in struct:__anon22967
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| ServerRpcNew.cs | 33 readonly Timespec deadline; field in struct:Grpc.Core.Internal.ServerRpcNew
36 public ServerRpcNew(Server server, CallSafeHandle call, string method, string host, Timespec deadline, Metadata requestMetadata)
42 this.deadline = deadline;
78 public Timespec Deadline
82 return this.deadline;
|
| /external/grpc-grpc/src/php/tests/interop/ |
| stress_client.php | 39 $deadline = $args['test_duration_secs'] ? variable
46 if ($deadline && $current_time > $deadline) {
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| rb_completion_queue.c | 44 gpr_timespec deadline; local
46 deadline = gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), increment);
48 next_call->cq, next_call->tag, deadline, NULL);
50 gpr_time_cmp(deadline, next_call->timeout) > 0) {
75 gpr_timespec deadline, void* reserved) {
79 next_call.timeout = deadline;
|
| /external/grpc-grpc/test/core/bad_client/tests/ |
| server_registered_method.cc | 49 gpr_timespec deadline; local
55 &deadline, &request_metadata_recv,
|
| head_of_line_blocking.cc | 77 gpr_timespec deadline; local
83 &deadline, &request_metadata_recv,
|
| /external/grpc-grpc/test/cpp/interop/ |
| metrics_client.cc | 36 "The deadline (in seconds) for RCP call");
55 std::chrono::system_clock::time_point deadline = local
58 context.set_deadline(deadline);
|
| /external/grpc-grpc-java/context/src/test/java/io/grpc/testing/ |
| DeadlineSubject.java | 27 import io.grpc.Deadline;
34 * Propositions for {@link Deadline} subjects.
36 public final class DeadlineSubject extends ComparableSubject<DeadlineSubject, Deadline> {
37 private static final Subject.Factory<DeadlineSubject, Deadline> deadlineFactory =
40 public static Subject.Factory<DeadlineSubject, Deadline> deadline() { method in class:DeadlineSubject
44 private DeadlineSubject(FailureMetadata metadata, Deadline subject) {
49 * Prepares for a check that the subject is deadline within the given tolerance of an
56 public void of(Deadline expected) {
57 Deadline actual = actual()
[all...] |
| /external/okhttp/okio/okio/src/main/java/okio/ |
| Timeout.java | 92 /** Returns true if a deadline is enabled. */
98 * Returns the {@linkplain System#nanoTime() nano time} when the deadline will
101 * @throws IllegalStateException if no deadline is set.
104 if (!hasDeadline) throw new IllegalStateException("No deadline");
109 * Sets the {@linkplain System#nanoTime() nano time} when the deadline will be
110 * reached. All operations must complete before this time. Use a deadline to
119 /** Set a deadline of now plus {@code duration} time. */
120 public final Timeout deadline(long duration, TimeUnit unit) { method in class:Timeout
132 /** Clears the deadline. */
139 * Throws an {@link InterruptedIOException} if the deadline has been reached or if the curren
[all...] |
| /external/okhttp/repackaged/okio/okio/src/main/java/com/android/okhttp/okio/ |
| Timeout.java | 94 /** Returns true if a deadline is enabled. */
100 * Returns the {@linkplain System#nanoTime() nano time} when the deadline will
103 * @throws IllegalStateException if no deadline is set.
106 if (!hasDeadline) throw new IllegalStateException("No deadline");
111 * Sets the {@linkplain System#nanoTime() nano time} when the deadline will be
112 * reached. All operations must complete before this time. Use a deadline to
121 /** Set a deadline of now plus {@code duration} time. */
122 public final Timeout deadline(long duration, TimeUnit unit) { method in class:Timeout
134 /** Clears the deadline. */
141 * Throws an {@link InterruptedIOException} if the deadline has been reached or if the curren
[all...] |
| /external/v8/src/heap/ |
| incremental-marking-job.cc | 34 double deadline = local
37 deadline, i::IncrementalMarking::NO_GC_VIA_STACK_GUARD,
|
| /cts/tests/tests/media/src/android/media/cts/ |
| TestUtils.java | 101 long deadline = System.currentTimeMillis() + timeoutMs; local
103 long delay = deadline - System.currentTimeMillis();
|
| /device/generic/goldfish/network/netmgr/ |
| poller.cpp | 32 static struct timespec* calculateTimeout(Pollable::Timestamp deadline,
35 if (deadline < Pollable::Timestamp::max()) {
36 if (deadline <= now) {
37 LOGE("Poller found past due deadline, setting to zero");
43 auto timeout = deadline - now;
88 Pollable::Timestamp deadline = Pollable::Timestamp::max(); local
97 if (pollableDeadline < deadline) {
98 deadline = pollableDeadline;
103 struct timespec* tsPtr = calculateTimeout(deadline, &ts);
|
| /external/grpc-grpc/src/php/lib/Grpc/ |
| AbstractCall.php | 56 $deadline = $now->add($delta); variable
58 $deadline = Timeval::infFuture(); variable
60 $this->call = new Call($channel, $method, $deadline);
|
| /external/grpc-grpc/src/php/tests/unit_tests/ |
| SecureEndToEndTest.php | 53 $deadline = Grpc\Timeval::infFuture(); variable
57 $deadline,
103 $deadline = Grpc\Timeval::infFuture(); variable
108 $deadline,
151 $deadline = Grpc\Timeval::infFuture(); variable
158 $deadline,
|
| /external/grpc-grpc/test/core/end2end/fuzzers/ |
| server_fuzzer.cc | 106 grpc_millis deadline = grpc_core::ExecCtx::Get()->Now() + 5000; local
111 // For example, the deadline timer might expire, leading to the timer
122 grpc_core::ExecCtx::Get()->Now() < deadline);
132 grpc_core::ExecCtx::Get()->Now() < deadline);
|
