QHttpPrivate Class Reference

Inheritance diagram for QHttpPrivate:

Public Functions
void	_q_continuePost ()
void	_q_slotBytesWritten (qint64 numBytes)
void	_q_slotClosed ()
void	_q_slotConnected ()
void	_q_slotDoFinished ()
void	_q_slotEncryptedBytesWritten (qint64 numBytes)
void	_q_slotError (QAbstractSocket::SocketError)
void	_q_slotReadyRead ()
void	_q_slotSendRequest ()
void	_q_startNextRequest ()
int	addRequest (QHttpNormalRequest *)
int	addRequest (QHttpRequest *)
void	closeConn ()
void	finishedWithError (const QString &detail, int errorCode)
void	finishedWithSuccess ()
void	init ()
void	postMoreData ()
	QHttpPrivate ()
void	setSock (QTcpSocket *sock)
void	setState (int)
	~QHttpPrivate ()
Public Functions inherited from QObjectPrivate
void	_q_reregisterTimers (void *pointer)
void	addConnection (int signal, Connection *c)
void	cleanConnectionLists ()
void	connectNotify (const char *signal)
void	deleteChildren ()
void	disconnectNotify (const char *signal)
bool	isSender (const QObject *receiver, const char *signal) const
bool	isSignalConnected (uint signalIdx) const
	Returns true if the signal with index signal_index from object sender is connected. More...
void	moveToThread_helper ()
	QObjectPrivate (int version=QObjectPrivateVersion)
QObjectList	receiverList (const char *signal) const
QObjectList	senderList () const
void	setParent_helper (QObject *)
void	setThreadData_helper (QThreadData *currentData, QThreadData *targetData)
int	signalIndex (const char *signalName) const
	Returns the signal index used in the internal connectionLists vector. More...
virtual	~QObjectPrivate ()
Public Functions inherited from QObjectData
virtual	~QObjectData ()=0

Public Variables
QAuthenticator	authenticator
QByteArray	buffer
qint64	bytesDone
qint64	bytesTotal
qint64	chunkedSize
bool	deleteSocket
QHttp::Error	error
QString	errorString
bool	hasFinishedWithError
QHttpRequestHeader	header
QString	headerStr
QString	hostName
QHttp::ConnectionMode	mode
QList< QHttpRequest * >	pending
bool	pendingPost
quint16	port
QTimer	post100ContinueTimer
QIODevice *	postDevice
QNetworkProxy	proxy
QAuthenticator	proxyAuthenticator
QRingBuffer	rba
bool	readHeader
int	reconnectAttempts
bool	repost
QHttpResponseHeader	response
QTcpSocket *	socket
QHttp::State	state
QIODevice *	toDevice
Public Variables inherited from QObjectPrivate
union {
QObject *   currentChildBeingDeleted
QAbstractDeclarativeData *   declarativeData
};
quint32	connectedSignals [2]
QObjectConnectionListVector *	connectionLists
Sender *	currentSender
QList< QPointer< QObject > >	eventFilters
ExtraData *	extraData
QString	objectName
Connection *	senders
QAtomicPointer< QtSharedPointer::ExternalRefCountData >	sharedRefcount
QThreadData *	threadData
void *	unused
Public Variables inherited from QObjectData
uint	blockSig: 1
QObjectList	children
uint	hasGuards: 1
uint	inEventHandler: 1
uint	inThreadChangeEvent: 1
uint	isWidget: 1
QMetaObject *	metaObject
uint	ownObjectName: 1
QObject *	parent
uint	pendTimer: 1
int	postedEvents
QObject *	q_ptr
uint	receiveChildEvents: 1
uint	sendChildEvents: 1
uint	unused: 22
uint	wasDeleted: 1

Additional Inherited Members
Public Types inherited from QObjectPrivate
typedef void(*	StaticMetaCallFunction) (QObject *, QMetaObject::Call, int, void **)
Static Public Functions inherited from QObjectPrivate
static void	clearGuards (QObject *)
static QObjectPrivate *	get (QObject *o)
static void	resetCurrentSender (QObject *receiver, Sender *currentSender, Sender *previousSender)
static Sender *	setCurrentSender (QObject *receiver, Sender *sender)
static void	signalSignature (const QMetaMethod &signal, QVarLengthArray< char > *result)

Detailed Description

Definition at line 94 of file qhttp.cpp.

