/third_party/python/Modules/_multiprocessing/ |
H A D | semaphore.c | 233 # define sem_timedwait(sem,deadline) sem_timedwait_save(sem,deadline,_save) 236 sem_timedwait_save(sem_t *sem, struct timespec *deadline, PyThreadState *_save) in sem_timedwait_save() argument 243 tvdeadline.tv_sec = deadline->tv_sec; in sem_timedwait_save() 244 tvdeadline.tv_usec = deadline->tv_nsec / 1000; in sem_timedwait_save() 310 struct timespec deadline = {0}; in _multiprocessing_SemLock_acquire_impl() local 334 deadline.tv_sec = now.tv_sec + sec; in _multiprocessing_SemLock_acquire_impl() 335 deadline.tv_nsec = now.tv_usec * 1000 + nsec; in _multiprocessing_SemLock_acquire_impl() 336 deadline.tv_sec += (deadline in _multiprocessing_SemLock_acquire_impl() [all...] |
/third_party/backends/sanei/ |
H A D | sanei_pp.c | 598 struct timeval start, end, deadline; in pp_calculate_thresh() local 604 gettimeofday( &deadline, NULL ); in pp_calculate_thresh() 605 deadline.tv_usec += 10; in pp_calculate_thresh() 606 deadline.tv_sec += deadline.tv_usec / 1000000; in pp_calculate_thresh() 607 deadline.tv_usec %= 1000000; in pp_calculate_thresh() 1217 struct timeval now, deadline; local 1222 gettimeofday( &deadline, NULL ); 1223 deadline.tv_usec += usec; 1224 deadline [all...] |
/third_party/backends/backend/ |
H A D | u12-io.c | 94 struct timeval now, deadline; in u12io_udelay() local 99 gettimeofday( &deadline, NULL ); in u12io_udelay() 100 deadline.tv_usec += usec; in u12io_udelay() 101 deadline.tv_sec += deadline.tv_usec / 1000000; in u12io_udelay() 102 deadline.tv_usec %= 1000000; in u12io_udelay() 106 } while ((now.tv_sec < deadline.tv_sec) || in u12io_udelay() 107 (now.tv_sec == deadline.tv_sec && now.tv_usec < deadline.tv_usec)); in u12io_udelay()
|
/third_party/eudev/src/udev/ |
H A D | udevadm-settle.c | 59 usec_t deadline; in adm_settle() local 109 deadline = now(CLOCK_MONOTONIC) + timeout * USEC_PER_SEC; in adm_settle() 152 if (now(CLOCK_MONOTONIC) >= deadline) in adm_settle()
|
/third_party/python/Lib/test/ |
H A D | test_wait4.py | 25 deadline = time.monotonic() + support.SHORT_TIMEOUT 26 while time.monotonic() <= deadline:
|
H A D | test_wait3.py | 23 deadline = time.monotonic() + support.SHORT_TIMEOUT 24 while time.monotonic() <= deadline:
|
H A D | fork_wait.py | 57 deadline = time.monotonic() + support.SHORT_TIMEOUT 60 if deadline < time.monotonic():
|
H A D | signalinterproctester.py | 32 deadline = time.monotonic() + timeout 34 while time.monotonic() < deadline:
|
/third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/ |
H A D | notification.cc | 67 bool Notification::WaitForNotificationWithDeadline(absl::Time deadline) const { in WaitForNotificationWithDeadline() 71 Condition(&HasBeenNotifiedInternal, &this->notified_yet_), deadline); in WaitForNotificationWithDeadline()
|
H A D | mutex.h | 327 // - either `cond` is true or the {timeout has expired, deadline has passed} 336 // Deadlines in the past are equivalent to an immediate deadline. 342 bool AwaitWithDeadline(const Condition &cond, absl::Time deadline); 369 // - either `cond` is `true` or the deadline has been passed, and 374 // Deadlines in the past are equivalent to an immediate deadline. 375 bool LockWhenWithDeadline(const Condition &cond, absl::Time deadline) 377 bool ReaderLockWhenWithDeadline(const Condition &cond, absl::Time deadline) 379 bool WriterLockWhenWithDeadline(const Condition &cond, absl::Time deadline) 381 return this->LockWhenWithDeadline(cond, deadline); in ABSL_EXCLUSIVE_LOCK_FUNCTION() 826 // spurious wakeup), or until the deadline ha [all...] |
H A D | notification.h | 98 // may occur immediately) or the deadline has expired, returning the value of 100 bool WaitForNotificationWithDeadline(absl::Time deadline) const;
|
/third_party/python/Lib/test/test_asyncio/ |
H A D | test_timeouts.py | 26 deadline = loop.time() + 0.01 27 async with asyncio.timeout_at(deadline) as cm: 30 self.assertEqual(deadline, cm.when()) 36 deadline = loop.time() + 0.01 37 async with asyncio.timeout_at(deadline) as cm1: 40 async with asyncio.timeout_at(deadline) as cm2:
|
/third_party/python/Python/ |
H A D | thread_pthread.h | 468 // Local scope for deadline in PyThread_acquire_lock_timed() 470 _PyTime_t deadline = _PyTime_Add(_PyTime_GetMonotonicClock(), timeout); in PyThread_acquire_lock_timed() local 471 _PyTime_AsTimespec_clamp(deadline, &abs_timeout); in PyThread_acquire_lock_timed() 474 _PyTime_t deadline = 0; in PyThread_acquire_lock_timed() local 476 deadline = _PyDeadline_Init(timeout); in PyThread_acquire_lock_timed() 511 timeout = _PyDeadline_Get(deadline); in PyThread_acquire_lock_timed()
|
H A D | thread_nt.h | 78 /* wait at least until the deadline */ in EnterNonRecursiveMutex() 80 _PyTime_t deadline = _PyTime_Add(_PyTime_GetPerfCounter(), nanoseconds); in EnterNonRecursiveMutex() local 88 nanoseconds = deadline - _PyTime_GetPerfCounter(); in EnterNonRecursiveMutex()
|
/third_party/node/deps/v8/src/heap/ |
H A D | incremental-marking-job.cc | 86 double deadline = in Step() local 89 deadline, i::IncrementalMarking::NO_GC_VIA_STACK_GUARD, in Step()
|
H A D | memory-reducer.cc | 88 double deadline = heap()->MonotonicallyIncreasingTimeInMs() + in NotifyTimer() local 91 deadline, IncrementalMarking::NO_GC_VIA_STACK_GUARD, in NotifyTimer()
|
/third_party/node/deps/v8/src/libplatform/ |
H A D | delayed-task-queue.cc | 37 double deadline = MonotonicallyIncreasingTime() + delay_in_seconds; in AppendDelayed() local 41 delayed_task_queue_.emplace(deadline, std::move(task)); in AppendDelayed() 49 // Move delayed tasks that have hit their deadline to the main queue. in GetNext() 84 // Gets the next task from the delayed queue for which the deadline has passed
|
H A D | default-foreground-task-runner.cc | 61 double deadline = MonotonicallyIncreasingTime() + delay_in_seconds; in PostDelayedTaskLocked() local 62 delayed_task_queue_.push({deadline, nestability, std::move(task)}); in PostDelayedTaskLocked()
|
/third_party/skia/third_party/externals/abseil-cpp/absl/time/ |
H A D | clock_test.cc | 55 const absl::Time deadline = absl::Now() + timeout; in SleepForBounded() local 56 while (absl::Now() < deadline) { in SleepForBounded()
|
/third_party/python/Modules/ |
H A D | selectmodule.c | 278 _PyTime_t timeout, deadline = 0; in select_select_impl() local 332 deadline = _PyDeadline_Init(timeout); in select_select_impl() 354 timeout = _PyDeadline_Get(deadline); in select_select_impl() 600 _PyTime_t timeout = -1, ms = -1, deadline = 0; in select_poll_poll_impl() local 620 deadline = _PyDeadline_Init(timeout); in select_poll_poll_impl() 667 timeout = _PyDeadline_Get(deadline); in select_poll_poll_impl() 927 _PyTime_t timeout, ms, deadline = 0; in select_devpoll_poll_impl() local 962 deadline = _PyDeadline_Init(timeout); in select_devpoll_poll_impl() 980 timeout = _PyDeadline_Get(deadline); in select_devpoll_poll_impl() 1540 _PyTime_t timeout = -1, ms = -1, deadline in select_epoll_poll_impl() local 2119 _PyTime_t timeout, deadline = 0; select_kqueue_control_impl() local [all...] |
/third_party/python/Lib/test/support/ |
H A D | threading_helper.py | 91 deadline = start_time + timeout 96 if time.monotonic() > deadline:
|
/third_party/skia/third_party/externals/abseil-cpp/absl/flags/internal/ |
H A D | sequence_lock_test.cc | 91 absl::Time deadline = absl::Now() + absl::Seconds(5); in TEST_P() local 92 for (int i = 0; i < 100 && absl::Now() < deadline; i++) { in TEST_P()
|
/third_party/python/Lib/ |
H A D | telnetlib.py | 314 deadline = _time() + timeout 329 timeout = deadline - _time() 618 deadline = _time() + timeout 632 timeout = deadline - _time()
|
/third_party/skia/third_party/externals/oboe/src/common/ |
H A D | AudioStream.cpp | 172 int64_t deadline = AudioClock::getNanoseconds() + timeoutNanoseconds; in waitForAvailableFrames() local 180 if (now > deadline) break; in waitForAvailableFrames()
|
/third_party/node/deps/v8/src/heap/cppgc/ |
H A D | marker.cc | 477 const auto deadline = v8::base::TimeTicks::Now() + max_duration; in AdvanceMarkingWithLimits() local 478 is_done = ProcessWorklistsWithDeadline(marked_bytes_limit, deadline); in AdvanceMarkingWithLimits() 482 is_done = ProcessWorklistsWithDeadline(marked_bytes_limit, deadline); in AdvanceMarkingWithLimits() 513 // than other objects. Therefore we reduce the interval between deadline in ProcessWorklistsWithDeadline() 514 // checks to guarantee the deadline is not exceeded. in ProcessWorklistsWithDeadline()
|