NetworkCacheIOChannelCurl.cpp [plain text]
#include "config.h"
#include "NetworkCacheIOChannel.h"
#include <wtf/RunLoop.h>
namespace WebKit {
namespace NetworkCache {
IOChannel::IOChannel(const String& filePath, Type type, Optional<WorkQueue::QOS>)
: m_path(filePath)
, m_type(type)
{
FileSystem::FileOpenMode mode { };
switch (type) {
case Type::Read:
mode = FileSystem::FileOpenMode::Read;
break;
case Type::Write:
mode = FileSystem::FileOpenMode::Write;
break;
case Type::Create:
mode = FileSystem::FileOpenMode::Write;
break;
}
m_fileDescriptor = FileSystem::openFile(filePath, mode);
}
IOChannel::~IOChannel()
{
FileSystem::closeFile(m_fileDescriptor);
}
static inline void runTaskInQueue(Function<void()>&& task, WorkQueue* queue)
{
if (queue) {
queue->dispatch(WTFMove(task));
return;
}
RunLoop::main().dispatch(WTFMove(task));
}
void IOChannel::read(size_t offset, size_t size, WorkQueue* queue, Function<void(Data&, int error)>&& completionHandler)
{
runTaskInQueue([this, protectedThis = makeRef(*this), offset, size, completionHandler = WTFMove(completionHandler)] {
long long fileSize;
if (!FileSystem::getFileSize(m_fileDescriptor, fileSize) || fileSize > std::numeric_limits<size_t>::max()) {
Data data;
completionHandler(data, -1);
return;
}
size_t readSize = fileSize;
readSize = std::min(size, readSize);
Vector<uint8_t> buffer(readSize);
FileSystem::seekFile(m_fileDescriptor, offset, FileSystem::FileSeekOrigin::Beginning);
int err = FileSystem::readFromFile(m_fileDescriptor, reinterpret_cast<char*>(buffer.data()), readSize);
err = err < 0 ? err : 0;
auto data = Data(WTFMove(buffer));
completionHandler(data, err);
}, queue);
}
void IOChannel::write(size_t offset, const Data& data, WorkQueue* queue, Function<void(int error)>&& completionHandler)
{
runTaskInQueue([this, protectedThis = makeRef(*this), offset, data, completionHandler = WTFMove(completionHandler)] {
FileSystem::seekFile(m_fileDescriptor, offset, FileSystem::FileSeekOrigin::Beginning);
int err = FileSystem::writeToFile(m_fileDescriptor, reinterpret_cast<const char*>(data.data()), data.size());
err = err < 0 ? err : 0;
completionHandler(err);
}, queue);
}
} }