Constructors and Destructors

QHttpPrivate()

QHttpPrivate::QHttpPrivate ( )

inline

Definition at line 99 of file qhttp.cpp.

        : socket(0), reconnectAttempts(2),
          deleteSocket(0), state(QHttp::Unconnected),
          error(QHttp::NoError), port(0), mode(QHttp::ConnectionModeHttp),
          toDevice(0), postDevice(0), bytesDone(0), chunkedSize(-1),
          repost(false), pendingPost(false)
    {
    }

~QHttpPrivate()

QHttpPrivate::~QHttpPrivate ( )

inline

Definition at line 108 of file qhttp.cpp.

    {
        while (!pending.isEmpty())
            delete pending.takeFirst();

        if (deleteSocket)
            delete socket;
    }

Functions

_q_continuePost()

void QHttpPrivate::_q_continuePost

(

)

Definition at line 2662 of file qhttp.cpp.

{
    if (pendingPost) {
        pendingPost = false;
        setState(QHttp::Sending);
        _q_slotBytesWritten(0);
    }
}

_q_slotBytesWritten()

void QHttpPrivate::_q_slotBytesWritten

(

qint64

numBytes

)

Definition at line 2747 of file qhttp.cpp.

{
    Q_Q(QHttp);
    bytesDone += written;
    emit q->dataSendProgress(bytesDone, bytesTotal);
    postMoreData();
}

_q_slotClosed()

void QHttpPrivate::_q_slotClosed

(

)

Definition at line 2641 of file qhttp.cpp.

{
    Q_Q(QHttp);

    if (state == QHttp::Reading) {
        if (response.hasKey(QLatin1String("content-length"))) {
            // We got Content-Length, so did we get all bytes?
            if (bytesDone + q->bytesAvailable() != response.contentLength()) {
                finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Wrong content length")), QHttp::WrongContentLength);
            }
        }
    } else if (state == QHttp::Connecting || state == QHttp::Sending) {
        finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Server closed connection unexpectedly")), QHttp::UnexpectedClose);
    }

    postDevice = 0;
    if (state != QHttp::Closing)
        setState(QHttp::Closing);
    QMetaObject::invokeMethod(q, "_q_slotDoFinished", Qt::QueuedConnection);
}

_q_slotConnected()

void QHttpPrivate::_q_slotConnected

(

)

Definition at line 2671 of file qhttp.cpp.

{
    if (state != QHttp::Sending) {
        bytesDone = 0;
        setState(QHttp::Sending);
    }

    QString str = header.toString();
    bytesTotal = str.length();
    socket->write(str.toLatin1(), bytesTotal);
#if defined(QHTTP_DEBUG)
    qDebug("QHttp: write request header %p:\n---{\n%s}---", &header, str.toLatin1().constData());
#endif

    if (postDevice) {
        postDevice->seek(0);    // reposition the device
        bytesTotal += postDevice->size();
        //check for 100-continue
        if (header.value(QLatin1String("expect")).contains(QLatin1String("100-continue"), Qt::CaseInsensitive)) {
            //create a time out for 2 secs.
            pendingPost = true;
            post100ContinueTimer.start(2000);
        }
    } else {
        bytesTotal += buffer.size();
        socket->write(buffer, buffer.size());
    }
}

_q_slotDoFinished()

void QHttpPrivate::_q_slotDoFinished

(

)

Definition at line 3083 of file qhttp.cpp.

{
    if (state == QHttp::Connected) {
        finishedWithSuccess();
    } else if (state != QHttp::Unconnected) {
        setState(QHttp::Unconnected);
        finishedWithSuccess();
    }
}

_q_slotEncryptedBytesWritten()

void QHttpPrivate::_q_slotEncryptedBytesWritten

(

qint64

numBytes

)

Definition at line 2740 of file qhttp.cpp.

{
    Q_UNUSED(written);
    postMoreData();
}

_q_slotError()

void QHttpPrivate::_q_slotError

(

QAbstractSocket::SocketError

err

)

Definition at line 2700 of file qhttp.cpp.

