aio_write在发布版本中失败

Question

我使用的是aio_write，它可以在调试版本中工作，但不能在发行版中工作。我已经检查了构造函数，一切都已初始化，并且我没有收到任何关于未初始化变量的警告。该类收集要以16K块的形式写入磁盘的数据。如果数据小于16K，即使是在发布版本中，它也可以工作。如果数据大于16K，则只写入第一个区块。WriteBuffer::ContinueWriteToFile无限期返回WriteFileState_Active。

WriteBuffer_posix.h：

class WriteBufferPlatformData
{
public:
    WriteBufferPlatformData();
    ~WriteBufferPlatformData();

    aiocb aioData;
    WriteBuffer::BufferVector::iterator currentBuffer;
};

WriteBuffer_posix.cpp：

WriteBufferPlatformData::WriteBufferPlatformData() :
    aioData(),
    currentBuffer()
{
    memset(&aioData,0,sizeof(aioData));
    aioData.aio_fildes=-1;
}

WriteBufferPlatformData::~WriteBufferPlatformData()
{
    if (0<=aioData.aio_fildes) {
        close(aioData.aio_fildes);
    }
}

WriteBuffer::WriteFileState WriteBuffer::StartWriteToFile(const char * filename)
{
    NYMPH_ASSERT(0>m_platformData->aioData.aio_fildes);

    m_platformData->aioData.aio_fildes=open(filename,O_WRONLY|O_CREAT|O_TRUNC,S_IRUSR|S_IWUSR|S_IRGRP|S_IWGRP|S_IROTH|S_IWOTH);

    NYMPH_ASSERT2(0<=m_platformData->aioData.aio_fildes,"Could not open file for writing: %s (%d)",filename,errno);
    if (0>m_platformData->aioData.aio_fildes) {
        return WriteFileState_Failed;
    }

    if (m_buffers.empty()) {
        close(m_platformData->aioData.aio_fildes);
        m_platformData->aioData.aio_fildes=-1;
        return WriteFileState_Complete;
    }

    m_isWriting=true;
    m_platformData->currentBuffer=m_buffers.begin();
    return ContinueWriteToFile();
}

WriteBuffer::WriteFileState WriteBuffer::ContinueWriteToFile()
{
    NYMPH_ASSERT(0<=m_platformData->aioData.aio_fildes);

    if (0!=m_platformData->aioData.aio_nbytes) {
        int writeErrno=aio_error(&(m_platformData->aioData));
        if (EINPROGRESS==writeErrno) {
            return WriteFileState_Active;
        }

        NYMPH_ASSERT(aio_return(&(m_platformData->aioData))==m_platformData->aioData.aio_nbytes);
        m_platformData->aioData.aio_nbytes=0;
        ++(m_platformData->currentBuffer);

        if (m_buffers.end()==m_platformData->currentBuffer) {
            close(m_platformData->aioData.aio_fildes);
            m_platformData->aioData.aio_fildes=-1;
            return WriteFileState_Complete;
        }
    }

    if (0==m_platformData->aioData.aio_nbytes) {
        m_platformData->aioData.aio_buf=*(m_platformData->currentBuffer);
        if (m_buffers.back()==m_platformData->aioData.aio_buf) {
            m_platformData->aioData.aio_nbytes=m_offset;
        } else {
            m_platformData->aioData.aio_nbytes=kBufferSize;
        }
        m_platformData->aioData.aio_offset=lseek(m_platformData->aioData.aio_fildes,0,SEEK_END);

        if (0!=aio_write(&(m_platformData->aioData))) {
            m_platformData->aioData.aio_nbytes=0;
            NYMPH_ASSERT(EAGAIN==errno);
            if (EAGAIN!=errno) {
                close(m_platformData->aioData.aio_fildes);
                m_platformData->aioData.aio_fildes=-1;
                return WriteFileState_Failed;
            }
        }
    }

    return WriteFileState_Active;
}

Answer 1

不管我在手册页中读到了什么，似乎调用aio_return和更改NYMPH_ASSERT(aio_return...致NYMPH_VERIFY(aio_return...已更正问题。