/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/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/v8/src/heap/ |
incremental-marking-job.cc | 35 double deadline = local 38 deadline, i::IncrementalMarking::NO_GC_VIA_STACK_GUARD,
|
memory-reducer.cc | 77 double deadline = heap()->MonotonicallyIncreasingTimeInMs() + local 80 deadline, IncrementalMarking::NO_GC_VIA_STACK_GUARD,
|
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/util/leak/ |
ReferenceTestUtils.java | 53 long deadline = SystemClock.uptimeMillis() + 5_000; local 55 if (SystemClock.uptimeMillis() > deadline) {
|
/external/mockito/src/test/java/org/mockitousage/verification/ |
DelayedExecution.java | 20 * Defines the number of milliseconds we expecting a Thread might need to unpark, we use this to avoid "oversleeping" while awaiting the deadline for 31 long deadline = timeUnit.toMillis(delay) + currentTimeMillis(); local 33 executor.submit(delayedExecution(r, deadline)); 44 private static Runnable delayedExecution(final Runnable r, final long deadline) { 49 parkUntil(deadline - MAX_EXPECTED_OVERSLEEP_MILLIS); 50 //now we closing to the deadline by burning CPU-time in a loop 51 burnRemaining(deadline); 53 System.out.println("[DelayedExecution] exec delay = "+(currentTimeMillis() - deadline)+"ms"); 62 private void burnRemaining(final long deadline) { 65 remaining = deadline - currentTimeMillis() [all...] |
/external/python/cpython2/Modules/_multiprocessing/ |
pipe_connection.c | 95 DWORD bytes, deadline, delay; local 109 deadline = GetTickCount() + (DWORD)(1000 * timeout + 0.5); 120 difference = deadline - GetTickCount();
|
/external/valgrind/drd/tests/ |
pth_inconsistent_cond_wait.c | 78 struct timespec deadline; local 83 memset(&deadline, 0, sizeof(deadline)); 84 deadline.tv_sec = now.tv_sec + 2; 85 deadline.tv_nsec = now.tv_usec * 1000; 86 PTH_CALL(pthread_cond_timedwait(&s_cond, mutex, &deadline));
|
/frameworks/base/core/java/android/os/ |
SynchronousResultReceiver.java | 78 final long deadline = System.currentTimeMillis() + timeoutMillis; local 87 // with the remaining time until the deadline. 88 timeoutMillis -= deadline - System.currentTimeMillis();
|
/prebuilts/go/darwin-x86/src/net/ |
dial.go | 21 // a connect to complete. If Deadline is also set, it may fail 34 // Deadline is the absolute point in time after which dials 36 // Zero means no deadline, or dependent on the operating system 38 Deadline time.Time 85 // deadline returns the earliest of: 87 // - d.Deadline 88 // - the context's deadline 89 // Or zero, if none of Timeout, Deadline, or context's deadline is set. 90 func (d *Dialer) deadline(ctx context.Context, now time.Time) (earliest time.Time) func [all...] |
/prebuilts/go/linux-x86/src/net/ |
dial.go | 21 // a connect to complete. If Deadline is also set, it may fail 34 // Deadline is the absolute point in time after which dials 36 // Zero means no deadline, or dependent on the operating system 38 Deadline time.Time 85 // deadline returns the earliest of: 87 // - d.Deadline 88 // - the context's deadline 89 // Or zero, if none of Timeout, Deadline, or context's deadline is set. 90 func (d *Dialer) deadline(ctx context.Context, now time.Time) (earliest time.Time) func [all...] |
/external/guava/guava/src/com/google/common/collect/ |
Queues.java | 268 long deadline = System.nanoTime() + unit.toNanos(timeout); local 275 E e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS); 303 long deadline = System.nanoTime() + unit.toNanos(timeout); local 315 e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS);
|
/external/guava/guava-testlib/src/com/google/common/testing/ |
GcFinalization.java | 135 final long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); local 154 } while (System.nanoTime() - deadline < 0); 170 final long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); local 184 } while (System.nanoTime() - deadline < 0); 223 final long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); local 235 } while (System.nanoTime() - deadline < 0);
|
/external/python/cpython3/Python/ |
condvar.h | 96 struct timeval deadline; local 98 PyCOND_GETTIMEOFDAY(&deadline); 99 PyCOND_ADD_MICROSECONDS(deadline, us); 100 ts.tv_sec = deadline.tv_sec; 101 ts.tv_nsec = deadline.tv_usec * 1000;
|
/packages/apps/Browser2/src/org/chromium/webview_shell/ |
WebViewLayoutTestActivity.java | 81 long deadline = System.currentTimeMillis() + unit.toMillis(timeout); local 82 while (!mFinished && System.currentTimeMillis() < deadline) { 83 mLock.wait(deadline - System.currentTimeMillis());
|
/prebuilts/go/darwin-x86/src/net/http/ |
client.go | 170 func (c *Client) send(req *Request, deadline time.Time) (resp *Response, didTimeout func() bool, err error) { 176 resp, didTimeout, err = send(req, c.transport(), deadline) 188 func (c *Client) deadline() time.Time { func 204 func send(ireq *Request, rt RoundTripper, deadline time.Time) (resp *Response, didTimeout func() bool, err error) { 247 if !deadline.IsZero() { 250 stopTimer, didTimeout := setRequestCancel(req, rt, deadline) 268 if !deadline.IsZero() { 278 // setRequestCancel sets the Cancel field of req, if deadline is 286 func setRequestCancel(req *Request, rt RoundTripper, deadline time.Time) (stopTimer func(), didTimeout func() bool) { 287 if deadline.IsZero() [all...] |
/prebuilts/go/linux-x86/src/net/http/ |
client.go | 170 func (c *Client) send(req *Request, deadline time.Time) (resp *Response, didTimeout func() bool, err error) { 176 resp, didTimeout, err = send(req, c.transport(), deadline) 188 func (c *Client) deadline() time.Time { func 204 func send(ireq *Request, rt RoundTripper, deadline time.Time) (resp *Response, didTimeout func() bool, err error) { 247 if !deadline.IsZero() { 250 stopTimer, didTimeout := setRequestCancel(req, rt, deadline) 268 if !deadline.IsZero() { 278 // setRequestCancel sets the Cancel field of req, if deadline is 286 func setRequestCancel(req *Request, rt RoundTripper, deadline time.Time) (stopTimer func(), didTimeout func() bool) { 287 if deadline.IsZero() [all...] |
/system/update_engine/ |
omaha_response.h | 57 std::string deadline; member in struct:chromeos_update_engine::OmahaResponse
|
/cts/tests/JobScheduler/src/android/jobscheduler/cts/ |
BatteryConstraintTest.java | 133 final long deadline = SystemClock.uptimeMillis() + waitMillis; local 136 } while (SystemClock.uptimeMillis() < deadline);
|
/cts/tests/tests/media/src/android/media/cts/ |
TestUtils.java | 196 long deadline = System.currentTimeMillis() + timeoutMs; local 198 long delay = deadline - System.currentTimeMillis();
|
/external/jemalloc/test/unit/ |
decay.c | 217 nstime_t time, decay_time, deadline; local 278 nstime_copy(&deadline, &time); 279 nstime_add(&deadline, &decay_time); 294 } while (nstime_compare(&time, &deadline) <= 0 && npurge1 == npurge0);
|
/external/libvpx/libvpx/ |
vpxenc.h | 41 int deadline; member in struct:VpxEncoderConfig
|
/external/v8/src/libplatform/ |
default-platform.cc | 148 // Move delayed tasks that hit their deadline to the main queue. 201 double deadline = MonotonicallyIncreasingTime() + delay_in_seconds; local 202 main_thread_delayed_queue_[isolate].push(std::make_pair(deadline, task));
|
/external/vogar/src/vogar/android/ |
AdbTarget.java | 104 final long deadline = start + (millisPerSecond * timeoutSeconds); local 108 (int) ((deadline - System.currentTimeMillis()) / millisPerSecond);
|
/external/webrtc/webrtc/voice_engine/test/auto_test/ |
voe_conference_test.cc | 75 uint32_t deadline = rtc::TimeAfter(kMaxRunTimeMs); local 82 while (rtc::TimeIsLater(rtc::Time(), deadline) &&
|