{
    Q_Q(QHttp);
    postDevice = 0;

    if (state == QHttp::Connecting || state == QHttp::Reading || state == QHttp::Sending) {
        switch (err) {
        case QTcpSocket::ConnectionRefusedError:
            finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Connection refused (or timed out)")), QHttp::ConnectionRefused);
            break;
        case QTcpSocket::HostNotFoundError:
            finishedWithError(QString::fromLatin1(QT_TRANSLATE_NOOP("QHttp", "Host %1 not found"))
                              .arg(socket->peerName()), QHttp::HostNotFound);
            break;
        case QTcpSocket::RemoteHostClosedError:
            if (state == QHttp::Sending && reconnectAttempts--) {
                setState(QHttp::Closing);
                setState(QHttp::Unconnected);
                socket->blockSignals(true);
                socket->abort();
                socket->blockSignals(false);
                QMetaObject::invokeMethod(q, "_q_slotSendRequest", Qt::QueuedConnection);
                return;
            }
            break;
#ifndef QT_NO_NETWORKPROXY
        case QTcpSocket::ProxyAuthenticationRequiredError:
            finishedWithError(socket->errorString(), QHttp::ProxyAuthenticationRequiredError);
            break;
#endif
        default:
            finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "HTTP request failed")), QHttp::UnknownError);
            break;
        }
    }

    closeConn();
}

_q_slotReadyRead()

void QHttpPrivate::_q_slotReadyRead

(

)

Definition at line 2791 of file qhttp.cpp.

