Lines Matching refs:chunk
1441 * handle array into chunks with the chunk size less than 64, and fire up as many
1442 * waiting threads as there are chunks. Then each thread would wait on a chunk of
1517 int chunks, chunk, remains;
1554 for (chunk = 0; chunk < chunks; chunk++) {
1555 threads[chunk].main_event = main_event;
1556 threads[chunk].signaled_index = &sig_index;
1557 threads[chunk].first_handle_index = WAIT_ALL_CHUNK_SIZE * chunk;
1558 threads[chunk].handles = handles + threads[chunk].first_handle_index;
1559 threads[chunk].handles_count = WAIT_ALL_CHUNK_SIZE;
1562 threads[chunk].main_event = main_event;
1563 threads[chunk].signaled_index = &sig_index;
1564 threads[chunk].first_handle_index = WAIT_ALL_CHUNK_SIZE * chunk;
1565 threads[chunk].handles = handles + threads[chunk].first_handle_index;
1566 threads[chunk].handles_count = remains;
1571 for (chunk = 0; chunk < chunks; chunk++) {
1574 threads[chunk].thread = (HANDLE)_beginthreadex(NULL, 0, _in_waiter_thread,
1575 &threads[chunk], 0, NULL);
1576 if (threads[chunk].thread == NULL) {
1579 chunk, chunks, errno);
1580 chunks = chunk;
1590 for (chunk = 0; chunk < chunks; chunk++) {
1591 WaitForSingleObject(threads[chunk].thread, INFINITE);
1592 CloseHandle(threads[chunk].thread);
