summaryrefslogtreecommitdiffstats
path: root/src/network/access
diff options
context:
space:
mode:
authorMarkus Goetz <Markus.Goetz@nokia.com>2011-04-13 15:11:09 +0200
committerMarkus Goetz <Markus.Goetz@nokia.com>2011-05-03 16:47:09 +0200
commit100b7565aafbd6d264e906eba77509891e607831 (patch)
tree794caed4047d9e5394b6051ea242e869fc0b1e53 /src/network/access
parent9aa2feec0e579c7e1bfcf990aae07a82daaad647 (diff)
QNAM HTTP: More comments
Diffstat (limited to 'src/network/access')
-rw-r--r--src/network/access/qnetworkreplyhttpimpl.cpp37
1 files changed, 14 insertions, 23 deletions
diff --git a/src/network/access/qnetworkreplyhttpimpl.cpp b/src/network/access/qnetworkreplyhttpimpl.cpp
index 359fb563e5..122c213f63 100644
--- a/src/network/access/qnetworkreplyhttpimpl.cpp
+++ b/src/network/access/qnetworkreplyhttpimpl.cpp
@@ -320,9 +320,8 @@ qint64 QNetworkReplyHttpImpl::size() const
qint64 QNetworkReplyHttpImpl::readData(char* data, qint64 maxlen)
{
Q_D(QNetworkReplyHttpImpl);
- qDebug() << "QNetworkReplyHttpImpl::readData()" << maxlen;
- // FIXME cacheload device
+ // cacheload device
if (d->cacheLoadDevice) {
// FIXME bytesdownloaded, position etc?
@@ -336,9 +335,10 @@ qint64 QNetworkReplyHttpImpl::readData(char* data, qint64 maxlen)
return ret;
}
- // FIXME 0-copy buffer
+ // zerocopy buffer
if (d->downloadZerocopyBuffer) {
- // bla
+ // FIXME bytesdownloaded, position etc?
+
qint64 howMuch = qMin(maxlen, (d->downloadBufferCurrentSize - d->downloadBufferReadPosition));
memcpy(data, d->downloadZerocopyBuffer + d->downloadBufferReadPosition, howMuch);
d->downloadBufferReadPosition += howMuch;
@@ -346,12 +346,13 @@ qint64 QNetworkReplyHttpImpl::readData(char* data, qint64 maxlen)
}
- // FIXME normal buffer
- if (d->downloadMultiBuffer.isEmpty())
- return d->state == d->Finished ? -1 : 0;
- // FIXME what about "Aborted" state?
+ // normal buffer
+ if (d->downloadMultiBuffer.isEmpty()) {
+ if (d->state == d->Finished || d->state == d->Aborted)
+ return -1;
+ return 0;
+ }
- //d->backendNotify(QNetworkReplyImplPrivate::NotifyDownstreamReadyWrite);
if (maxlen == 1) {
// optimization for getChar()
*data = d->downloadMultiBuffer.getChar();
@@ -364,7 +365,8 @@ qint64 QNetworkReplyHttpImpl::readData(char* data, qint64 maxlen)
void QNetworkReplyHttpImpl::setReadBufferSize(qint64 size)
{
- return; // FIXME, unsupported right now
+ // FIXME, unsupported right now
+ return;
}
bool QNetworkReplyHttpImpl::canReadLine () const
@@ -377,6 +379,8 @@ bool QNetworkReplyHttpImpl::canReadLine () const
if (d->cacheLoadDevice)
return d->cacheLoadDevice->canReadLine() || d->downloadMultiBuffer.canReadLine();
+ // FIXME zerocopy buffer?
+
return d->downloadMultiBuffer.canReadLine();
}
@@ -407,38 +411,25 @@ void QNetworkReplyHttpImpl::setSslConfigurationImplementation(const QSslConfigur
QSslConfiguration QNetworkReplyHttpImpl::sslConfigurationImplementation() const
{
Q_D(const QNetworkReplyHttpImpl);
- qDebug() << "sslConfigurationImplementation";
return d->sslConfiguration;
}
#endif
QNetworkReplyHttpImplPrivate::QNetworkReplyHttpImplPrivate()
-// FIXME order etc
: QNetworkReplyPrivate()
-
, manager(0)
, managerPrivate(0)
, synchronous(false)
-
, state(Idle)
-
, statusCode(0)
-
, outgoingData(0)
-
, bytesUploaded(-1)
-
-
, cacheLoadDevice(0)
, loadingFromCache(false)
-
, cacheSaveDevice(0)
, cacheEnabled(false)
-
-
, resumeOffset(0)
, preMigrationDownloaded(-1)
-
, bytesDownloaded(0)
, lastBytesDownloaded(-1)
, downloadBufferReadPosition(0)