FileWriterSync.cpp [plain text]
#include "config.h"
#if ENABLE(FILE_SYSTEM)
#include "FileWriterSync.h"
#include "AsyncFileWriter.h"
#include "Blob.h"
#include "FileException.h"
namespace WebCore {
void FileWriterSync::write(Blob* data, ExceptionCode& ec)
{
ASSERT(writer());
ASSERT(m_complete);
ec = 0;
if (!data) {
ec = FileException::TYPE_MISMATCH_ERR;
return;
}
prepareForWrite();
writer()->write(position(), data);
writer()->waitForOperationToComplete();
ASSERT(m_complete);
ec = FileException::ErrorCodeToExceptionCode(m_error);
if (ec)
return;
setPosition(position() + data->size());
if (position() > length())
setLength(position());
}
void FileWriterSync::seek(long long position, ExceptionCode& ec)
{
ASSERT(writer());
ASSERT(m_complete);
ec = 0;
seekInternal(position);
}
void FileWriterSync::truncate(long long offset, ExceptionCode& ec)
{
ASSERT(writer());
ASSERT(m_complete);
ec = 0;
if (offset < 0) {
ec = FileException::INVALID_STATE_ERR;
return;
}
prepareForWrite();
writer()->truncate(offset);
writer()->waitForOperationToComplete();
ASSERT(m_complete);
ec = FileException::ErrorCodeToExceptionCode(m_error);
if (ec)
return;
if (offset < position())
setPosition(offset);
setLength(offset);
}
void FileWriterSync::didWrite(long long, bool complete)
{
ASSERT(m_error == FileError::OK);
ASSERT(!m_complete);
#ifndef NDEBUG
m_complete = complete;
#else
ASSERT_UNUSED(complete, complete);
#endif
}
void FileWriterSync::didTruncate()
{
ASSERT(m_error == FileError::OK);
ASSERT(!m_complete);
#ifndef NDEBUG
m_complete = true;
#endif
}
void FileWriterSync::didFail(FileError::ErrorCode error)
{
ASSERT(m_error == FileError::OK);
m_error = error;
ASSERT(!m_complete);
#ifndef NDEBUG
m_complete = true;
#endif
}
FileWriterSync::FileWriterSync()
: m_error(FileError::OK)
#ifndef NDEBUG
, m_complete(true)
#endif
{
}
void FileWriterSync::prepareForWrite()
{
ASSERT(m_complete);
m_error = FileError::OK;
#ifndef NDEBUG
m_complete = false;
#endif
}
FileWriterSync::~FileWriterSync()
{
}
}
#endif // ENABLE(FILE_SYSTEM)