#include "config.h"
#if ENABLE(BLOB)
#include "FileStream.h"
#include "FileSystem.h"
#include <wtf/text/WTFString.h>
namespace WebCore {
FileStream::FileStream()
: m_handle(invalidPlatformFileHandle)
, m_bytesProcessed(0)
, m_totalBytesToRead(0)
{
}
FileStream::~FileStream()
{
ASSERT(!isHandleValid(m_handle));
}
void FileStream::start()
{
}
void FileStream::stop()
{
close();
}
long long FileStream::getSize(const String& path, double expectedModificationTime)
{
time_t modificationTime;
if (!getFileModificationTime(path, modificationTime))
return -1;
if (isValidFileTime(expectedModificationTime)) {
if (static_cast<time_t>(expectedModificationTime) != modificationTime)
return -1;
}
long long length;
if (!getFileSize(path, length))
return -1;
return length;
}
bool FileStream::openForRead(const String& path, long long offset, long long length)
{
if (isHandleValid(m_handle))
return true;
m_handle = openFile(path, OpenForRead);
if (!isHandleValid(m_handle))
return false;
if (offset > 0) {
if (seekFile(m_handle, offset, SeekFromBeginning) < 0)
return false;
}
m_totalBytesToRead = length;
m_bytesProcessed = 0;
return true;
}
bool FileStream::openForWrite(const String&)
{
return false;
}
void FileStream::close()
{
if (isHandleValid(m_handle)) {
closeFile(m_handle);
m_handle = invalidPlatformFileHandle;
}
}
int FileStream::read(char* buffer, int bufferSize)
{
if (!isHandleValid(m_handle))
return -1;
long long remaining = m_totalBytesToRead - m_bytesProcessed;
int bytesToRead = (remaining < bufferSize) ? static_cast<int>(remaining) : bufferSize;
int bytesRead = 0;
if (bytesToRead > 0)
bytesRead = readFromFile(m_handle, buffer, bytesToRead);
if (bytesRead < 0)
return -1;
if (bytesRead > 0)
m_bytesProcessed += bytesRead;
return bytesRead;
}
int FileStream::write(const KURL&, long long, int)
{
return -1;
}
bool FileStream::truncate(long long)
{
return false;
}
}
#endif // ENABLE(BLOB)