Searched refs:NUM_THREADS (Results 1 – 6 of 6) sorted by relevance
92 #define NUM_THREADS 8 macro280 static sem_t chunk_sems[NUM_THREADS - 1][NUM_CHUNKS];299 uint64_t mark = ((thread_num == (NUM_THREADS - 1) ? in marker_fill()320 marker_fill(desired_buf, chunk_start, size, NUM_THREADS - 1); in verify_file()402 if (thread_num < NUM_THREADS - 1) { in worker()418 pthread_t threads[NUM_THREADS]; in main()419 thread_data_t thread_data[NUM_THREADS]; in main()462 for(i=0; i < NUM_THREADS - 1; i++) { in main()472 for(i=0; i < NUM_THREADS; i++) { in main()482 for(i=0; i < NUM_THREADS; i++) { in main()[all …]
93 #define NUM_THREADS 100 macro133 if (count >= NUM_THREADS * NUM_ITERATIONS) in basic_thread()169 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()243 tt_int_op(count, ==, NUM_THREADS * NUM_ITERATIONS); in thread_basic()257 #undef NUM_THREADS258 #define NUM_THREADS 10 macro293 struct alerted_record alerted[NUM_THREADS]; in thread_conditions_simple()294 THREAD_T threads[NUM_THREADS]; in thread_conditions_simple()[all …]
39 #define NUM_THREADS 100 macro74 pthread_t threads[NUM_THREADS]; in main()89 for (t = 0; t < NUM_THREADS; t++) { in main()
58 #define NUM_THREADS 3 macro236 thrd_t threads[NUM_THREADS]; in main()242 for (t = 0; t < NUM_THREADS; t++) { in main()251 for (t = 2; t < NUM_THREADS; t++) in main()
1358 NUM_THREADS enumerator1391 for (i = 1; i < NUM_THREADS; i++) { in find_next_range()1403 for (i = 0; i < NUM_THREADS; i++) { in find_next_range()1424 for (i = 0; i < NUM_THREADS; i++) { in find_next_range()1443 for (i = 0; i < NUM_THREADS; i++) { in find_next_range()1492 struct send_range *front_ranges[NUM_THREADS]; in send_merge_thread()1493 bqueue_t *queues[NUM_THREADS]; in send_merge_thread()1548 for (int i = 0; i < NUM_THREADS; i++) { in send_merge_thread()