{
    Q_Q(QHttp);
    QHttp::State oldState = state;
    if (state != QHttp::Reading) {
        setState(QHttp::Reading);
        readHeader = true;
        headerStr = QLatin1String("");
        bytesDone = 0;
        chunkedSize = -1;
        repost = false;
    }

    while (readHeader) {
        bool end = false;
        QString tmp;
        while (!end && socket->canReadLine()) {
            tmp = QString::fromAscii(socket->readLine());
            if (tmp == QLatin1String("\r\n") || tmp == QLatin1String("\n") || tmp.isEmpty())
                end = true;
            else
                headerStr += tmp;
        }

        if (!end)
            return;

        response = QHttpResponseHeader(headerStr);
        headerStr = QLatin1String("");
#if defined(QHTTP_DEBUG)
        qDebug("QHttp: read response header:\n---{\n%s}---", response.toString().toLatin1().constData());
#endif
        // Check header
        if (!response.isValid()) {
            finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Invalid HTTP response header")),
                              QHttp::InvalidResponseHeader);
            closeConn();
            return;
        }

        int statusCode = response.statusCode();
        if (statusCode == 401 || statusCode == 407) { // (Proxy) Authentication required
            QAuthenticator *auth =
#ifndef QT_NO_NETWORKPROXY
                statusCode == 407
                ? &proxyAuthenticator :
#endif
                &authenticator;
            if (auth->isNull())
                auth->detach();
            QAuthenticatorPrivate *priv = QAuthenticatorPrivate::getPrivate(*auth);
            priv->parseHttpResponse(response, (statusCode == 407));
            if (priv->phase == QAuthenticatorPrivate::Done) {
                socket->blockSignals(true);
#ifndef QT_NO_NETWORKPROXY
                if (statusCode == 407)
                    emit q->proxyAuthenticationRequired(proxy, auth);
                else
#endif
                    emit q->authenticationRequired(hostName, port, auth);
                socket->blockSignals(false);
            } else if (priv->phase == QAuthenticatorPrivate::Invalid) {
                finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Unknown authentication method")),
                        QHttp::AuthenticationRequiredError);
                closeConn();
                return;
            }

            // priv->phase will get reset to QAuthenticatorPrivate::Start if the authenticator got modified in the signal above.
            if (priv->phase == QAuthenticatorPrivate::Done) {
#ifndef QT_NO_NETWORKPROXY
                if (statusCode == 407)
                    finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Proxy authentication required")),
                                      QHttp::ProxyAuthenticationRequiredError);
                else
#endif
                    finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Authentication required")),
                                      QHttp::AuthenticationRequiredError);
                closeConn();
                return;
            } else {
                // close the connection if it isn't already and reconnect using the chosen authentication method
                bool willClose = (response.value(QLatin1String("proxy-connection")).toLower() == QLatin1String("close"))
                                 || (response.value(QLatin1String("connection")).toLower() == QLatin1String("close"));
                if (willClose) {
                    if (socket) {
                        setState(QHttp::Closing);
                        socket->blockSignals(true);
                        socket->close();
                        socket->blockSignals(false);
                        socket->readAll();
                    }
                    _q_slotSendRequest();
                    return;
                } else {
                    repost = true;
                }
            }
        } else {
            buffer.clear();
        }

        if (response.statusCode() == 100 && pendingPost) {
            // if we have pending POST, start sending data otherwise ignore
            post100ContinueTimer.stop();
            QMetaObject::invokeMethod(q, "_q_continuePost", Qt::QueuedConnection);
            return;
        }

        // The 100-continue header is ignored (in case of no 'expect:100-continue' header),
        // because when using the POST method, we send both the request header and data in
        // one chunk.
        if (response.statusCode() != 100) {
            post100ContinueTimer.stop();
            pendingPost = false;
            readHeader = false;
            if (response.hasKey(QLatin1String("transfer-encoding")) &&
                response.value(QLatin1String("transfer-encoding")).toLower().contains(QLatin1String("chunked")))
                chunkedSize = 0;

            if (!repost)
                emit q->responseHeaderReceived(response);
            if (state == QHttp::Unconnected || state == QHttp::Closing)
                return;
        } else {
            // Restore the state, the next incoming data will be treated as if
            // we never say the 100 response.
            state = oldState;
        }
    }

    bool everythingRead = false;

    if (q->currentRequest().method() == QLatin1String("HEAD") ||
        response.statusCode() == 304 || response.statusCode() == 204 ||
        response.statusCode() == 205) {
        // HEAD requests have only headers as replies
        // These status codes never have a body:
        //  304 Not Modified
        //  204 No Content
        //  205 Reset Content
        everythingRead = true;
    } else {
        qint64 n = socket->bytesAvailable();
        QByteArray *arr = 0;
        if (chunkedSize != -1) {
            // transfer-encoding is chunked
            for (;;) {
                // get chunk size
                if (chunkedSize == 0) {
                    if (!socket->canReadLine())
                        break;
                    QString sizeString = QString::fromAscii(socket->readLine());
                    int tPos = sizeString.indexOf(QLatin1Char(';'));
                    if (tPos != -1)
                        sizeString.truncate(tPos);
                    bool ok;
                    chunkedSize = sizeString.toInt(&ok, 16);
                    if (!ok) {
                        finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Invalid HTTP chunked body")),
                                          QHttp::WrongContentLength);
                        closeConn();
                        delete arr;
                        return;
                    }
                    if (chunkedSize == 0) // last-chunk
                        chunkedSize = -2;
                }

                // read trailer
                while (chunkedSize == -2 && socket->canReadLine()) {
                    QString read = QString::fromAscii(socket->readLine());
                    if (read == QLatin1String("\r\n") || read == QLatin1String("\n"))
                        chunkedSize = -1;
                }
                if (chunkedSize == -1) {
                    everythingRead = true;
                    break;
                }

                // make sure that you can read the terminating CRLF,
                // otherwise wait until next time...
                n = socket->bytesAvailable();
                if (n == 0)
                    break;
                if (n == chunkedSize || n == chunkedSize+1) {
                    n = chunkedSize - 1;
                    if (n == 0)
                        break;
                }

                // read data
                qint64 toRead = chunkedSize < 0 ? n : qMin(n, chunkedSize);
                if (!arr)
                    arr = new QByteArray;
                uint oldArrSize = arr->size();
                arr->resize(oldArrSize + toRead);
                qint64 read = socket->read(arr->data()+oldArrSize, toRead);
                arr->resize(oldArrSize + read);

                chunkedSize -= read;

                if (chunkedSize == 0 && n - read >= 2) {
                    // read terminating CRLF
                    char tmp[2];
                    socket->read(tmp, 2);
                    if (tmp[0] != '\r' || tmp[1] != '\n') {
                        finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Invalid HTTP chunked body")),
                                          QHttp::WrongContentLength);
                        closeConn();
                        delete arr;
                        return;
                    }
                }
            }
        } else if (response.hasContentLength()) {
            if (repost && (n < response.contentLength())) {
                // wait for the content to be available fully
                // if repost is required, the content is ignored
                return;
            }
            n = qMin(qint64(response.contentLength() - bytesDone), n);
            if (n > 0) {
                arr = new QByteArray;
                arr->resize(n);
                qint64 read = socket->read(arr->data(), n);
                arr->resize(read);
            }
            if (bytesDone + q->bytesAvailable() + n == response.contentLength())
                everythingRead = true;
        } else if (n > 0) {
            // workaround for VC++ bug
            QByteArray temp = socket->readAll();
            arr = new QByteArray(temp);
        }

        if (arr && !repost) {
            n = arr->size();
            if (toDevice) {
                qint64 bytesWritten;
                bytesWritten = toDevice->write(*arr, n);
                delete arr;
                arr = 0;
                // if writing to the device does not succeed, quit with error
                if (bytesWritten == -1 || bytesWritten < n) {
                    finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Error writing response to device")), QHttp::UnknownError);
                } else {
                    bytesDone += bytesWritten;
#if defined(QHTTP_DEBUG)
                qDebug("QHttp::_q_slotReadyRead(): read %lld bytes (%lld bytes done)", n, bytesDone);
#endif
                }
                if (response.hasContentLength())
                    emit q->dataReadProgress(bytesDone, response.contentLength());
                else
                    emit q->dataReadProgress(bytesDone, 0);
            } else {
                char *ptr = rba.reserve(arr->size());
                memcpy(ptr, arr->data(), arr->size());
                delete arr;
                arr = 0;
#if defined(QHTTP_DEBUG)
                qDebug("QHttp::_q_slotReadyRead(): read %lld bytes (%lld bytes done)", n, bytesDone + q->bytesAvailable());
#endif
                if (response.hasContentLength())
                    emit q->dataReadProgress(bytesDone + q->bytesAvailable(), response.contentLength());
                else
                    emit q->dataReadProgress(bytesDone + q->bytesAvailable(), 0);
                emit q->readyRead(response);
            }
        }

        delete arr;
    }

    if (everythingRead) {
        if (repost) {
            _q_slotSendRequest();
            return;
        }
        // Handle "Connection: close"
        if (response.value(QLatin1String("connection")).toLower() == QLatin1String("close")) {
            closeConn();
        } else {
            setState(QHttp::Connected);
            // Start a timer, so that we emit the keep alive signal
            // "after" this method returned.
            QMetaObject::invokeMethod(q, "_q_slotDoFinished", Qt::QueuedConnection);
        }
    }
}

