/arkcompiler/runtime_core/static_core/plugins/ets/tests/ets_test_suite/atomics/ |
D | concurrent_wait_store_notify.ets | 16 // 1. If this test prints "1 ok" then the order of events is as follows: wait -> store -> notify 17 // 2. "0 not-equal": store -> wait -> notify, or store -> notify -> wait 33 let res = Atomics.wait(arr, 0, 0) as string 41 wait() 48 function wait(): int {
|
D | skipped_cyclic_barrier.ets | 33 wait() 34 c.println("wait completed") 46 function wait() { 51 // wait until is 0 54 Atomics.wait(arr, 0, cur)
|
D | concurrent_store_load.ets | 27 wait() 37 function wait(): int {
|
D | concurrent_increment.ets | 28 wait() 40 function wait(): int {
|
D | skipped_rendezvous_channel.ets | 57 Atomics.wait(arr, 0, oldValue) 73 Atomics.wait(arr, 0, 0)
|
D | CMakeLists.txt | 26 # --- Non-concurrent wait/notify tests 32 # --- Concurrent wait/notify tests
|
D | nonconcurrent_wait_not_equal.ets | 20 let x = Atomics.wait(arr, 0, 1)
|
D | skipped_wait_timeout.ets | 27 let reason = Atomics.wait(arr, 0, 0, 10)
|
D | nonconcurrent_wait_i32_not_equal.ets | 23 let x = Atomics.wait(arr, 0, 0)
|
D | nonconcurrent_wait_i64_not_equal.ets | 23 let x = Atomics.wait(arr, 0, 0)
|
D | concurrent_countdownlatch.ets | 36 Atomics.wait(arr, 0, cur)
|
/arkcompiler/ets_runtime/test/workloadtest/ |
D | work_load.py | 72 process.wait() 79 process.wait() 98 proc.wait() 104 proc.wait() 125 process.wait()
|
/arkcompiler/runtime_core/libpandabase/tests/ |
D | base_thread_test.cpp | 46 cv.wait(lk, [] { return operated; }); in ThreadFunc() 78 cv.wait(lk, [] { return updated; }); in __anon8d86b7760202()
|
/arkcompiler/ets_frontend/ets2panda/compiler/core/ |
D | compileQueue.cpp | 70 …queue->jobsAvailable_.wait(lock, [queue]() { return queue->terminate_ || queue->jobsCount_ != 0; }… in Worker() 111 jobsFinished_.wait(lock, [this]() { return activeWorkers_ == 0 && jobsCount_ == 0; }); in Wait()
|
D | compileJob.cpp | 25 cond_.wait(lock, [this] { return dependencies_ == 0; }); in Run()
|
/arkcompiler/ets_frontend/es2panda/util/ |
D | workerQueue.cpp | 63 …queue->jobsAvailable_.wait(lock, [queue]() { return queue->terminate_ || queue->jobsCount_ != 0; }… in Worker() 104 jobsFinished_.wait(lock, [this]() { return activeWorkers_ == 0 && jobsCount_ == 0; }); in Wait()
|
/arkcompiler/ets_frontend/es2panda/compiler/core/ |
D | compileQueue.cpp | 38 cond_.wait(lock, [this] { return dependencies_ == 0; }); in Run() 58 cond_.wait(lock, [this] { return dependencies_ == 0; }); in Run()
|
/arkcompiler/runtime_core/static_core/plugins/ets/stdlib/escompat/ |
D | Atomics.ets | 262 public static wait(typedArray: Int32Array, offset: int, value: int): string { 275 public static wait(typedArray: Int32Array, offset: int, value: int, timeout: long): string { 283 … * Notifies (wakes up) threads that are suspended by the Atomics.wait() calls at the given index. 286 …* Note: This method also wakes up threads suspended by the BigInt64Array Atomics.wait(t64, offset6… 357 public static wait(typedArray: BigInt64Array, offset: int, value: long): string { 370 public static wait(typedArray: BigInt64Array, offset: int, value: long, timeout: long): string { 378 … * Notifies (wakes up) threads that are suspended by the Atomics.wait() calls at the given index. 381 …* Note: This method also wakes up threads suspended by the Int32Array Atomics.wait(t32, offset32) …
|
/arkcompiler/runtime_core/static_core/runtime/tests/ |
D | multithreaded_intern_string_table_test.cpp | 93 preCv_.wait(lk); in PreCheck() 131 postCv_.wait(lk); in PostFree()
|
/arkcompiler/runtime_core/docs/diagrams/ |
D | gc-trigger-sequence-OOM.pusequence | 29 Allocator -> GCTaskQueue: Add new GC task and wait for GC
|
/arkcompiler/runtime_core/static_core/docs/diagrams/ |
D | gc-trigger-sequence-OOM.plantuml | 29 Allocator -> GCTaskQueue: Add new GC task and wait for GC
|
/arkcompiler/ets_frontend/es2panda/scripts/ |
D | generate_js_bytecode.py | 61 proc.wait()
|
/arkcompiler/ets_frontend/es2panda/aot/ |
D | emitFiles.cpp | 107 cond_.wait(lock, [this] { return dependencies_ == 0; }); in Run()
|
/arkcompiler/ets_runtime/test/regresstest/ |
D | run_regress_test.py | 122 ret = proc.wait() 270 ret = proc.wait() 280 proc.wait() 286 proc.wait()
|
/arkcompiler/toolchain/tooling/ |
D | protocol_handler.cpp | 63 requestQueueCond_.wait(queueLock); in ProcessCommand()
|