| /aosp_15_r20/external/python/cpython3/Modules/_multiprocessing/ |
| D | semaphore.c | 55 #define SEM_CREATE(name, val, max) CreateSemaphore(NULL, val, max, NULL) argument
216 #define SEM_CREATE(name, val, max) sem_open(name, O_CREAT | O_EXCL, 0600, val) argument
233 # define sem_timedwait(sem,deadline) sem_timedwait_save(sem,deadline,_save) argument
236 sem_timedwait_save(sem_t *sem, struct timespec *deadline, PyThreadState *_save) in sem_timedwait_save()
310 struct timespec deadline = {0}; in _multiprocessing_SemLock_acquire_impl() local
|
| /aosp_15_r20/external/python/cpython2/Modules/_multiprocessing/ |
| D | semaphore.c | 35 #define SEM_CREATE(name, val, max) CreateSemaphore(NULL, val, max, NULL) argument
195 #define SEM_CREATE(name, val, max) sem_open(name, O_CREAT | O_EXCL, 0600, val) argument
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()
280 struct timespec deadline = {0}; in semlock_acquire() local
|
| /aosp_15_r20/prebuilts/tools/common/m2/repository/io/grpc/grpc-context/1.0.3/ |
| HD | grpc-context-1.0.3.jar | ... io.grpc.Context parent
io.grpc.Deadline deadline
java.util.concurrent.ScheduledExecutorService scheduler
public ... |
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-channel/src/ |
| D | select.rs | 47 let val = r as *mut T as usize; in hook() localVariable
105 fn deadline(&self) -> Option<Instant>; in deadline() method
131 fn deadline(&self) -> Option<Instant> { in deadline() method
252 let mut deadline: Option<Instant> = match timeout { in run_select() localVariable
410 let mut deadline: Option<Instant> = match timeout { in run_ready() localVariable
|
| /aosp_15_r20/external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
| H A D | ShadowDisplayEventReceiver.java | 303 void setHavePendingVsync(boolean val); in setHavePendingVsync()
306 void setTimestampNanos(long val); in setTimestampNanos()
309 void setFrame(int val); in setFrame()
345 Object newFrameTimeline(long id, long expectedPresentTime, long deadline); in newFrameTimeline()
|
| /aosp_15_r20/external/libvpx/test/ |
| H A D | encode_api_test.cc | 48 void *Memset16(void *dest, int val, size_t length) { in Memset16()
65 const int val = 1 << (bit_depth - 1); in CreateImage() local
395 vpx_enc_deadline_t deadline) { in Configure()
598 void EncodeOssFuzz69906(int cpu_used, vpx_enc_deadline_t deadline) { in EncodeOssFuzz69906()
1111 vpx_enc_deadline_t deadline) { in Configure()
|
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/context/grpc-java-context/android_common_apex33/javac/ |
| D | grpc-java-context.jar | ... Deadline deadline
private void setUpDeadlineCancellation (io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService)
io ... |
| /aosp_15_r20/prebuilts/tools/common/google-api-java-client/1.31.3/libs/ |
| HD | grpc-context-1.27.2.jar | ... {
final synthetic java.util.concurrent.Executor val$e
final synthetic io.grpc.Context this ... |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/context/grpc-java-context/android_common_apex10000/javac/ |
| D | grpc-java-context.jar | ... Deadline deadline
private void setUpDeadlineCancellation (io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService)
io ... |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/context/grpc-java-context/android_common_apex34/javac/ |
| D | grpc-java-context.jar | ... Deadline deadline
private void setUpDeadlineCancellation (io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService)
io ... |
| /aosp_15_r20/prebuilts/tools/common/google-api-java-client/1.33.2/libs/ |
| HD | grpc-context-1.27.2.jar | ... {
final synthetic java.util.concurrent.Executor val$e
final synthetic io.grpc.Context this ... |
| /aosp_15_r20/packages/services/Car/tests/BugReportApp/libs/ |
| D | grpc-context-1.19.0.jar | ... abstract int size ()
}
io/grpc/Deadline$SystemTicker.class
Deadline.java
package io. |
| /aosp_15_r20/out/soong/.intermediates/external/grpc-grpc-java/context/grpc-java-context/android_common_apex30/javac/ |
| D | grpc-java-context.jar | ... Deadline deadline
private void setUpDeadlineCancellation (io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService)
io ... |
| /aosp_15_r20/system/logging/logd/ |
| H A D | LogReader.cpp | 143 std::chrono::steady_clock::time_point deadline = {}; in onDataAvailable() local
158 int val = 0; in onDataAvailable() local
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/gensrcs/libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | LinkedTransferQueue.java | 370 final Object cmpExItem(Object cmp, Object val) { // try to match in cmpExItem()
373 final DualNode cmpExNext(DualNode cmp, DualNode val) { in cmpExNext()
426 long deadline = (timed) ? System.nanoTime() + ns : 0L; in await() local
535 final DualNode cmpExTail(DualNode cmp, DualNode val) { in cmpExTail()
538 final DualNode cmpExHead(DualNode cmp, DualNode val) { in cmpExHead()
|
| D | SubmissionPublisher.java | 1098 final boolean weakCasCtl(int cmp, int val) { in weakCasCtl()
1111 final boolean casDemand(long cmp, long val) { in casDemand()
1479 long deadline = timed ? System.nanoTime() + nanos : 0L; in block() local
|
| /aosp_15_r20/libcore/ojluni/src/main/java/java/util/concurrent/ |
| H A D | LinkedTransferQueue.java | 370 final Object cmpExItem(Object cmp, Object val) { // try to match in cmpExItem()
373 final DualNode cmpExNext(DualNode cmp, DualNode val) { in cmpExNext()
426 long deadline = (timed) ? System.nanoTime() + ns : 0L; in await() local
535 final DualNode cmpExTail(DualNode cmp, DualNode val) { in cmpExTail()
538 final DualNode cmpExHead(DualNode cmp, DualNode val) { in cmpExHead()
|
| H A D | SubmissionPublisher.java | 1098 final boolean weakCasCtl(int cmp, int val) { in weakCasCtl()
1111 final boolean casDemand(long cmp, long val) { in casDemand()
1479 long deadline = timed ? System.nanoTime() + nanos : 0L; in block() local
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/20/libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | LinkedTransferQueue.java | 370 final Object cmpExItem(Object cmp, Object val) { // try to match in cmpExItem()
373 final DualNode cmpExNext(DualNode cmp, DualNode val) { in cmpExNext()
426 long deadline = (timed) ? System.nanoTime() + ns : 0L; in await() local
535 final DualNode cmpExTail(DualNode cmp, DualNode val) { in cmpExTail()
538 final DualNode cmpExHead(DualNode cmp, DualNode val) { in cmpExHead()
|
| D | SubmissionPublisher.java | 1098 final boolean weakCasCtl(int cmp, int val) { in weakCasCtl()
1111 final boolean casDemand(long cmp, long val) { in casDemand()
1479 long deadline = timed ? System.nanoTime() + nanos : 0L; in block() local
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio/src/ |
| D | channel.rs | 36 let val = if trimed_agent.is_empty() { in format_user_agent_string() localVariable
382 let val = match target { in optimize_for() localVariable
398 let val = match lb_policy { in load_balancing_policy() localVariable
707 let deadline = deadline.into(); in wait_for_connected() localVariable
|
| /aosp_15_r20/frameworks/base/services/tests/mockingservicestests/src/com/android/server/job/controllers/ |
| H A D | FlexibilityControllerTest.java | 242 private void setDeviceConfigInt(String key, int val) { in setDeviceConfigInt()
247 private void setDeviceConfigLong(String key, Long val) { in setDeviceConfigLong()
252 private void setDeviceConfigString(String key, String val) { in setDeviceConfigString()
631 long deadline = 100 * MINUTE_IN_MILLIS; in testCurPercent() local
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/context/ |
| D | context.go | 652 deadline time.Time member
730 key, val any member
|
| /aosp_15_r20/external/python/cpython3/Modules/ |
| D | signalmodule.c | 274 PyObject *exc, *val, *tb; in report_wakeup_write_error() local
291 PyObject *exc, *val, *tb; in report_wakeup_send_error() local
1266 _PyTime_t deadline = _PyDeadline_Init(timeout); local
|
| /aosp_15_r20/external/pytorch/torch/csrc/distributed/c10d/ |
| H A D | socket.cpp | 79 inline void setSocketError(int val) noexcept { in setSocketError()
452 auto deadline = Clock::now() + timeout; in waitForInput() local
|