_q_slotSendRequest()

void QHttpPrivate::_q_slotSendRequest

(

)

Definition at line 2482 of file qhttp.cpp.

{
    if (hostName.isNull()) {
        finishedWithError(QLatin1String(QT_TRANSLATE_NOOP("QHttp", "No server set to connect to")),
                          QHttp::UnknownError);
        return;
    }

    QString connectionHost = hostName;
    int connectionPort = port;
    bool sslInUse = false;

#ifndef QT_NO_OPENSSL
    QSslSocket *sslSocket = qobject_cast<QSslSocket *>(socket);
    if (mode == QHttp::ConnectionModeHttps || (sslSocket && sslSocket->isEncrypted()))
        sslInUse = true;
#endif

#ifndef QT_NO_NETWORKPROXY
    bool cachingProxyInUse = false;
    bool transparentProxyInUse = false;
    if (proxy.type() == QNetworkProxy::DefaultProxy)
        proxy = QNetworkProxy::applicationProxy();

    if (proxy.type() == QNetworkProxy::HttpCachingProxy) {
        if (proxy.hostName().isEmpty())
            proxy.setType(QNetworkProxy::NoProxy);
        else
            cachingProxyInUse = true;
    } else if (proxy.type() == QNetworkProxy::HttpProxy) {
        // Compatibility behaviour: HttpProxy can be used to mean both
        // transparent and caching proxy
        if (proxy.hostName().isEmpty()) {
            proxy.setType(QNetworkProxy::NoProxy);
        } else if (sslInUse) {
            // Disallow use of caching proxy with HTTPS; instead fall back to
            // transparent HTTP CONNECT proxying.
            transparentProxyInUse = true;
        } else {
            proxy.setType(QNetworkProxy::HttpCachingProxy);
            cachingProxyInUse = true;
        }
    }

    // Proxy support. Insert the Proxy-Authorization item into the
    // header before it's sent off to the proxy.
    if (cachingProxyInUse) {
        QUrl proxyUrl;
        proxyUrl.setScheme(QLatin1String("http"));
        proxyUrl.setHost(hostName);
        if (port && port != 80)
            proxyUrl.setPort(port);
        QString request = QString::fromAscii(proxyUrl.resolved(QUrl::fromEncoded(header.path().toLatin1())).toEncoded());

        header.setRequest(header.method(), request, header.majorVersion(), header.minorVersion());
        header.setValue(QLatin1String("Proxy-Connection"), QLatin1String("keep-alive"));

        QAuthenticatorPrivate *auth = QAuthenticatorPrivate::getPrivate(proxyAuthenticator);
        if (auth && auth->method != QAuthenticatorPrivate::None) {
            QByteArray response = auth->calculateResponse(header.method().toLatin1(), header.path().toLatin1());
            header.setValue(QLatin1String("Proxy-Authorization"), QString::fromLatin1(response));
        }

        connectionHost = proxy.hostName();
        connectionPort = proxy.port();
    }

    if (transparentProxyInUse || sslInUse) {
        socket->setProxy(proxy);
    }
#endif

    // Username support. Insert the user and password into the query
    // string.
    QAuthenticatorPrivate *auth = QAuthenticatorPrivate::getPrivate(authenticator);
    if (auth && auth->method != QAuthenticatorPrivate::None) {
        QByteArray response = auth->calculateResponse(header.method().toLatin1(), header.path().toLatin1());
        header.setValue(QLatin1String("Authorization"), QString::fromLatin1(response));
    }

    // Do we need to setup a new connection or can we reuse an
    // existing one?
    if (socket->peerName() != connectionHost || socket->peerPort() != connectionPort
        || socket->state() != QTcpSocket::ConnectedState
#ifndef QT_NO_OPENSSL
        || (sslSocket && sslSocket->isEncrypted() != (mode == QHttp::ConnectionModeHttps))
#endif
        ) {
        socket->blockSignals(true);
        socket->abort();
        socket->blockSignals(false);

        setState(QHttp::Connecting);
#ifndef QT_NO_OPENSSL
        if (sslSocket && mode == QHttp::ConnectionModeHttps) {
            sslSocket->connectToHostEncrypted(hostName, port);
        } else
#endif
        {
            socket->connectToHost(connectionHost, connectionPort);
        }
    } else {
        _q_slotConnected();
    }

}

