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 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 …]
40 #define NUM_THREADS 100 macro75 pthread_t threads[NUM_THREADS]; in main()90 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()
1397 NUM_THREADS enumerator1430 for (i = 1; i < NUM_THREADS; i++) { in find_next_range()1442 for (i = 0; i < NUM_THREADS; i++) { in find_next_range()1463 for (i = 0; i < NUM_THREADS; i++) { in find_next_range()1482 for (i = 0; i < NUM_THREADS; i++) { in find_next_range()1531 struct send_range *front_ranges[NUM_THREADS]; in send_merge_thread()1532 bqueue_t *queues[NUM_THREADS]; in send_merge_thread()1587 for (int i = 0; i < NUM_THREADS; i++) { in send_merge_thread()