0

我正在阅读 SSD，请求 20 个异步作业。io_getevents 返回值 7 表示它已超时。超时设置为 10 秒，如下所示。通话经过的时间实际上是 4.89e-05 秒，例如，还剩下几乎所有 10 秒。问：有人遇到过这样的事情吗？如果你这样做了，那么你找到解决方案了吗？

以下是部分代码：

struct timespec ts = { 10, 0 } ; /* ten seconds delay */
const long ec = io_getevents( ctx, num_jobs, num_jobs, &events[ 0 ], &ts ) ;

当 ec 返回 7, ts.tv_sec = 10,ts.tv_nsec = 0

Linux内核：

Linux VTL80-G-1J4-823-21 2.6.18-274.18.1.el5 #1 SMP Thu Feb 9 12:20:03 EST 2012 x86_64 x86_64 x86_64 GNU/Linux

非常感谢您的帮助！顺便提一句。我将无法在几个小时之前检查该帖子。

4

1 回答 1

1

通过添加额外的步骤和调试输出，我们发现我们的 linux 上的 aio 驱动程序存在问题（5.3 Carthage，2.6.18-128.el5）

我们应用的解决方案（我把它放在以防万一有人遇到同样的问题）是这样的：（
我们自己计算经过的秒数。）

1) 如果我们看到从我们返回的错误，io_getevents()我们会报告它。完毕。

2) 如果我们看到 0 个作业完成且经过的秒数，我们计算自己超出了预期的一个，我们会报告错误。完毕。否则我们继续（我们不更改超时时间io_getevents()）

3）如果一些工作完成了，我们分析它们res的错误（负值），如果有任何失败的工作，我们报告它。完毕。

4）如果还有一些剩余的工作，我们重置计时器（是的，我们将再次等待“预期”时间）并继续。

使用此方法，如果io_getevents()报告错误或任何作业报告错误，我们将报告错误。在最坏的情况下，当每个作业在整个 T-epsilon 等待时间后返回 ok 时，整个过程将需要 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 ;
        }
    }
}
于 2013-08-23T15:19:43.023 回答