_q_startNextRequest()

void QHttpPrivate::_q_startNextRequest

(

)

Definition at line 2466 of file qhttp.cpp.

{
    Q_Q(QHttp);
    if (pending.isEmpty())
        return;
    QHttpRequest *r = pending.first();

    error = QHttp::NoError;
    errorString = QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Unknown error"));

    if (q->bytesAvailable() != 0)
        q->readAll(); // clear the data
    emit q->requestStarted(r->id);
    r->start(q);
}

addRequest() [1/2]

int QHttpPrivate::addRequest

(

QHttpNormalRequest *

req

)

Definition at line 2440 of file qhttp.cpp.

{
    QHttpRequestHeader h = req->requestHeader();
    if (h.path().isEmpty()) {
        // note: the following qWarning is autotested. If you change it, change the test too.
        qWarning("QHttp: empty path requested is invalid -- using '/'");
        h.setRequest(h.method(), QLatin1String("/"), h.majorVersion(), h.minorVersion());
        req->setRequestHeader(h);
    }

    // contine below
    return addRequest(static_cast<QHttpRequest *>(req));
}

addRequest() [2/2]

int QHttpPrivate::addRequest

(

QHttpRequest *

req

)

Definition at line 2454 of file qhttp.cpp.

{
    Q_Q(QHttp);
    pending.append(req);

    if (pending.count() == 1) {
        // don't emit the requestStarted() signal before the id is returned
        QMetaObject::invokeMethod(q, "_q_startNextRequest", Qt::QueuedConnection);
    }
    return req->id;
}

closeConn()

void QHttpPrivate::closeConn

(

)

Definition at line 3141 of file qhttp.cpp.

{
    Q_Q(QHttp);
    // If no connection is open -> ignore
    if (state == QHttp::Closing || state == QHttp::Unconnected)
        return;

    postDevice = 0;
    setState(QHttp::Closing);

    // Already closed ?
    if (!socket || !socket->isOpen()) {
        QMetaObject::invokeMethod(q, "_q_slotDoFinished", Qt::QueuedConnection);
    } else {
        // Close now.
        socket->close();
    }
}

finishedWithError()

