0

私は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;
}
4

1 に答える 1

0

マニュアルページで読んだことにもかかわらず、aio_returnを呼び出す必要があり、NYMPH_ASSERT（aio_return ...をNYMPH_VERIFY（aio_return ...）に変更すると問題が修正されたようです。

于 2011-04-06T22:12:17.413 に答える