| /external/mockito/src/test/java/org/mockitousage/verification/ |
| D | DelayedExecution.java | 27 long deadline = timeUnit.toMillis(delay) + currentTimeMillis(); in callAsync() local
29 executor.submit(delayedExecution(r, deadline)); in callAsync()
40 private static Runnable delayedExecution(final Runnable r, final long deadline) { in delayedExecution() argument
45 parkUntil(deadline - MAX_EXPECTED_OVERSLEEP_MILLIS); in delayedExecution()
47 burnRemaining(deadline); in delayedExecution()
49 … System.out.println("[DelayedExecution] exec delay = "+(currentTimeMillis() - deadline)+"ms"); in delayedExecution()
58 private void burnRemaining(final long deadline) { in delayedExecution() argument
61 remaining = deadline - currentTimeMillis(); in delayedExecution()
|
| /external/libmojo/mojo/message_pump/ |
| D | message_pump_mojo.cc | 96 base::TimeTicks deadline) { in AddHandler() argument
104 handler_data.deadline = deadline; in AddHandler()
107 if (!deadline.is_null()) { in AddHandler()
224 const MojoDeadline deadline = GetDeadlineForWait(run_state); in DoNonMojoWork() local
227 if (deadline == MOJO_DEADLINE_INDEFINITE) { in DoNonMojoWork()
230 if (deadline > 0) { in DoNonMojoWork()
231 event_.TimedWait(base::TimeDelta::FromMicroseconds(deadline)); in DoNonMojoWork()
246 const MojoDeadline deadline = GetDeadlineForWait(run_state); in WaitForReadyHandles() local
248 wait_set_handle_.get(), MOJO_HANDLE_SIGNAL_READABLE, deadline, nullptr); in WaitForReadyHandles()
374 if (!it->second.deadline.is_null() && it->second.deadline < now) in RemoveExpiredHandles()
[all …]
|
| D | handle_watcher.cc | 39 base::TimeTicks MojoDeadlineToTimeTicks(MojoDeadline deadline) { in MojoDeadlineToTimeTicks() argument
40 return deadline == MOJO_DEADLINE_INDEFINITE ? base::TimeTicks() : in MojoDeadlineToTimeTicks()
41 internal::NowTicks() + base::TimeDelta::FromMicroseconds(deadline); in MojoDeadlineToTimeTicks()
52 base::TimeTicks deadline; member
104 data.deadline); in StartWatching()
167 base::TimeTicks deadline,
229 base::TimeTicks deadline, in StartWatching() argument
237 request_data.start_data.deadline = deadline; in StartWatching()
363 MojoDeadline deadline, in SameThreadWatchingState() argument
370 this, handle, handle_signals, MojoDeadlineToTimeTicks(deadline)); in SameThreadWatchingState()
[all …]
|
| /external/libvpx/libvpx/test/ |
| D | codec_factory.h | 41 unsigned long deadline,
97 VP8Encoder(vpx_codec_enc_cfg_t cfg, unsigned long deadline, in VP8Encoder() argument
99 : Encoder(cfg, deadline, init_flags, stats) {} in VP8Encoder()
131 unsigned long deadline, in CreateEncoder() argument
135 return new VP8Encoder(cfg, deadline, init_flags, stats); in CreateEncoder()
138 (void)deadline; in CreateEncoder()
193 VP9Encoder(vpx_codec_enc_cfg_t cfg, unsigned long deadline, in VP9Encoder() argument
195 : Encoder(cfg, deadline, init_flags, stats) {} in VP9Encoder()
227 unsigned long deadline, in CreateEncoder() argument
231 return new VP9Encoder(cfg, deadline, init_flags, stats); in CreateEncoder()
[all …]
|
| D | encode_test_driver.h | 89 Encoder(vpx_codec_enc_cfg_t cfg, unsigned long deadline, in Encoder() argument
91 : cfg_(cfg), deadline_(deadline), init_flags_(init_flags), stats_(stats) { in Encoder()
148 void set_deadline(unsigned long deadline) { deadline_ = deadline; } in set_deadline() argument
|
| /external/valgrind/drd/tests/ |
| D | pth_inconsistent_cond_wait.c | 78 struct timespec deadline; in thread_func() local
83 memset(&deadline, 0, sizeof(deadline)); in thread_func()
84 deadline.tv_sec = now.tv_sec + 2; in thread_func()
85 deadline.tv_nsec = now.tv_usec * 1000; in thread_func()
86 PTH_CALL(pthread_cond_timedwait(&s_cond, mutex, &deadline)); in thread_func()
|
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| D | GcFinalization.java | 135 final long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); in awaitDone() local
154 } while (System.nanoTime() - deadline < 0); in awaitDone()
170 final long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); in await() local
184 } while (System.nanoTime() - deadline < 0); in await()
223 final long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); in awaitDone() local
235 } while (System.nanoTime() - deadline < 0); in awaitDone()
|
| /external/autotest/site_utils/suite_scheduler/ |
| D | timed_event.py | 25 def __init__(self, keyword, manifest_versions, always_handle, deadline): argument
35 self._deadline = deadline
146 deadline = now_hour + datetime.timedelta(hours=extra_hour)
148 always_handle, deadline)
220 deadline = this_week_deadline
222 deadline = this_week_deadline + datetime.timedelta(days=1)
224 always_handle, deadline)
|
| /external/libmojo/mojo/public/cpp/system/ |
| D | handle.h | 189 MojoDeadline deadline, in Wait() argument
191 return MojoWait(handle.value(), signals, deadline, signals_state); in Wait()
232 MojoDeadline deadline, in WaitMany() argument
242 MojoWaitMany(nullptr, nullptr, 0, deadline, nullptr, nullptr)); in WaitMany()
253 deadline, &result_index, first_state); in WaitMany()
263 MojoDeadline deadline, in WaitMany() argument
272 MojoWaitMany(nullptr, nullptr, 0, deadline, nullptr, nullptr)); in WaitMany()
280 static_cast<uint32_t>(handles.size()), deadline, &result_index, nullptr); in WaitMany()
|
| /external/python/cpython2/Modules/_multiprocessing/ |
| D | semaphore.c | 212 # define sem_timedwait(sem,deadline) sem_timedwait_save(sem,deadline,_save) argument
215 sem_timedwait_save(sem_t *sem, struct timespec *deadline, PyThreadState *_save) in sem_timedwait_save() argument
222 tvdeadline.tv_sec = deadline->tv_sec; in sem_timedwait_save()
223 tvdeadline.tv_usec = deadline->tv_nsec / 1000; in sem_timedwait_save()
280 struct timespec deadline = {0}; in semlock_acquire() local
308 deadline.tv_sec = now.tv_sec + sec; in semlock_acquire()
309 deadline.tv_nsec = now.tv_usec * 1000 + nsec; in semlock_acquire()
310 deadline.tv_sec += (deadline.tv_nsec / 1000000000); in semlock_acquire()
311 deadline.tv_nsec %= 1000000000; in semlock_acquire()
321 res = sem_timedwait(self->handle, &deadline); in semlock_acquire()
|
| D | pipe_connection.c | 95 DWORD bytes, deadline, delay; in conn_poll() local
109 deadline = GetTickCount() + (DWORD)(1000 * timeout + 0.5); in conn_poll()
120 difference = deadline - GetTickCount(); in conn_poll()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 378 long deadline = System.nanoTime() + timeoutNanos; in enter() local
386 timeoutNanos = deadline - System.nanoTime(); in enter()
479 long deadline = System.nanoTime() + timeoutNanos; in enterWhen() local
483 timeoutNanos = deadline - System.nanoTime(); in enterWhen()
518 long deadline = System.nanoTime() + timeoutNanos; in enterWhenUninterruptibly() local
533 timeoutNanos = deadline - System.nanoTime(); in enterWhenUninterruptibly()
546 timeoutNanos = deadline - System.nanoTime(); in enterWhenUninterruptibly()
739 long deadline = System.nanoTime() + timeoutNanos; in waitForUninterruptibly() local
751 timeoutNanos = deadline - System.nanoTime(); in waitForUninterruptibly()
|
| /external/libmojo/mojo/edk/system/ |
| D | test_utils.cc | 50 void Sleep(MojoDeadline deadline) { in Sleep() argument
51 CHECK_LE(deadline, in Sleep()
54 base::TimeDelta::FromMicroseconds(static_cast<int64_t>(deadline))); in Sleep()
|
| D | waiter.cc | 41 MojoResult Waiter::Wait(MojoDeadline deadline, uintptr_t* context) { in Wait() argument
62 if (deadline > static_cast<uint64_t>(std::numeric_limits<int64_t>::max())) { in Wait()
71 base::TimeDelta::FromMicroseconds(static_cast<int64_t>(deadline)); in Wait()
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| D | WaitingThread.java | 142 public boolean await(Date deadline) in await() argument
161 if (deadline != null) { in await()
162 success = this.cond.awaitUntil(deadline); in await()
|
| /external/libvpx/libvpx/ |
| D | warnings.c | 80 int lag_in_frames, int deadline, int rc_end_usage, in check_lag_in_frames_realtime_deadline() argument
82 if (deadline == VPX_DL_REALTIME && lag_in_frames != 0 && rc_end_usage == 1) in check_lag_in_frames_realtime_deadline()
96 stream_config->g_lag_in_frames, global_config->deadline, in check_encoder_config()
|
| D | usage.dox | 114 Both the encoding and decoding functions have a <code>deadline</code>
117 returning. This is a soft deadline -- that is, the semantics of the
118 requested operation take precedence over meeting the deadline. If, for
119 example, an application sets a <code>deadline</code> of 1000us, and the
121 after 2000us. In this case the deadline is not met, but the semantics of the
123 a <code>deadline</code> of 5000us, the decoder will see that it has 3000us
126 4000us (instead of the allocated 5000us). In this case the deadline is met,
130 deadline. In this case, the codec will perform as much processing as
|
| D | usage_cx.dox | 5 compressed data. The <code>deadline</code> parameter controls the amount
7 more information on the <code>deadline</code> parameter, see
|
| /external/iputils/doc/ |
| D | arping.sgml | 20 <arg choice="opt">-w <replaceable/deadline/</arg>
60 <link linkend="arping.deadline"><replaceable/deadline/</link>
141 <term><option><anchor id="arping.deadline">-w <replaceable/deadline/</option></term>
151 <link linkend="arping.deadline"><replaceable/deadline/</link>
|
| /external/libmojo/mojo/android/system/src/org/chromium/mojo/system/impl/ |
| D | CoreImpl.java | 97 public WaitManyResult waitMany(List<Pair<Handle, HandleSignals>> handles, long deadline) { in waitMany() argument
114 int code = nativeWaitMany(buffer, deadline); in waitMany()
135 public WaitResult wait(Handle handle, HandleSignals signals, long deadline) { in wait() argument
141 nativeWait(buffer, getMojoHandle(handle), signals.getFlags(), deadline))); in wait()
259 Handle handle, HandleSignals signals, long deadline, Callback callback) { in asyncWait() argument
260 return nativeAsyncWait(getMojoHandle(handle), signals.getFlags(), deadline, callback); in asyncWait()
590 private native int nativeWaitMany(ByteBuffer buffer, long deadline); in nativeWaitMany() argument
601 private native int nativeWait(ByteBuffer buffer, int mojoHandle, int signals, long deadline); in nativeWait() argument
633 int mojoHandle, int signals, long deadline, AsyncWaiter.Callback callback); in nativeAsyncWait() argument
|
| /external/libmojo/mojo/public/cpp/bindings/lib/ |
| D | binding_state.h | 78 MojoDeadline deadline = MOJO_DEADLINE_INDEFINITE) {
80 return router_->WaitForIncomingMessage(deadline);
183 MojoDeadline deadline = MOJO_DEADLINE_INDEFINITE) {
185 return router_->WaitForIncomingMessage(deadline);
|
| /external/v8/src/heap/ |
| D | embedder-tracing.cc | 41 double deadline, EmbedderHeapTracer::AdvanceTracingActions actions) { in Trace() argument
45 return remote_tracer_->AdvanceTracing(deadline, actions); in Trace()
|
| /external/libmojo/mojo/public/c/system/ |
| D | functions.h | 91 MojoDeadline deadline,
137 MojoDeadline deadline,
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | Queues.java | 268 long deadline = System.nanoTime() + unit.toNanos(timeout); in drain() local
275 E e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS); in drain()
303 long deadline = System.nanoTime() + unit.toNanos(timeout); in drainUninterruptibly() local
315 e = q.poll(deadline - System.nanoTime(), TimeUnit.NANOSECONDS); in drainUninterruptibly()
|
| /external/libbrillo/brillo/dbus/ |
| D | dbus_connection.cc | 35 base::TimeTicks deadline = base::TimeTicks::Now() + timeout; in ConnectWithTimeout() local
51 } while (base::TimeTicks::Now() < deadline); in ConnectWithTimeout()
|