| /third_party/openssl/Configurations/ |
| D | 10-main.conf | 242 cflags => add(threads("-pthread")),
244 ex_libs => add(threads("-pthread")),
265 cflags => add_before("-m64", threads("-pthread")),
267 ex_libs => add(threads("-pthread")),
295 cppflags => add(threads("-D_REENTRANT")),
298 lflags => add(threads("-mt")),
299 ex_libs => add(threads("-lpthread")),
315 cflags => add(threads("-pthread")),
317 ex_libs => add(threads("-pthread")),
353 cppflags => add(threads("-D_REENTRANT")),
[all …]
|
| /third_party/node/deps/openssl/openssl/Configurations/ |
| D | 10-main.conf | 245 cflags => add(threads("-pthread")),
247 ex_libs => add(threads("-pthread")),
268 cflags => add_before("-m64", threads("-pthread")),
270 ex_libs => add(threads("-pthread")),
298 cppflags => add(threads("-D_REENTRANT")),
301 lflags => add(threads("-mt")),
302 ex_libs => add(threads("-lpthread")),
318 cflags => add(threads("-pthread")),
320 ex_libs => add(threads("-pthread")),
356 cppflags => add(threads("-D_REENTRANT")),
[all …]
|
| /third_party/glfw/tests/ |
| D | threads.c | 78 Thread threads[] = in main() local
84 const int count = sizeof(threads) / sizeof(Thread); in main()
95 threads[i].window = glfwCreateWindow(200, 200, in main()
96 threads[i].title, in main()
98 if (!threads[i].window) in main()
104 glfwSetWindowPos(threads[i].window, 200 + 250 * i, 200); in main()
105 glfwShowWindow(threads[i].window); in main()
108 glfwMakeContextCurrent(threads[0].window); in main()
114 if (thrd_create(&threads[i].id, thread_main, threads + i) != in main()
130 if (glfwWindowShouldClose(threads[i].window)) in main()
[all …]
|
| /third_party/ltp/testcases/kernel/syscalls/tgkill/ |
| D | tgkill01.c | 25 static struct thread_state *threads; variable
66 if (threads[i].tid == -1) in stop_threads()
69 SAFE_PTHREAD_JOIN(threads[i].thread, NULL); in stop_threads()
70 threads[i].tid = -1; in stop_threads()
73 if (threads) in stop_threads()
74 free(threads); in stop_threads()
84 TEST(sys_tgkill(getpid(), threads[i].tid, SIGUSR1)); in run()
93 if (!pthread_equal(sigusr1_thread, threads[i].thread)) { in run()
109 threads = SAFE_MALLOC(sizeof(*threads) * n_threads); in setup()
117 threads[i].tid = -1; in setup()
[all …]
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threads-smp/ |
| D | README.md | 1 # lws minimal ws server (threads) + SMP
3 This demonstrates both independent threads creating content
4 as in the -threads example, and multiple service threads
21 $ ./lws-minimal-ws-server-threads-smp
22 [2019/01/28 06:59:17:4217] USER: LWS minimal ws server + threads + smp | visit http://localhost:7681
23 [2019/01/28 06:59:17:4219] NOTICE: Service threads: 2
32 Two lws service threads are started.
34 Two separate asynchronous threads generate strings and add them to a ringbuffer,
35 signalling all lws service threads to send new entries to all the browser windows.
38 and hook it up to the lws service threads.
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threads-foreign-libuv-smp/ |
| D | README.md | 1 # lws minimal ws server (threads) + SMP
3 This demonstrates both independent threads creating content as in the
4 -threads example, multiple service threads as in the http-server-smp
21 $ ./lws-minimal-ws-server-threads-smp
22 [2019/01/28 06:59:17:4217] USER: LWS minimal ws server + threads + smp | visit http://localhost:7681
23 [2019/01/28 06:59:17:4219] NOTICE: Service threads: 2
32 Two lws service threads are started.
34 Two separate asynchronous threads generate strings and add them to a ringbuffer,
35 signalling all lws service threads to send new entries to all the browser windows.
38 and hook it up to the lws service threads.
|
| /third_party/protobuf/objectivec/Tests/ |
| D | GPBConcurrencyTests.m | 68 - (void)startThreads:(NSArray *)threads {
69 for (NSThread *thread in threads) {
74 - (void)joinThreads:(NSArray *)threads {
75 for (NSThread *thread in threads) {
91 NSArray *threads =
94 [self startThreads:threads];
95 [self joinThreads:threads];
111 NSArray *threads =
114 [self startThreads:threads];
115 [self joinThreads:threads];
[all …]
|
| /third_party/icu/icu4j/main/tests/collate/src/com/ibm/icu/dev/test/collator/ |
| D | CollationThreadTest.java | 226 private void runThreads(Thread[] threads, Control control) { in runThreads() argument
227 for (int i = 0; i < threads.length; ++i) { in runThreads()
228 threads[i].start(); in runThreads()
241 for (int i = 0; i < threads.length; ++i) { in runThreads()
242 threads[i].join(); in runThreads()
259 Thread[] threads = new Thread[10]; in testThreads() local
260 for (int i = 0; i < threads.length; ++i) { in testThreads()
271 threads[i] = new Thread(test); in testThreads()
274 runThreads(threads, control); in testThreads()
284 Thread[] threads = new Thread[10]; in testFrozen() local
[all …]
|
| /third_party/icu/ohos_icu4j/src/main/tests/ohos/global/icu/dev/test/collator/ |
| D | CollationThreadTest.java | 229 private void runThreads(Thread[] threads, Control control) { in runThreads() argument
230 for (int i = 0; i < threads.length; ++i) { in runThreads()
231 threads[i].start(); in runThreads()
244 for (int i = 0; i < threads.length; ++i) { in runThreads()
245 threads[i].join(); in runThreads()
262 Thread[] threads = new Thread[10]; in testThreads() local
263 for (int i = 0; i < threads.length; ++i) { in testThreads()
274 threads[i] = new Thread(test); in testThreads()
277 runThreads(threads, control); in testThreads()
287 Thread[] threads = new Thread[10]; in testFrozen() local
[all …]
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
| D | marl_bench.h | 68 for (unsigned int threads = 1U; threads <= numLogicalCPUs; threads++) { in args() local
69 b->Args({NumTasks, threads}); in args()
72 for (unsigned int threads = 1U; threads <= numLogicalCPUs; threads *= 2) { in args() local
73 b->Args({NumTasks, threads}); in args()
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_atfork/ |
| D | 1-2.c | 89 static pthread_t threads[3]; variable
96 threads[0] = pthread_self(); in prepare()
101 threads[1] = pthread_self(); in parent()
106 threads[2] = pthread_self(); in child()
137 if (!pthread_equal(ch, threads[0])) { in threaded()
142 if (!pthread_equal(pthread_self(), threads[2])) { in threaded()
151 if (!pthread_equal(ch, threads[0])) { in threaded()
156 if (!pthread_equal(pthread_self(), threads[1])) { in threaded()
|
| /third_party/musl/libc-test/src/functional/ |
| D | test-malloc-info-stats-print.h | 38 char threads[SIZES_COUNT][MAX_TID_LEN + 1]; member
81 snprintf(test_results.threads[0], MAX_TID_LEN, "%d", (pid_t) syscall(__NR_gettid)); in get_main_thread_test_results()
115 pthread_t threads[SIZES_COUNT]; in get_different_threads_test_results() local
117 pthread_create(&threads[i], NULL, allocate_wait_free, &thread_data[i]); in get_different_threads_test_results()
122 snprintf(test_results.threads[i], MAX_TID_LEN, "%d", thread_data[i].self_id); in get_different_threads_test_results()
128 pthread_join(threads[i], NULL); in get_different_threads_test_results()
148 …populate_thread_stats(test_results->stats_before_allocations, test_results->threads[0], &stats_bef… in validate_main_thread_test_results()
149 …populate_thread_stats(test_results->stats_after_allocations, test_results->threads[0], &stats_afte… in validate_main_thread_test_results()
150 populate_thread_stats(test_results->stats_after_free, test_results->threads[0], &stats_after_free); in validate_main_thread_test_results()
174 …result &= populate_thread_stats(test_results->stats_after_allocations, test_results->threads[i], &… in validate_different_threads_test_results()
[all …]
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/ |
| D | mutex_test.cc | 47 int threads) { in CreatePool() argument
48 return absl::make_unique<absl::synchronization_internal::ThreadPool>(threads); in CreatePool()
69 int threads; member
164 mc.target += cxt->threads; in TestAwait()
181 target += cxt->threads; in TestSignalAll()
187 ABSL_RAW_CHECK(cxt->threads == 2, "TestSignal should use 2 threads"); in TestSignal()
199 target += cxt->threads; in TestSignal()
216 target += cxt->threads; in TestCVTimeout()
225 ABSL_RAW_CHECK(cxt->threads > 2, "TestTime should use more than 2 threads"); in TestTime()
299 ABSL_RAW_CHECK(cxt->g0 == cxt->threads, "TestTime failed"); in TestTime()
[all …]
|
| /third_party/libuv/test/ |
| D | benchmark-async.c | 76 struct ctx* threads; in test_async() local
81 threads = calloc(nthreads, sizeof(threads[0])); in test_async()
82 ASSERT_NOT_NULL(threads); in test_async()
85 ctx = threads + i; in test_async()
100 ASSERT(0 == uv_thread_join(&threads[i].thread)); in test_async()
105 ctx = threads + i; in test_async()
117 free(threads); in test_async()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-threads/ |
| D | CMakeLists.txt | 1 project(lws-minimal-secure-streams-threads C)
19 add_executable(${PROJECT_NAME} minimal-secure-streams-threads.c)
26 add_test(NAME ss-threads COMMAND
28 $<TARGET_FILE:lws-minimal-secure-streams-threads>)
31 add_test(NAME ss-threads COMMAND lws-minimal-secure-streams-threads)
33 set_tests_properties(ss-threads
35 …ORKING_DIRECTORY ${CMAKE_SOURCE_DIR}/minimal-examples/secure-streams/minimal-secure-streams-threads
51 add_executable(${PROJECT_NAME}-client minimal-secure-streams-threads.c)
93 $<TARGET_FILE:lws-minimal-secure-streams-threads-client> -i +${CTEST_SOCKET_PATH})
95 …add_test(NAME sspcthreads_sspc COMMAND lws-minimal-secure-streams-threads-client -i +${CTEST_SOCKE…
[all …]
|
| /third_party/vk-gl-cts/framework/delibs/decpp/ |
| D | deSpinBarrier.cpp | 238 std::vector<TestThread*> threads (numThreads, static_cast<TestThread*>(DE_NULL)); in multiThreadTest() local
242 threads[ndx] = new TestThread(barrier, &sharedVar, numThreads, ndx); in multiThreadTest()
243 DE_TEST_ASSERT(threads[ndx]); in multiThreadTest()
244 threads[ndx]->start(); in multiThreadTest()
249 threads[ndx]->join(); in multiThreadTest()
250 delete threads[ndx]; in multiThreadTest()
312 std::vector<TestExitThread*> threads (numThreads, static_cast<TestExitThread*>(DE_NULL)); in multiThreadRemoveTest() local
316 threads[ndx] = new TestExitThread(barrier, numThreads, ndx, waitMode); in multiThreadRemoveTest()
317 DE_TEST_ASSERT(threads[ndx]); in multiThreadRemoveTest()
318 threads[ndx]->start(); in multiThreadRemoveTest()
[all …]
|
| /third_party/icu/ohos_icu4j/src/main/tests/ohos/global/icu/dev/test/translit/ |
| D | ThreadTest.java | 28 private ArrayList<Worker> threads = new ArrayList<Worker>(); field in ThreadTest
40 threads.add(thread); in TestThreads()
44 for (Worker thread: threads) { in TestThreads()
83 ArrayList<Thread> threads = new ArrayList<Thread>(); in TestAnyTranslit() local
85 threads.add(new Thread() { in TestAnyTranslit()
92 for (Thread th:threads) { in TestAnyTranslit()
95 for (Thread th:threads) { in TestAnyTranslit()
|
| /third_party/icu/icu4j/main/tests/translit/src/com/ibm/icu/dev/test/translit/ |
| D | ThreadTest.java | 25 private ArrayList<Worker> threads = new ArrayList<Worker>(); field in ThreadTest
37 threads.add(thread); in TestThreads()
41 for (Worker thread: threads) { in TestThreads()
80 ArrayList<Thread> threads = new ArrayList<Thread>(); in TestAnyTranslit() local
82 threads.add(new Thread() { in TestAnyTranslit()
89 for (Thread th:threads) { in TestAnyTranslit()
92 for (Thread th:threads) { in TestAnyTranslit()
|
| /third_party/skia/src/core/ |
| D | SkExecutor.cpp | 73 explicit SkThreadPool(int threads, bool allowBorrowing) : fAllowBorrowing(allowBorrowing) { in SkThreadPool() argument
74 for (int i = 0; i < threads; i++) { in SkThreadPool()
142 std::unique_ptr<SkExecutor> SkExecutor::MakeFIFOThreadPool(int threads, bool allowBorrowing) { in MakeFIFOThreadPool() argument
144 return std::make_unique<SkThreadPool<WorkList>>(threads > 0 ? threads : num_cores(), in MakeFIFOThreadPool()
147 std::unique_ptr<SkExecutor> SkExecutor::MakeLIFOThreadPool(int threads, bool allowBorrowing) { in MakeLIFOThreadPool() argument
149 return std::make_unique<SkThreadPool<WorkList>>(threads > 0 ? threads : num_cores(), in MakeLIFOThreadPool()
|
| /third_party/mbedtls/programs/ssl/ |
| D | ssl_pthread_server.c | 107 static pthread_info_t threads[MAX_NUM_THREADS]; variable
259 if (threads[i].active == 0) { in thread_create()
263 if (threads[i].data.thread_complete == 1) { in thread_create()
265 pthread_join(threads[i].thread, NULL); in thread_create()
266 memset(&threads[i], 0, sizeof(pthread_info_t)); in thread_create()
278 memcpy(&threads[i].data, &base_info, sizeof(base_info)); in thread_create()
279 threads[i].active = 1; in thread_create()
280 memcpy(&threads[i].data.client_fd, client_fd, sizeof(mbedtls_net_context)); in thread_create()
282 if ((ret = pthread_create(&threads[i].thread, NULL, handle_ssl_connection, in thread_create()
283 &threads[i].data)) != 0) { in thread_create()
[all …]
|
| /third_party/icu/icu4c/source/test/intltest/ |
| D | tsmthred.cpp | 112 SimpleThread *threads[THREADTEST_NRTHREADS]; in TestThreads() local
119 threads[i] = new TestThreadsThread(&threadTestChars[i]); in TestThreads()
126 if (threads[i]->start() != 0) { in TestThreads()
139 threads[i]->join(); in TestThreads()
143 delete threads[i]; in TestThreads()
216 TestArabicShapeThreads threads[30]; in TestArabicShapingThreads() local
221 for(i=0; i < UPRV_LENGTHOF(threads); i++) { in TestArabicShapingThreads()
222 if (threads[i].start() != 0) { in TestArabicShapingThreads()
227 for(i=0; i < UPRV_LENGTHOF(threads); i++) { in TestArabicShapingThreads()
228 threads[i].join(); in TestArabicShapingThreads()
[all …]
|
| /third_party/ffmpeg/tests/fate/ |
| D | lavf-container.mak | 38 fate-lavf-avi fate-lavf-nut: CMD = lavf_container "" "-c:a mp2 -ar 44100 -threads 1"
44 fate-lavf-gxf: CMD = lavf_container "-ar 48000" "-r 25 -s pal -ac 1 -threads 1"
45 fate-lavf-gxf_pal: CMD = lavf_container_timecode_nodrop "-ar 48000 -r 25 -s pal -ac 1 -threads 1 -f…
46 fate-lavf-gxf_ntsc: CMD = lavf_container_timecode_drop "-ar 48000 -s ntsc -ac 1 -threads 1 -f gxf"
47 fate-lavf-ismv: CMD = lavf_container_timecode "-an -write_tmcd 1 -c:v mpeg4 -threads 1"
48 fate-lavf-mkv: CMD = lavf_container "" "-c:a mp2 -c:v mpeg4 -ar 44100 -threads 1"
49 fate-lavf-mkv_attachment: CMD = lavf_container_attach "-c:a mp2 -c:v mpeg4 -threads 1 -f matroska"
50 …-lavf-mov: CMD = lavf_container_timecode "-movflags +faststart -c:a pcm_alaw -c:v mpeg4 -threads 1"
51 …ov_rtphint: CMD = lavf_container "" "-movflags +rtphint -c:a pcm_alaw -c:v mpeg4 -threads 1 -f mov"
52 fate-lavf-mp4: CMD = lavf_container_timecode "-c:v mpeg4 -an -threads 1"
[all …]
|
| /third_party/skia/tools/calmbench/ |
| D | ab.py | 93 if args.threads == -1:
94 args.threads = 1
96 args.threads = max(1, multiprocessing.cpu_count() / 2)
149 self.threads = []
152 if len(self.threads) >= args.threads:
156 self.threads.append(t)
163 while len(self.threads) > 0:
167 " (%d threads running)" % len(self.threads) +
178 for t in self.threads:
182 for t in self.threads:
[all …]
|
| /third_party/benchmark/test/ |
| D | benchmark_test.cc | 166 int thread_size = static_cast<int>(size) / state.threads(); in BM_ParallelMemset()
234 assert(st.threads() == 1 || st.threads() == 2 || st.threads() == 3); in BM_DenseThreadRanges()
237 assert(st.threads() == 1 || st.threads() == 3 || st.threads() == 4); in BM_DenseThreadRanges()
240 assert(st.threads() == 5 || st.threads() == 8 || st.threads() == 11 || in BM_DenseThreadRanges()
241 st.threads() == 14); in BM_DenseThreadRanges()
|
| /third_party/node/deps/uv/src/ |
| D | threadpool.c | 38 static uv_thread_t* threads; variable
179 if (uv_thread_join(threads + i)) in uv__threadpool_cleanup()
182 if (threads != default_threads) in uv__threadpool_cleanup()
183 uv__free(threads); in uv__threadpool_cleanup()
188 threads = NULL; in uv__threadpool_cleanup()
207 threads = default_threads; in init_threads()
209 threads = uv__malloc(nthreads * sizeof(threads[0])); in init_threads()
210 if (threads == NULL) { in init_threads()
212 threads = default_threads; in init_threads()
230 if (uv_thread_create(threads + i, worker, &sem)) in init_threads()
|