| /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 | 74 double deadline = heap()->MonotonicallyIncreasingTimeInMs() + local
77 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 | 16 * Defines the number of milliseconds we expecting a Thread might need to unpark, we use this to avoid "oversleeping" while awaiting the deadline for
27 long deadline = timeUnit.toMillis(delay) + currentTimeMillis(); local
29 executor.submit(delayedExecution(r, deadline));
40 private static Runnable delayedExecution(final Runnable r, final long deadline) {
45 parkUntil(deadline - MAX_EXPECTED_OVERSLEEP_MILLIS);
46 //now we closing to the deadline by burning CPU-time in a loop
47 burnRemaining(deadline);
49 System.out.println("[DelayedExecution] exec delay = "+(currentTimeMillis() - deadline)+"ms");
58 private void burnRemaining(final long deadline) {
61 remaining = deadline - currentTimeMillis()
[all...] |
| /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 | 64 final long deadline = System.currentTimeMillis() + timeoutMillis; local
73 // with the remaining time until the deadline.
74 timeoutMillis -= deadline - System.currentTimeMillis();
|
| /prebuilts/go/darwin-x86/src/net/ |
| dial.go | 20 // a connect to complete. If Deadline is also set, it may fail
33 // Deadline is the absolute point in time after which dials
35 // Zero means no deadline, or dependent on the operating system
37 Deadline time.Time
83 // deadline returns the earliest of:
85 // - d.Deadline
86 // - the context's deadline
87 // Or zero, if none of Timeout, Deadline, or context's deadline is set.
88 func (d *Dialer) deadline(ctx context.Context, now time.Time) (earliest time.Time) func
[all...] |
| /prebuilts/go/linux-x86/src/net/ |
| dial.go | 20 // a connect to complete. If Deadline is also set, it may fail
33 // Deadline is the absolute point in time after which dials
35 // Zero means no deadline, or dependent on the operating system
37 Deadline time.Time
83 // deadline returns the earliest of:
85 // - d.Deadline
86 // - the context's deadline
87 // Or zero, if none of Timeout, Deadline, or context's deadline is set.
88 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/libmojo/mojo/message_pump/ |
| message_pump_mojo.h | 57 // NOTE: a value of 0 for |deadline| indicates an indefinite timeout.
61 base::TimeTicks deadline);
83 base::TimeTicks deadline; member in struct:mojo::common::MessagePumpMojo::Handler
107 // handles may be available, or |false| if the wait's deadline was exceeded.
116 // Removes any handles that have expired their deadline. Runs the handler's
123 // Returns the deadline for the call to MojoWait().
148 // Set of handles that have a deadline set. Avoids iterating over all elements
149 // in |handles_| in the common case (no deadline set).
|
| /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 | 167 func (c *Client) send(req *Request, deadline time.Time) (resp *Response, didTimeout func() bool, err error) {
173 resp, didTimeout, err = send(req, c.transport(), deadline)
185 func (c *Client) deadline() time.Time { func
201 func send(ireq *Request, rt RoundTripper, deadline time.Time) (resp *Response, didTimeout func() bool, err error) {
244 if !deadline.IsZero() {
247 stopTimer, didTimeout := setRequestCancel(req, rt, deadline)
265 if !deadline.IsZero() {
275 // setRequestCancel sets the Cancel field of req, if deadline is
283 func setRequestCancel(req *Request, rt RoundTripper, deadline time.Time) (stopTimer func(), didTimeout func() bool) {
284 if deadline.IsZero()
[all...] |
| /prebuilts/go/linux-x86/src/net/http/ |
| client.go | 167 func (c *Client) send(req *Request, deadline time.Time) (resp *Response, didTimeout func() bool, err error) {
173 resp, didTimeout, err = send(req, c.transport(), deadline)
185 func (c *Client) deadline() time.Time { func
201 func send(ireq *Request, rt RoundTripper, deadline time.Time) (resp *Response, didTimeout func() bool, err error) {
244 if !deadline.IsZero() {
247 stopTimer, didTimeout := setRequestCancel(req, rt, deadline)
265 if !deadline.IsZero() {
275 // setRequestCancel sets the Cancel field of req, if deadline is
283 func setRequestCancel(req *Request, rt RoundTripper, deadline time.Time) (stopTimer func(), didTimeout func() bool) {
284 if deadline.IsZero()
[all...] |
| /system/update_engine/ |
| omaha_response.h | 48 std::string deadline; member in struct:chromeos_update_engine::OmahaResponse
|
| omaha_response_handler_action_unittest.cc | 154 in.deadline = "20101020";
160 string deadline; local
161 EXPECT_TRUE(utils::ReadFile(test_deadline_file, &deadline));
162 EXPECT_EQ("20101020", deadline);
186 string deadline; local
187 EXPECT_TRUE(utils::ReadFile(test_deadline_file, &deadline) &&
188 deadline.empty());
200 in.deadline = "some-deadline";
207 string deadline; local
[all...] |
| /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 | 127 // Move delayed tasks that hit their deadline to the main queue.
163 double deadline = MonotonicallyIncreasingTime() + delay_in_seconds; local
164 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) &&
|
| /hardware/interfaces/soundtrigger/2.0/vts/functional/ |
| VtsHalSoundtriggerV2_0TargetTest.cpp | 71 auto deadline = std::chrono::system_clock::now() + local
74 if (mCv.wait_until(lock, deadline) == std::cv_status::timeout) {
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| AbstractExecutorService.java | 169 final long deadline = timed ? System.nanoTime() + nanos : 0L; local
191 nanos = deadline - System.nanoTime();
265 final long deadline = System.nanoTime() + nanos; local
277 if (((i == 0) ? nanos : deadline - System.nanoTime()) <= 0L)
285 try { f.get(deadline - System.nanoTime(), NANOSECONDS); }
|
| /external/libchrome/base/process/ |
| process_posix.cc | 126 base::TimeTicks deadline; local
129 deadline = base::TimeTicks::Now() + remaining_delta;
154 remaining_delta = deadline - base::TimeTicks::Now();
|
