io_getevents возвращает меньшее количество заданий, чем запрошено, за время, меньшее времени ожидания

Делая дополнительные шаги и отлаживая вывод, мы выясняем, что есть проблема с драйвером aio в нашем linux (5.3 Карфаген, 2.6.18-128.el5)

Решение, которое мы применили (я добавляю его на случай, если кто-то столкнется с той же проблемой), таково:
(Мы считаем прошедшие секунды для вызова сами.)

1) Если мы увидим ошибку, возвращенную из io_getevents() мы сообщаем об этом. СДЕЛАННЫЙ.

2) Если мы видим, что 0 заданий завершено и истекли секунды, мы считаем себя выше ожидаемого и сообщаем об ошибке. СДЕЛАННЫЙ. В противном случае мы продолжаем (мы не меняем тайм-аут на io_getevents())

3) Если некоторые работы завершены, мы анализируем их res для ошибки (отрицательное значение), и если была какая-либо неудачная работа, мы сообщаем об этом. СДЕЛАННЫЙ.

4) Если осталось несколько заданий, мы сбрасываем таймер (да, мы снова будем ждать «ожидаемое» время) и продолжаем.

С помощью этого метода мы сообщим об ошибке, если io_getevents() сообщил об ошибке или любой из заданий сообщил об ошибке.
В худшем случае, когда каждое задание возвращается нормально после всего времени ожидания T-epsilon, весь процесс займет N * T времени для завершения.

Я надеюсь, что кто-то найдет это полезным.
Благословения,
Грег.

Пример:

struct timespec       tmCountStart ;
unsigned              seconds_delay = SECONDS_DELAY ;

clock_gettime( CLOCK_REALTIME, &tmCountStart ) ;
while ( num_remaining_jobs > 0 )
{
struct timespec ts = { seconds_delay, 0 } ;
struct io_event events[ num_remaining_jobs ] ;
long ec ;

do
{
ec = io_getevents( ctx, num_remaining_jobs, num_remaining_jobs, &events[ 0 ], &ts ) ;
}
while( ec == -EINTR ) ;

if ( ec < 0 )
throw exception reporting error ec. cancel all remaining jobs
else if ( ec == 0 )
{
const double elapsed = count elapsed seconds from tmCountStart
seconds_delay = SECONDS_DELAY - static_cast< unsigned >( elapsed ) ;
if ( seconds_delay > SECONDS_DELAY )
throw exception reporting timeout. cancel all remaining jobs
}
else // we got some jobs back. may not all of them
{
for ( int i = 0 ; i < ec ; i++ )
if (( int64_t )events[ i ].res < 0 )
throw exception reporting failing job. cancel all remaining jobs.

num_remaining_jobs -= ec ;
if ( num_remaining_jobs > 0 )
{
clock_gettime( CLOCK_REALTIME, &tmCountStart ) ; // reset timer.
seconds_delay = SECONDS_DELAY ;
}
}
}