| /arkcompiler/runtime_core/runtime/ |
| D | thread_manager.h | 32 // This interval is required for waiting for threads to stop.
41 VM_THREAD = 4, // Includes VM threads
92 os << "ARK THREADS (" << threads_count_ << "):\n"; in EnumerateThreadsForDump()
197 // Some uninitialized threads may not have attached flag, in SatisfyTheMask()
199 // Newly created threads are using flag suspend new count. in SatisfyTheMask()
224 * Tries to stop all daemon threads in case there are no active basic threads
230 * Deregister all suspended threads including daemon threads.
243 …// * CREATED - wait until threads finish initializing which requires communication with ThreadMana… in CanDeregister()
245 // * TERMINATING - threads which requires communication with Runtime; in CanDeregister()
246 // * FINISHED threads should be deleted itself; in CanDeregister()
[all …]
|
| D | thread_manager.cpp | 83 … // assumes it stays registered; only threads in statuses FINISHED, IS_TERMINATED_LOOP and NATIVE in DeregisterSuspendedThreads()
105 // All threads except current are blocked (have BLOCKED or NATIVE status) in DeregisterSuspendedThreads()
106 LOG(DEBUG, RUNTIME) << "Potential deadlock with daemon threads is detected"; in DeregisterSuspendedThreads()
127 LOG(DEBUG, RUNTIME) << "Deadlock with daemon threads was not confirmed"; in StopThreadsOnDeadlock()
151 // First wait for non-daemon threads to finish in WaitForDeregistration()
156 // Then stop daemon threads in WaitForDeregistration()
159 // Finally wait until all threads are suspended in WaitForDeregistration()
162 // There are threads, which are not completely registered in WaitForDeregistration()
163 // We can not destroy other threads, as they may use shared data (waiting mutexes) in WaitForDeregistration()
190 // Suspend any future new threads in StopDaemonThreads()
[all …]
|
| D | thread_pool.h | 102 LOG(DEBUG, RUNTIME) << "Scale thread pool for " << new_n_threads << " new threads"; in Scale()
104 … LOG(ERROR, RUNTIME) << "Incorrect number of threads " << new_n_threads << " for thread pool"; in Scale()
108 // Need to add new threads. in Scale()
117 // Need to remove threads. in Scale()
129 // Same number of threads - do nothing. in Scale()
|
| D | lock_order_graph.cpp | 35 bool LockOrderGraph::CheckForTerminationLoops(const PandaList<MTManagedThread *> &threads, in CheckForTerminationLoops() argument
43 for (auto thread : threads) { in CheckForTerminationLoops()
88 // the node belongs to a loop (i.e., there is a deadlock with corresponding threads), or in CheckForTerminationLoops()
|
| D | options.yaml | 305 …description: Set number of additional GC helper threads. GC uses these threads to speed up collect…
329 …description: The max stack size for marking stage proceed in workers threads, if it exceeded, we w…
588 - name: verification-threads
591 description: number of verification threads
|
| /arkcompiler/runtime_core/libpandafile/tests/ |
| D | panda_cache_test.cpp | 274 std::thread threads[NUMBER_OF_READERS]; in TEST() local
277 threads[i] = std::thread(MethodReaderThread, &cache); in TEST()
280 threads[i].join(); in TEST()
290 std::thread threads[NUMBER_OF_READERS]; in TEST() local
293 threads[i] = std::thread(FieldReaderThread, &cache); in TEST()
296 threads[i].join(); in TEST()
306 std::thread threads[NUMBER_OF_READERS]; in TEST() local
309 threads[i] = std::thread(ClassReaderThread, &cache); in TEST()
312 threads[i].join(); in TEST()
|
| /arkcompiler/runtime_core/runtime/mem/gc/ |
| D | generational-gc-base.h | 129 // Atomic with relaxed order reason: memory accesses from different threads in RecordCountFreedYoung()
143 // Atomic with relaxed order reason: memory accesses from different threads in RecordSizeFreedYoung()
157 // Atomic with relaxed order reason: memory accesses from different threads in RecordCountMovedYoung()
171 // Atomic with relaxed order reason: memory accesses from different threads in RecordSizeMovedYoung()
185 // Atomic with relaxed order reason: memory accesses from different threads in RecordCountMovedTenured()
199 // Atomic with relaxed order reason: memory accesses from different threads in RecordSizeMovedTenured()
213 // Atomic with relaxed order reason: memory accesses from different threads in RecordCountFreedTenured()
227 // Atomic with relaxed order reason: memory accesses from different threads in RecordSizeFreedTenured()
|
| /arkcompiler/runtime_core/runtime/tests/ |
| D | multithreaded_intern_string_table_test.cpp | 194 std::array<std::thread, TEST_THREADS> threads; in TEST_F() local
206 … threads[i] = std::thread(TestConcurrentInsertion, std::ref(strings), std::ref(array_item), this); in TEST_F()
210 threads[i].join(); in TEST_F()
216 std::array<std::thread, TEST_THREADS> threads; in TEST_F() local
218 threads[i] = std::thread(TestThreadEntry, this); in TEST_F()
221 threads[i].join(); in TEST_F()
|
| D | allocator_test_base.h | 355 * \brief Simultaneously allocate/free objects in different threads
359 * @tparam THREADS_COUNT - the number of threads used in this test
367 * \brief Simultaneously allocate/free objects in different threads
370 * @tparam THREADS_COUNT - the number of threads used in this test
379 …\brief Simultaneously allocate objects and iterate over objects (in range too) in different threads
382 * @tparam THREADS_COUNT - the number of threads used in this test
391 * \brief Simultaneously allocate and collect objects in different threads
394 * @tparam THREADS_COUNT - the number of threads used in this test
397 * @param max_thread_with_collect - maximum threads which will call collect simultaneously
1042 … // Do while because other threads can use the whole pool before we try to allocate smth in it in MT_AllocRun()
[all …]
|
| D | mem_stats_test.cpp | 361 // order where threads observe all modifications in the same order in FillMemStatsForConcurrency()
364 // order where threads observe all modifications in the same order in FillMemStatsForConcurrency()
366 // Unlock all threads in FillMemStatsForConcurrency()
370 // consistent order where threads observe all modifications in the same order in FillMemStatsForConcurrency()
407 std::array<std::thread, NUM_THREADS> threads; in TEST_F() local
413 … threads[i] = std::thread(FillMemStatsForConcurrency, std::ref(stats), std::ref(ready_to_start), in TEST_F()
418 threads[i].join(); in TEST_F()
|
| D | thread_test.cpp | 30 * gtest ASSERT_DEATH doesn't work with multiple threads: in ThreadTest()
31 * "In particular, death tests don't like having multiple threads in the parent process" in ThreadTest()
|
| /arkcompiler/runtime_core/runtime/mem/ |
| D | rendezvous.h | 27 /** Meeting point for all managed threads.
38 // Wait until all threads release Mutator lock and acquires it for write;
40 // Ends safepoint (wakes up waiting threads, releases Mutator lock);
|
| D | rendezvous.cpp | 27 // Suspend all threads in SafepointBegin()
39 // Resume all threads in SafepointEnd()
|
| /arkcompiler/runtime_core/verification/verifier/ |
| D | verifier.cpp | 313 uint32_t threads = cli_options.GetThreads(); in Main() local
314 if (threads == 0) { in Main()
315 threads = std::thread::hardware_concurrency(); in Main()
317 if (threads == 0) { in Main()
318 threads = 1; in Main()
319 } else if (threads > MAX_THREADS) { in Main()
320 threads = MAX_THREADS; in Main()
323 runtime_options.SetVerificationThreads(threads); in Main()
|
| D | options.yaml | 141 - name: threads
144 …description: Number of verification threads. Use 0 for the system-specific default, usually 1 thre…
|
| /arkcompiler/ets_frontend/test262/ |
| D | run_test262.py | 71 parser.add_argument('--threads', default=DEFAULT_THREADS, type=int,
478 def get_timeout(args, threads): argument
479 timeout = DEFAULT_TIMEOUT * threads
486 threads = DEFAULT_THREADS
487 if args.threads:
488 threads = args.threads
489 return threads
560 threads = get_threads(args)
561 timeout = get_timeout(args, threads)
568 test_cmd.append(f"--threads={threads}")
|
| D | README.md | 23 [--threads THREADS] [--hostArgs HOSTARGS]
47 --threads THREADS Run this many tests in parallel. Note that the browser
149 --threads=15
|
| D | harness.patch | 32 - Number(argv.threads), hostType, argv.hostArgs, hostPath, { tempDir, timeout, transform }
44 + Number(argv.threads), hostType, argv.hostArgs, hostPath, { tempDir, timeout, transform, test262D…
100 .nargs('threads', 1)
101 .default('threads', 1)
102 .alias('threads', 't')
|
| /arkcompiler/runtime_core/docs/diagrams/ |
| D | mm-components.pucomponent | 21 [Daemon threads]
24 [ReferenceProcessor] ..> [Daemon threads]
|
| /arkcompiler/runtime_core/libpandabase/mem/ringbuf/ |
| D | lock_free_ring_buffer.h | 39 // Atomic with release order reason: threads should see correct initialization in LockFreeBuffer()
41 // Atomic with release order reason: threads should see correct initialization in LockFreeBuffer()
95 // Atomic with release order reason: let others threads to see the latest value in TryPop()
|
| /arkcompiler/runtime_core/libpandabase/tests/ |
| D | alloc_tracker_test.cpp | 130 std::vector<std::thread> threads; in TEST() local
132 threads.emplace_back( in TEST()
142 for (auto &thread : threads) { in TEST()
|
| /arkcompiler/runtime_core/libpandabase/os/ |
| D | mutex.h | 81 // This field is set to false in case of deadlock with daemon threads (only daemon threads
83 // those threads ignoring failures on lock structures destructors.
|
| /arkcompiler/runtime_core/runtime/mem/gc/gc-hung/ |
| D | gc_hung.cpp | 174 // check threads suspend while get "Locks::mutator_lock->WriteLock()", and report to hung
175 void GcHung::CheckSuspend(const PandaList<MTManagedThread *> &threads, uint64_t start_time) in CheckSuspend() argument
179 for (const auto &thread : threads) { in CheckSuspend()
285 void GcHung::Check(const PandaList<MTManagedThread *> &threads, uint64_t start_time) in Check() argument
288 instance_->CheckSuspend(threads, start_time); in Check()
|
| D | gc_hung.h | 81 static void Check(const PandaList<MTManagedThread *> &threads, uint64_t start_time);
108 void CheckSuspend(const PandaList<MTManagedThread *> &threads, uint64_t start_time);
|
| /arkcompiler/runtime_core/runtime/arch/ |
| D | memory_helpers.h | 35 …e while FullMemoryBarrier callers expect all previous reads and writes to be visible in all threads
|