Searched refs:NUM_THREADS (Results 1 – 6 of 6) sorted by relevance
93 #define NUM_THREADS 8 macro281 static sem_t chunk_sems[NUM_THREADS - 1][NUM_CHUNKS];300 uint64_t mark = ((thread_num == (NUM_THREADS - 1) ? in marker_fill()321 marker_fill(desired_buf, chunk_start, size, NUM_THREADS - 1); in verify_file()403 if (thread_num < NUM_THREADS - 1) { in worker()419 pthread_t threads[NUM_THREADS]; in main()420 thread_data_t thread_data[NUM_THREADS]; in main()463 for(i=0; i < NUM_THREADS - 1; i++) { in main()473 for(i=0; i < NUM_THREADS; i++) { in main()483 for(i=0; i < NUM_THREADS; i++) { in main()[all …]
93 #define NUM_THREADS 100 macro169 THREAD_T threads[NUM_THREADS]; in thread_basic()228 for (i = 0; i < NUM_THREADS; ++i) in thread_basic()238 for (i = 0; i < NUM_THREADS; ++i) in thread_basic()257 #undef NUM_THREADS258 #define NUM_THREADS 10 macro294 THREAD_T threads[NUM_THREADS]; in thread_conditions_simple()313 for (i = 0; i < NUM_THREADS; ++i) { in thread_conditions_simple()328 for (i = 0; i < NUM_THREADS; ++i) { in thread_conditions_simple()340 for (i = 0; i < NUM_THREADS; ++i) in thread_conditions_simple()[all …]
42 #define NUM_THREADS 100 macro77 pthread_t threads[NUM_THREADS]; in main()92 for (t = 0; t < NUM_THREADS; t++) { in main()
60 #define NUM_THREADS 3 macro238 thrd_t threads[NUM_THREADS]; in main()244 for (t = 0; t < NUM_THREADS; t++) { in main()253 for (t = 2; t < NUM_THREADS; t++) in main()
1392 NUM_THREADS enumerator1425 for (i = 1; i < NUM_THREADS; i++) { in find_next_range()1437 for (i = 0; i < NUM_THREADS; i++) { in find_next_range()1458 for (i = 0; i < NUM_THREADS; i++) { in find_next_range()1477 for (i = 0; i < NUM_THREADS; i++) { in find_next_range()1526 struct send_range *front_ranges[NUM_THREADS]; in send_merge_thread()1527 bqueue_t *queues[NUM_THREADS]; in send_merge_thread()1582 for (int i = 0; i < NUM_THREADS; i++) { in send_merge_thread()