QtNetworkReply.cpp [plain text]
#include "config.h"
#include "QtNetworkReply.h"
#include "SharedMemory.h"
#include "WebFrameNetworkingContext.h"
#include "WebPage.h"
#include "WebProcess.h"
#include <QNetworkCookie>
#include <QNetworkReply>
#include <QNetworkRequest>
namespace WebKit {
QtNetworkReply::QtNetworkReply(const QNetworkRequest& req, QtNetworkAccessManager* parent)
: QNetworkReply(parent)
, m_bytesAvailable(0)
, m_sharedMemorySize(0)
{
setRequest(req);
setOperation(QNetworkAccessManager::GetOperation);
setUrl(req.url());
setOpenMode(QIODevice::ReadOnly);
}
void QtNetworkReply::setData(const SharedMemory::Handle& handle, qint64 dataSize)
{
if (handle.isNull())
return;
m_sharedMemory = SharedMemory::create(handle, SharedMemory::ReadOnly);
if (!m_sharedMemory)
return;
m_bytesAvailable = dataSize;
m_sharedMemorySize = dataSize;
}
void QtNetworkReply::setReplyData(const QtNetworkReplyData& replyData)
{
if (!replyData.m_contentType.isEmpty())
setHeader(QNetworkRequest::ContentTypeHeader, QString(replyData.m_contentType));
setHeader(QNetworkRequest::ContentLengthHeader, QVariant::fromValue(replyData.m_contentLength));
setData(replyData.m_dataHandle, replyData.m_contentLength);
}
qint64 QtNetworkReply::readData(char* data, qint64 maxlen)
{
if (!m_sharedMemory)
return 0;
qint64 bytesRead = maxlen < m_bytesAvailable ? maxlen : m_bytesAvailable;
if (memcpy(data, static_cast<char*>(m_sharedMemory->data()) + m_sharedMemorySize - m_bytesAvailable, bytesRead)) {
m_bytesAvailable -= bytesRead;
return bytesRead;
}
return 0;
}
qint64 QtNetworkReply::bytesAvailable() const
{
return m_bytesAvailable + QNetworkReply::bytesAvailable();
}
void QtNetworkReply::abort() { }
void QtNetworkReply::close() { }
void QtNetworkReply::setReadBufferSize(qint64 size) { }
bool QtNetworkReply::canReadLine () const { return true; }
void QtNetworkReply::finalize()
{
QNetworkReply::setFinished(true);
emit readyRead();
emit finished();
}
}