Home
last modified time | relevance | path

Searched refs:threads (Results 1 – 25 of 48) sorted by relevance

12

/packages/services/Car/tools/cpu_perf/
Dperfetto_cpu_analysis.py96 self.threads = [] # ThreadInfo
99 threads = list(filter(
101 self.threads))
103 return threads
120 self.threads.sort(reverse = True, key = lambda p : p.getTotalCycles())
121 for t in self.threads:
201 threads = p.get_filtered_threads(filterThreads[name])
203 for t in threads:
268 for t in p.threads:
273 info.threads.append(thread_info)
/packages/modules/NeuralNetworks/runtime/test/
DTestOpenmpSettings.cpp67 std::vector<std::thread> threads; in TEST_F() local
72 threads.push_back(std::thread([sleepFor]() { in TEST_F()
89 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
DTestGenerated.cpp357 std::vector<std::thread> threads; in executeMultithreadedOwnCompilation() local
359 threads.push_back(std::thread([&]() { executeOnce(model, testModel); })); in executeMultithreadedOwnCompilation()
361 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in executeMultithreadedOwnCompilation()
371 std::vector<std::thread> threads; in executeMultithreadedSharedCompilation() local
373 threads.push_back( in executeMultithreadedSharedCompilation()
376 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in executeMultithreadedSharedCompilation()
DSupportLibraryTestGenerated.cpp442 std::vector<std::thread> threads; in executeMultithreadedOwnCompilation() local
444 threads.push_back(std::thread([&]() { executeOnce(model, testModel); })); in executeMultithreadedOwnCompilation()
446 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in executeMultithreadedOwnCompilation()
475 std::vector<std::thread> threads; in executeMultithreadedSharedCompilation() local
477 threads.push_back( in executeMultithreadedSharedCompilation()
480 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in executeMultithreadedSharedCompilation()
/packages/modules/Bluetooth/system/stack/test/btm/
Dstack_btm_dm_inq_db_test.cc122 threads[i] = thread_new(name.c_str()); in setup_thread()
128 thread_free(threads[i]); in teardown_thread()
132 thread_t* threads[kNumberOfThreads]; member in BtmDmInqDbThreadedTest
175 thread_post(threads[i], allocate_db_entry, static_cast<void*>(data))); in TEST_F()
219 thread_post(threads[i], check_address, static_cast<void*>(data))); in TEST_F()
/packages/modules/DnsResolver/tests/
Dresolv_stress_test.cpp48 std::vector<std::thread> threads(num_threads); in RunGetAddrInfoStressTest() local
49 for (std::thread& thread : threads) { in RunGetAddrInfoStressTest()
71 for (std::thread& thread : threads) { in RunGetAddrInfoStressTest()
Dresolv_cache_unit_test.cpp462 std::vector<std::thread> threads(5); in TEST_F() local
463 for (std::thread& thread : threads) { in TEST_F()
492 for (std::thread& thread : threads) { in TEST_F()
505 std::vector<std::thread> threads(5); in TEST_F() local
506 for (std::thread& thread : threads) { in TEST_F()
522 for (std::thread& thread : threads) { in TEST_F()
536 std::vector<std::thread> threads(5); in TEST_F() local
537 for (std::thread& thread : threads) { in TEST_F()
559 for (std::thread& thread : threads) { in TEST_F()
/packages/modules/UprobeStats/src/
DUprobeStats.cpp115 std::vector<std::thread> threads; in main() local
121 threads.emplace_back(doPoll, poll_args); in main()
123 for (auto &thread : threads) { in main()
/packages/providers/ContactsProvider/tests/src/com/android/providers/contacts/
DContactsDatabaseHelperTest.java259 final Thread[] threads = new Thread[NUM_THREADS]; in testGetMimeTypeId_conflict() local
260 for (int i = 0; i < threads.length; i++) { in testGetMimeTypeId_conflict()
261 threads[i] = new Thread(r); in testGetMimeTypeId_conflict()
262 threads[i].setDaemon(true); in testGetMimeTypeId_conflict()
264 for (int i = 0; i < threads.length; i++) { in testGetMimeTypeId_conflict()
265 threads[i].start(); in testGetMimeTypeId_conflict()
267 for (int i = 0; i < threads.length; i++) { in testGetMimeTypeId_conflict()
269 threads[i].join(); in testGetMimeTypeId_conflict()
/packages/modules/Connectivity/tests/common/java/android/net/metrics/
DIpConnectivityLogTest.java97 final Thread[] threads = new Thread[nCallers]; in testLoggingEventsWithMultipleCallers() local
100 threads[i] = new Thread(() -> { in testLoggingEventsWithMultipleCallers()
109 threads[i].start(); in testLoggingEventsWithMultipleCallers()
112 for (Thread thread : threads) { in testLoggingEventsWithMultipleCallers()
/packages/modules/GeoTZ/
Drun-data-pipeline.sh167 --num-threads ${STEP1_THREAD_COUNT} \
203 --num-threads ${STEP3_THREAD_COUNT} \
221 --num-threads ${STEP4_THREAD_COUNT} \
239 --num-threads ${STEP5_THREAD_COUNT} \
/packages/modules/NetworkStack/tests/integration/signature/android/net/netlink/
DInetDiagSocketIntegrationTest.java205 final Thread[] threads = new Thread[numThreads]; in testB141603906() local
208 threads[i] = new Thread(() -> { in testB141603906()
215 for (Thread thread : threads) { in testB141603906()
219 for (Thread thread : threads) { in testB141603906()
/packages/modules/DnsResolver/
DREADME-DoT.md45 This code creates O(1) threads per socket, and does not create a new thread for each
58 We need to pass messages between threads using a pipe, and not a condition variable
61 up on inputs from the query threads. Therefore, inputs from the query
62 threads have to arrive on a socket, so that `poll()` can listen for them.
63 (There can only be a single thread because [you can't use different threads
64 to read and write in OpenSSL](https://www.openssl.org/blog/blog/2017/02/21/threads/)).
DDnsQueryLogTest.cpp91 std::vector<std::thread> threads(threadNum); in TEST_F() local
94 for (auto& thread : threads) { in TEST_F()
102 for (auto& thread : threads) { in TEST_F()
/packages/modules/Virtualization/authfs/src/fusefs/
Dmount.rs39 threads: Option<NonZeroU8>, in mount_and_enter_message_loop()
69 if let Some(num) = threads { in mount_and_enter_message_loop()
/packages/modules/Bluetooth/system/gd/docs/architecture/
Darchitecture.md10 First of all, the GD stack does not build on concepts of threads. Instead, it
12 it still needs to interact with processes and threads before achieving the
49 threads may exist in this process for various reasons. The GD stack runs
56 * Reduce the number of threads as much as possible to simplify synchronization
57 * Do blocking I/O operations in separate threads
60 * Move alarm and timer mechanisms to their calling threads to avoid a separate
64 * Prefer data passing over data sharing among threads to reduce locking and
67 After above optimization, we are left with five main types of threads within the
75 to bind handlers to different threads and that should not affect the overall
/packages/modules/StatsD/statsd/tests/utils/
DMultiConditionTrigger_test.cpp54 vector<thread> threads; in TEST() local
59 threads.emplace_back([&done, &conditionName, &trigger, i] { in TEST()
77 threads[i].join(); in TEST()
/packages/modules/GeoTZ/data_pipeline/src/test/java/com/android/timezone/location/data_pipeline/steps/geojsontz_to_tzs2polygons/
DGeoJsonTzToTzS2PolygonsTest.java69 final int threads = 1; in regressionTest() local
74 "--num-threads", Integer.toString(threads), in regressionTest()
/packages/modules/GeoTZ/data_pipeline/src/test/java/com/android/timezone/location/data_pipeline/steps/tzs2polygons_tzs2cellunions/
DTzS2PolygonsToTzS2CellUnionsTest.java67 final int threads = 1; in regressionTest() local
73 "--num-threads", Integer.toString(threads), in regressionTest()
/packages/modules/GeoTZ/data_pipeline/src/test/java/com/android/timezone/location/data_pipeline/steps/tzs2cellunions_to_tzs2ranges/
DTzS2CellUnionsToTzS2RangesTest.java67 final int threads = 1; in regressionTest() local
73 "--num-threads", Integer.toString(threads), in regressionTest()
/packages/modules/GeoTZ/data_pipeline/src/test/java/com/android/timezone/location/data_pipeline/steps/mergetzs2ranges/
DMergeTzS2RangesTest.java75 final int threads = 1; in regressionTest() local
85 "--num-threads", Integer.toString(threads), in regressionTest()
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/mapclient/
DMapClientContent.java473 String threads = new String(); in clearMessages() local
478 threads += threadCursor.getInt(threadCursor.getColumnIndex(Threads._ID)) + ", "; in clearMessages()
490 if (threads.length() > 2) { in clearMessages()
491 threads = threads.substring(0, threads.length() - 2); in clearMessages()
492 resolver.delete(Threads.CONTENT_URI, Threads._ID + " IN (" + threads + ")", null); in clearMessages()
/packages/modules/Connectivity/thread/tests/integration/src/android/net/thread/
DServiceDiscoveryTest.java355 final ArrayList<Thread> threads = new ArrayList<>(); in discoveryProxy_multipleClientsBrowseAndResolveServiceOverMdns() local
373 threads.add(new Thread(task)); in discoveryProxy_multipleClientsBrowseAndResolveServiceOverMdns()
375 for (Thread thread : threads) { in discoveryProxy_multipleClientsBrowseAndResolveServiceOverMdns()
378 for (Thread thread : threads) { in discoveryProxy_multipleClientsBrowseAndResolveServiceOverMdns()
/packages/modules/Bluetooth/system/blueberry/grpc/
Dblueberry_device_controller.py27 futures.ThreadPoolExecutor(max_workers=FLAGS.threads),
/packages/services/Car/car_product/build/
Dcar_system_ext.mk39 dalvik.vm.dex2oat-threads=2 \

12