/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/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/libmojo/mojo/edk/system/ |
test_utils.cc | 50 void Sleep(MojoDeadline deadline) { 51 CHECK_LE(deadline, 54 base::TimeDelta::FromMicroseconds(static_cast<int64_t>(deadline)));
|
test_utils.h | 34 void Sleep(MojoDeadline deadline);
|
waiter.h | 40 // - |MOJO_RESULT_DEADLINE_EXCEEDED| if the deadline was exceeded; in this 58 MojoResult Wait(MojoDeadline deadline, uintptr_t* context);
|
waiter.cc | 40 // TODO(vtl): Fast-path the |deadline == 0| case? 41 MojoResult Waiter::Wait(MojoDeadline deadline, uintptr_t* context) { 59 // Treat any out-of-range deadline as "forever" (which is wrong, but okay 62 if (deadline > static_cast<uint64_t>(std::numeric_limits<int64_t>::max())) { 68 // variables take an absolute deadline. 71 base::TimeDelta::FromMicroseconds(static_cast<int64_t>(deadline));
|
/external/libvpx/libvpx/test/ |
codec_factory.h | 41 unsigned long deadline, 97 VP8Encoder(vpx_codec_enc_cfg_t cfg, unsigned long deadline, 99 : Encoder(cfg, deadline, init_flags, stats) {} 131 unsigned long deadline, 135 return new VP8Encoder(cfg, deadline, init_flags, stats); 138 (void)deadline; 193 VP9Encoder(vpx_codec_enc_cfg_t cfg, unsigned long deadline, 195 : Encoder(cfg, deadline, init_flags, stats) {} 227 unsigned long deadline, 231 return new VP9Encoder(cfg, deadline, init_flags, stats) [all...] |
/external/libmojo/mojo/public/java/system/src/org/chromium/mojo/system/ |
Handle.java | 30 public WaitResult wait(Core.HandleSignals signals, long deadline);
|
/libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
Condition.java | 378 * or the specified deadline elapses. 391 * <li>The specified deadline elapses; or 412 * <p>The return value indicates whether the deadline has elapsed, 415 * boolean aMethod(Date deadline) { 422 * stillWaiting = theCondition.awaitUntil(deadline); 441 * of the specified deadline. In either case the implementation 445 * @param deadline the absolute time to wait until 446 * @return {@code false} if the deadline has elapsed upon return, else 451 boolean awaitUntil(Date deadline) throws InterruptedException;
|
LockSupport.java | 237 * the specified deadline, unless the permit is available. 251 * <li>The specified deadline passes; or 264 * @param deadline the absolute time, in milliseconds from the Epoch, 268 public static void parkUntil(Object blocker, long deadline) { 271 U.park(true, deadline); 358 * the specified deadline, unless the permit is available. 372 * <li>The specified deadline passes; or 383 * @param deadline the absolute time, in milliseconds from the Epoch, 386 public static void parkUntil(long deadline) { 387 U.park(true, deadline); [all...] |
/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/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));
|
/device/google/cuttlefish_common/host/libs/usbip/ |
device.h | 73 std::function<bool(const CmdRequest& request, uint32_t deadline, 79 uint32_t deadline, std::vector<uint8_t> data,
|
/external/libmojo/mojo/public/c/system/ |
functions.h | 62 // - Until |deadline| has passed. 64 // If |deadline| is |MOJO_DEADLINE_INDEFINITE|, this will wait "forever" (until 65 // one of the other wait termination conditions is satisfied). If |deadline| is 79 // |MOJO_RESULT_DEADLINE_EXCEEDED| if the deadline has passed without any of 91 MojoDeadline deadline, 99 // - |deadline| has passed. 105 // See |MojoWait()| for more details about |deadline|. 129 // |MOJO_RESULT_DEADLINE_EXCEEDED| if the deadline has passed without any of 137 MojoDeadline deadline,
|
/external/python/cpython3/Lib/test/ |
test_wait3.py | 21 deadline = time.monotonic() + 10.0 22 while time.monotonic() <= deadline:
|
test_wait4.py | 23 deadline = time.monotonic() + 10.0 24 while time.monotonic() <= deadline:
|
test_multiprocessing_main_handling.py | 61 deadline = time.time() + 10 # up to 10 s to report the results 64 if time.time() > deadline: 89 deadline = time.time() + 10 # up to 10 s to report the results 92 if time.time() > deadline:
|
/external/v8/src/heap/ |
embedder-tracing.cc | 41 double deadline, EmbedderHeapTracer::AdvanceTracingActions actions) { 45 return remote_tracer_->AdvanceTracing(deadline, actions);
|
/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/libvpx/libvpx/ |
vpxenc.h | 41 int deadline; member in struct:VpxEncoderConfig
|
warnings.c | 27 "Lag in frames is ignored when deadline is set to realtime for cbr mode."; 80 int lag_in_frames, int deadline, int rc_end_usage, 82 if (deadline == VPX_DL_REALTIME && lag_in_frames != 0 && rc_end_usage == 1) 96 stream_config->g_lag_in_frames, global_config->deadline,
|
/external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
WaitingThread.java | 130 * @param deadline when to time out, or <code>null</code> for no timeout 142 public boolean await(Date deadline) 161 if (deadline != null) { 162 success = this.cond.awaitUntil(deadline);
|
/test/framework/harnesses/host_controller/tradefed/ |
remote_client.py | 125 deadline = time.time() + timeout 131 if time.time() > deadline: 134 if time.time() > deadline:
|
/system/bt/osi/src/ |
alarm.cc | 98 period_ms_t deadline; member in struct:alarm_t 99 period_ms_t prev_deadline; // Previous deadline - used for accounting of 213 if (alarm->deadline > just_now) remaining_ms = alarm->deadline - just_now; 271 alarm->deadline = 0; 422 // we'll need to re-schedule since we've adjusted the earliest deadline. 427 // Calculate the next deadline for this alarm 432 alarm->deadline = just_now + (alarm->period - ms_into_period); 434 // Add it into the timer list sorted by deadline (earliest deadline first) 570 period_ms_t deadline = alarm->deadline; local [all...] |
/device/google/cuttlefish_common/host/libs/vadb/ |
virtual_adb_client.h | 65 const usbip::CmdRequest& r, uint32_t deadline, 71 bool is_host_to_device, uint32_t deadline,
|