| /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()
|