void QHttpPrivate::finishedWithError	(	const QString &	detail,
		int	errorCode
	)

Definition at line 2619 of file qhttp.cpp.

{
    Q_Q(QHttp);
    if (pending.isEmpty())
        return;
    QHttpRequest *r = pending.first();
    hasFinishedWithError = true;

    error = QHttp::Error(errorCode);
    errorString = detail;

    // did we recurse?
    if (!r->finished) {
        r->finished = true;
        emit q->requestFinished(r->id, true);
    }

    while (!pending.isEmpty())
        delete pending.takeFirst();
    emit q->done(hasFinishedWithError);
}

finishedWithSuccess()

void QHttpPrivate::finishedWithSuccess

(

)

Definition at line 2589 of file qhttp.cpp.

{
    Q_Q(QHttp);
    if (pending.isEmpty())
        return;
    QHttpRequest *r = pending.first();

    // did we recurse?
    if (r->finished)
        return;
    r->finished = true;
    hasFinishedWithError = false;

    emit q->requestFinished(r->id, false);
    if (hasFinishedWithError) {
        // we recursed and changed into an error. The finishedWithError function
        // below has emitted the done(bool) signal and cleared the queue by now.
        return;
    }

    pending.removeFirst();
    delete r;

    if (pending.isEmpty()) {
        emit q->done(false);
    } else {
        _q_startNextRequest();
    }
}

init()

void QHttpPrivate::init

(

)

Definition at line 1609 of file qhttp.cpp.

{
    Q_Q(QHttp);
    errorString = QLatin1String(QT_TRANSLATE_NOOP("QHttp", "Unknown error"));
    QMetaObject::invokeMethod(q, "_q_slotDoFinished", Qt::QueuedConnection);
    post100ContinueTimer.setSingleShot(true);
    QObject::connect(&post100ContinueTimer, SIGNAL(timeout()), q, SLOT(_q_continuePost()));
}

postMoreData()

void QHttpPrivate::postMoreData

(

)

Definition at line 2756 of file qhttp.cpp.

{
    if (pendingPost)
        return;

    if (!postDevice)
        return;

    // the following is backported code from Qt 4.6 QNetworkAccessManager.
    // We also have to check the encryptedBytesToWrite() if it is an SSL socket.
#ifndef QT_NO_OPENSSL
    QSslSocket *sslSocket = qobject_cast<QSslSocket*>(socket);
    // if it is really an ssl socket, check more than just bytesToWrite()
    if ((socket->bytesToWrite() + (sslSocket ? sslSocket->encryptedBytesToWrite() : 0)) == 0) {
#else
    if (socket->bytesToWrite() == 0) {
#endif
        int max = qMin<qint64>(4096, postDevice->size() - postDevice->pos());
        QByteArray arr;
        arr.resize(max);

        int n = postDevice->read(arr.data(), max);
        if (n < 0) {
            qWarning("Could not read enough bytes from the device");
            closeConn();
            return;
        }
        if (postDevice->atEnd()) {
            postDevice = 0;
        }

        socket->write(arr, n);
    }
}

setSock()

void QHttpPrivate::setSock

(

QTcpSocket *

sock

)

Definition at line 3160 of file qhttp.cpp.

{
    Q_Q(const QHttp);

    // disconnect all existing signals
    if (socket)
        socket->disconnect();
    if (deleteSocket)
        delete socket;

    // use the new QTcpSocket socket, or create one if socket is 0.
    deleteSocket = (sock == 0);
    socket = sock;
    if (!socket) {
#ifndef QT_NO_OPENSSL
        if (QSslSocket::supportsSsl())
            socket = new QSslSocket();
        else
#endif
            socket = new QTcpSocket();
    }

    // connect all signals
    QObject::connect(socket, SIGNAL(connected()), q, SLOT(_q_slotConnected()));
    QObject::connect(socket, SIGNAL(disconnected()), q, SLOT(_q_slotClosed()));
    QObject::connect(socket, SIGNAL(readyRead()), q, SLOT(_q_slotReadyRead()));
    QObject::connect(socket, SIGNAL(error(QAbstractSocket::SocketError)), q, SLOT(_q_slotError(QAbstractSocket::SocketError)));
    QObject::connect(socket, SIGNAL(bytesWritten(qint64)),
                     q, SLOT(_q_slotBytesWritten(qint64)));
#ifndef QT_NO_NETWORKPROXY
    QObject::connect(socket, SIGNAL(proxyAuthenticationRequired(QNetworkProxy,QAuthenticator*)),
                     q, SIGNAL(proxyAuthenticationRequired(QNetworkProxy,QAuthenticator*)));
#endif

#ifndef QT_NO_OPENSSL
    if (qobject_cast<QSslSocket *>(socket)) {
        QObject::connect(socket, SIGNAL(sslErrors(QList<QSslError>)),
                         q, SIGNAL(sslErrors(QList<QSslError>)));
        QObject::connect(socket, SIGNAL(encryptedBytesWritten(qint64)),
                         q, SLOT(_q_slotEncryptedBytesWritten(qint64)));
    }
#endif
}

setState()

void QHttpPrivate::setState

(

int

s

)

Definition at line 3131 of file qhttp.cpp.

{
    Q_Q(QHttp);
#if defined(QHTTP_DEBUG)
    qDebug("QHttp state changed %d -> %d", state, s);
#endif
    state = QHttp::State(s);
    emit q->stateChanged(s);
}

Properties

authenticator

QAuthenticator QHttpPrivate::authenticator

Definition at line 176 of file qhttp.cpp.

buffer

QByteArray QHttpPrivate::buffer

Definition at line 156 of file qhttp.cpp.

bytesDone

qint64 QHttpPrivate::bytesDone

Definition at line 160 of file qhttp.cpp.

bytesTotal

qint64 QHttpPrivate::bytesTotal

Definition at line 161 of file qhttp.cpp.

chunkedSize

qint64 QHttpPrivate::chunkedSize

Definition at line 162 of file qhttp.cpp.

deleteSocket

bool QHttpPrivate::deleteSocket

Definition at line 145 of file qhttp.cpp.

error

QHttp::Error QHttpPrivate::error

Definition at line 149 of file qhttp.cpp.

errorString

QString QHttpPrivate::errorString

Definition at line 150 of file qhttp.cpp.

hasFinishedWithError

bool QHttpPrivate::hasFinishedWithError

Definition at line 178 of file qhttp.cpp.

header

QHttpRequestHeader QHttpPrivate::header

Definition at line 164 of file qhttp.cpp.

headerStr

QString QHttpPrivate::headerStr

Definition at line 167 of file qhttp.cpp.

hostName

QString QHttpPrivate::hostName

Definition at line 152 of file qhttp.cpp.

mode

QHttp::ConnectionMode QHttpPrivate::mode

Definition at line 154 of file qhttp.cpp.

pending

QList<QHttpRequest *> QHttpPrivate::pending

Definition at line 146 of file qhttp.cpp.

pendingPost

bool QHttpPrivate::pendingPost

Definition at line 179 of file qhttp.cpp.

port

quint16 QHttpPrivate::port

Definition at line 153 of file qhttp.cpp.

post100ContinueTimer

QTimer QHttpPrivate::post100ContinueTimer

Definition at line 180 of file qhttp.cpp.

postDevice

QIODevice* QHttpPrivate::postDevice

Definition at line 158 of file qhttp.cpp.

proxy

QNetworkProxy QHttpPrivate::proxy

Definition at line 173 of file qhttp.cpp.

proxyAuthenticator

QAuthenticator QHttpPrivate::proxyAuthenticator

Definition at line 174 of file qhttp.cpp.

rba

QRingBuffer QHttpPrivate::rba

Definition at line 170 of file qhttp.cpp.

readHeader

bool QHttpPrivate::readHeader

Definition at line 166 of file qhttp.cpp.

reconnectAttempts

int QHttpPrivate::reconnectAttempts

Definition at line 144 of file qhttp.cpp.

repost

bool QHttpPrivate::repost

Definition at line 177 of file qhttp.cpp.

response

QHttpResponseHeader QHttpPrivate::response

Definition at line 168 of file qhttp.cpp.

socket

QTcpSocket* QHttpPrivate::socket

Definition at line 143 of file qhttp.cpp.

state

QHttp::State QHttpPrivate::state

Definition at line 148 of file qhttp.cpp.

toDevice

QIODevice* QHttpPrivate::toDevice

Definition at line 157 of file qhttp.cpp.

---

The documentation for this class was generated from the following file:

• /src/network/access/qhttp.cpp