#include <qhttpthreaddelegate_p.h>

Inheritance diagram for QHttpThreadDelegate:

Public Slots
void	abortRequest ()

void	readBufferFreed (qint64 size)

void	readBufferSizeChanged (qint64 size)

void	startRequest ()

void	startRequestSynchronously ()

Public Slots inherited from QObject
void	deleteLater ()
	Schedules this object for deletion. More...

Signals
void	authenticationRequired (const QHttpNetworkRequest &request, QAuthenticator *)

void	downloadData (QByteArray)

void	downloadFinished ()

void	downloadMetaData (QList< QPair< QByteArray, QByteArray > >, int, QString, bool, QSharedPointer< char >, qint64)

void	downloadProgress (qint64, qint64)

void	error (QNetworkReply::NetworkError, const QString)

void	proxyAuthenticationRequired (const QNetworkProxy &, QAuthenticator *)

void	sslConfigurationChanged (const QSslConfiguration)

void	sslErrors (const QList< QSslError > &, bool , QList< QSslError > )

Signals inherited from QObject
void	destroyed (QObject *=0)
	This signal is emitted immediately before the object obj is destroyed, and can not be blocked. More...

Public Functions
	QHttpThreadDelegate (QObject *parent=0)

	~QHttpThreadDelegate ()

Public Functions inherited from QObject
bool	blockSignals (bool b)
	If block is true, signals emitted by this object are blocked (i.e., emitting a signal will not invoke anything connected to it). More...

const QObjectList &	children () const
	Returns a list of child objects. More...

bool	connect (const QObject sender, const char signal, const char *member, Qt::ConnectionType type=Qt::AutoConnection) const

bool	disconnect (const char signal=0, const QObject receiver=0, const char *member=0)

bool	disconnect (const QObject receiver, const char member=0)

void	dumpObjectInfo ()
	Dumps information about signal connections, etc. More...

void	dumpObjectTree ()
	Dumps a tree of children to the debug output. More...

QList< QByteArray >	dynamicPropertyNames () const
	Returns the names of all properties that were dynamically added to the object using setProperty(). More...

virtual bool	event (QEvent *)
	This virtual function receives events to an object and should return true if the event e was recognized and processed. More...

virtual bool	eventFilter (QObject , QEvent )
	Filters events if this object has been installed as an event filter for the watched object. More...

template<typename T >
T	findChild (const QString &aName=QString()) const
	Returns the child of this object that can be cast into type T and that is called name, or 0 if there is no such object. More...

template<typename T >
QList< T >	findChildren (const QString &aName=QString()) const
	Returns all children of this object with the given name that can be cast to type T, or an empty list if there are no such objects. More...

template<typename T >
QList< T >	findChildren (const QRegExp &re) const

bool	inherits (const char *classname) const
	Returns true if this object is an instance of a class that inherits className or a QObject subclass that inherits className; otherwise returns false. More...

void	installEventFilter (QObject *)
	Installs an event filter filterObj on this object. More...

bool	isWidgetType () const
	Returns true if the object is a widget; otherwise returns false. More...

void	killTimer (int id)
	Kills the timer with timer identifier, id. More...

virtual const QMetaObject *	metaObject () const
	Returns a pointer to the meta-object of this object. More...

void	moveToThread (QThread *thread)
	Changes the thread affinity for this object and its children. More...

QString	objectName () const

QObject *	parent () const
	Returns a pointer to the parent object. More...

QVariant	property (const char *name) const
	Returns the value of the object's name property. More...

Q_INVOKABLE	QObject (QObject *parent=0)
	Constructs an object with parent object parent. More...

void	removeEventFilter (QObject *)
	Removes an event filter object obj from this object. More...

void	setObjectName (const QString &name)

void	setParent (QObject *)
	Makes the object a child of parent. More...

bool	setProperty (const char *name, const QVariant &value)
	Sets the value of the object's name property to value. More...

void	setUserData (uint id, QObjectUserData *data)

bool	signalsBlocked () const
	Returns true if signals are blocked; otherwise returns false. More...

int	startTimer (int interval)
	Starts a timer and returns a timer identifier, or returns zero if it could not start a timer. More...

QThread *	thread () const
	Returns the thread in which the object lives. More...

QObjectUserData *	userData (uint id) const

virtual	~QObject ()
	Destroys the object, deleting all its child objects. More...

Protected Slots
void	cacheCredentialsSlot (const QHttpNetworkRequest &request, QAuthenticator *authenticator)

void	dataReadProgressSlot (int done, int total)

void	finishedSlot ()

void	finishedWithErrorSlot (QNetworkReply::NetworkError errorCode, const QString &detail=QString())

void	headerChangedSlot ()

void	readyReadSlot ()

void	sslErrorsSlot (const QList< QSslError > &errors)

void	synchronousAuthenticationRequiredSlot (const QHttpNetworkRequest &request, QAuthenticator *)

void	synchronousFinishedSlot ()

void	synchronousFinishedWithErrorSlot (QNetworkReply::NetworkError errorCode, const QString &detail=QString())

void	synchronousHeaderChangedSlot ()

void	synchronousProxyAuthenticationRequiredSlot (const QNetworkProxy &, QAuthenticator *)

Protected Variables
QByteArray	cacheKey

QSharedPointer< char >	downloadBuffer

QNetworkAccessCachedHttpConnection *	httpConnection

QHttpNetworkReply *	httpReply

QEventLoop *	synchronousRequestLoop

Protected Variables inherited from QObject
QScopedPointer< QObjectData >	d_ptr

Static Protected Variables
static QThreadStorage< QNetworkAccessCache * >	connections

Static Protected Variables inherited from QObject
static const QMetaObject	staticQtMetaObject

Additional Inherited Members
Static Public Functions inherited from QObject
static bool	connect (const QObject sender, const char signal, const QObject receiver, const char member, Qt::ConnectionType=Qt::AutoConnection)
	Creates a connection of the given type from the signal in the sender object to the method in the receiver object. More...

static bool	connect (const QObject sender, const QMetaMethod &signal, const QObject receiver, const QMetaMethod &method, Qt::ConnectionType type=Qt::AutoConnection)

static bool	disconnect (const QObject sender, const char signal, const QObject receiver, const char member)
	Disconnects signal in object sender from method in object receiver. More...

static bool	disconnect (const QObject sender, const QMetaMethod &signal, const QObject receiver, const QMetaMethod &member)

static uint	registerUserData ()

static QString	tr (const char sourceText, const char comment=0, int n=-1)

static QString	trUtf8 (const char sourceText, const char comment=0, int n=-1)

Static Public Variables inherited from QObject
static const QMetaObject	staticMetaObject
	This variable stores the meta-object for the class. More...

Protected Functions inherited from QObject
virtual void	childEvent (QChildEvent *)
	This event handler can be reimplemented in a subclass to receive child events. More...

virtual void	connectNotify (const char *signal)
	This virtual function is called when something has been connected to signal in this object. More...

virtual void	customEvent (QEvent *)
	This event handler can be reimplemented in a subclass to receive custom events. More...

virtual void	disconnectNotify (const char *signal)
	This virtual function is called when something has been disconnected from signal in this object. More...

	QObject (QObjectPrivate &dd, QObject *parent=0)

int	receivers (const char *signal) const
	Returns the number of receivers connected to the signal. More...

QObject *	sender () const
	Returns a pointer to the object that sent the signal, if called in a slot activated by a signal; otherwise it returns 0. More...

int	senderSignalIndex () const

virtual void	timerEvent (QTimerEvent *)
	This event handler can be reimplemented in a subclass to receive timer events for the object. More...

Related Functions inherited from QObject
T	qFindChildqFindChildren (const QObject *obj, const QString &name)()

QList< T >	qFindChildrenqFindChildren (const QObject *obj, const QString &name)()

QList< T >	qFindChildrenqFindChildren (const QObject *obj, const QRegExp &regExp)()

T *	qobject_cast (QObject *object)

	QObjectList

void *	qt_find_obj_child (QObject parent, const char type, const QString &name)
	Returns a pointer to the object named name that inherits type and with a given parent. More...

Detailed Description

Definition at line 81 of file qhttpthreaddelegate_p.h.

Constructors and Destructors

◆ QHttpThreadDelegate()

QHttpThreadDelegate::QHttpThreadDelegate ( QObject * parent = 0 )

explicit

Definition at line 193 of file qhttpthreaddelegate.cpp.

                                                         :
     QObject(parent)
     , ssl(false)
     , downloadBufferMaximumSize(0)
     , readBufferMaxSize(0)
     , bytesEmitted(0)
     , pendingDownloadData(0)
     , pendingDownloadProgress(0)
     , synchronous(false)
     , incomingStatusCode(0)
     , isPipeliningUsed(false)
     , incomingContentLength(-1)
     , incomingErrorCode(QNetworkReply::NoError)
     , downloadBuffer(0)
     , httpConnection(0)
     , httpReply(0)
     , synchronousRequestLoop(0)
 {
 }

◆ ~QHttpThreadDelegate()

QHttpThreadDelegate::~QHttpThreadDelegate ( )

Definition at line 178 of file qhttpthreaddelegate.cpp.

 {
     // It could be that the main thread has asked us to shut down, so we need to delete the HTTP reply
     if (httpReply) {
         delete httpReply;
     }
 
     // Get the object cache that stores our QHttpNetworkConnection objects
     // and release the entry for this QHttpNetworkConnection
     if (connections.hasLocalData() && !cacheKey.isEmpty()) {
         connections.localData()->releaseEntry(cacheKey);
     }
 }

Functions

◆ abortRequest

void QHttpThreadDelegate::abortRequest ( )

slot

Definition at line 334 of file qhttpthreaddelegate.cpp.

Referenced by startRequestSynchronously().

 {
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::abortRequest() thread=" << QThread::currentThreadId() << "sync=" << synchronous;
 #endif
     if (httpReply) {
         delete httpReply;
         httpReply = 0;
     }
 
     // Got aborted by the timeout timer
     if (synchronous) {
         incomingErrorCode = QNetworkReply::TimeoutError;
         QMetaObject::invokeMethod(synchronousRequestLoop, "quit", Qt::QueuedConnection);
     } else {
         //only delete this for asynchronous mode or QNetworkAccessHttpBackend will crash - see QNetworkAccessHttpBackend::postRequest()
         this->deleteLater();
     }
 }

◆ authenticationRequired

void QHttpThreadDelegate::authenticationRequired	(	const QHttpNetworkRequest &	request,
		QAuthenticator *
	)

signal

Referenced by startRequest(), and synchronousAuthenticationRequiredSlot().

◆ cacheCredentialsSlot

void QHttpThreadDelegate::cacheCredentialsSlot	(	const QHttpNetworkRequest &	request,
		QAuthenticator *	authenticator
	)

protectedslot

Definition at line 580 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     authenticationManager->cacheCredentials(request.url(), authenticator);
 }

◆ dataReadProgressSlot

void QHttpThreadDelegate::dataReadProgressSlot	(	int	done,
		int	total
	)

protectedslot

Definition at line 569 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     // If we don't have a download buffer don't attempt to go this codepath
     // It is not used by QNetworkAccessHttpBackend
     if (downloadBuffer.isNull())
         return;
 
     pendingDownloadProgress->fetchAndAddRelease(1);
     emit downloadProgress(done, total);
 }

◆ downloadData

void QHttpThreadDelegate::downloadData ( QByteArray )

signal

Referenced by finishedSlot(), and readyReadSlot().

◆ downloadFinished

void QHttpThreadDelegate::downloadFinished ( )

signal

Referenced by finishedSlot(), and finishedWithErrorSlot().

◆ downloadMetaData

void QHttpThreadDelegate::downloadMetaData	(	QList< QPair< QByteArray, QByteArray > >	,
		int	,
		QString	,
		bool	,
		QSharedPointer< char >	,
		qint64
	)

signal

Referenced by headerChangedSlot().

◆ downloadProgress

void QHttpThreadDelegate::downloadProgress	(	qint64	,
		qint64
	)

signal

Referenced by dataReadProgressSlot().

◆ error

void QHttpThreadDelegate::error	(	QNetworkReply::NetworkError	,
		const QString
	)

signal

Referenced by finishedSlot(), and finishedWithErrorSlot().

◆ finishedSlot

void QHttpThreadDelegate::finishedSlot ( )

protectedslot

Definition at line 411 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::finishedSlot() thread=" << QThread::currentThreadId() << "result=" << httpReply->statusCode();
 #endif
 
     // If there is still some data left emit that now
     while (httpReply->readAnyAvailable()) {
         pendingDownloadData->fetchAndAddRelease(1);
         emit downloadData(httpReply->readAny());
     }
 
 #ifndef QT_NO_OPENSSL
     if (ssl)
         emit sslConfigurationChanged(httpReply->sslConfiguration());
 #endif
 
     if (httpReply->statusCode() >= 400) {
             // it's an error reply
             QString msg = QLatin1String(QT_TRANSLATE_NOOP("QNetworkReply",
                                                           "Error downloading %1 - server replied: %2"));
             msg = msg.arg(QString::fromAscii(httpRequest.url().toEncoded()), httpReply->reasonPhrase());
             emit error(statusCodeFromHttp(httpReply->statusCode(), httpRequest.url()), msg);
         }
 
     emit downloadFinished();
 
     QMetaObject::invokeMethod(httpReply, "deleteLater", Qt::QueuedConnection);
     QMetaObject::invokeMethod(this, "deleteLater", Qt::QueuedConnection);
     httpReply = 0;
 }

◆ finishedWithErrorSlot

void QHttpThreadDelegate::finishedWithErrorSlot	(	QNetworkReply::NetworkError	errorCode,
		const QString &	detail = `QString()`
	)

protectedslot

Definition at line 469 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::finishedWithErrorSlot() thread=" << QThread::currentThreadId() << "error=" << errorCode << detail;
 #endif
 
 #ifndef QT_NO_OPENSSL
     if (ssl)
         emit sslConfigurationChanged(httpReply->sslConfiguration());
 #endif
     emit error(errorCode,detail);
     emit downloadFinished();
 
 
     QMetaObject::invokeMethod(httpReply, "deleteLater", Qt::QueuedConnection);
     QMetaObject::invokeMethod(this, "deleteLater", Qt::QueuedConnection);
     httpReply = 0;
 }

◆ headerChangedSlot

void QHttpThreadDelegate::headerChangedSlot ( )

protectedslot

Definition at line 513 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::headerChangedSlot() thread=" << QThread::currentThreadId();
 #endif
 
 #ifndef QT_NO_OPENSSL
     if (ssl)
         emit sslConfigurationChanged(httpReply->sslConfiguration());
 #endif
 
     // Is using a zerocopy buffer allowed by user and possible with this reply?
     if (httpReply->supportsUserProvidedDownloadBuffer()
         && downloadBufferMaximumSize > 0) {
         char *buf = new char[httpReply->contentLength()]; // throws if allocation fails
         if (buf) {
             downloadBuffer = QSharedPointer<char>(buf, downloadBufferDeleter);
             httpReply->setUserProvidedDownloadBuffer(buf);
         }
     }
 
     // We fetch this into our own
     incomingHeaders = httpReply->header();
     incomingStatusCode = httpReply->statusCode();
     incomingReasonPhrase = httpReply->reasonPhrase();
     isPipeliningUsed = httpReply->isPipeliningUsed();
     incomingContentLength = httpReply->contentLength();
 
     emit downloadMetaData(incomingHeaders,
                           incomingStatusCode,
                           incomingReasonPhrase,
                           isPipeliningUsed,
                           downloadBuffer,
                           incomingContentLength);
 }

◆ proxyAuthenticationRequired

void QHttpThreadDelegate::proxyAuthenticationRequired	(	const QNetworkProxy &	,
		QAuthenticator *
	)

signal

Referenced by startRequest(), and synchronousProxyAuthenticationRequiredSlot().

◆ readBufferFreed

void QHttpThreadDelegate::readBufferFreed ( qint64 size )

slot

Definition at line 366 of file qhttpthreaddelegate.cpp.

 {
     if (readBufferMaxSize) {
         bytesEmitted -= size;
 
         QMetaObject::invokeMethod(this, "readyReadSlot", Qt::QueuedConnection);
     }
 }

◆ readBufferSizeChanged

void QHttpThreadDelegate::readBufferSizeChanged ( qint64 size )

slot

Definition at line 354 of file qhttpthreaddelegate.cpp.

 {
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::readBufferSizeChanged() size " << size;
 #endif
     if (httpReply) {
         httpReply->setDownstreamLimited(true);
         httpReply->setReadBufferSize(size);
         readBufferMaxSize = size;
     }
 }

◆ readyReadSlot

void QHttpThreadDelegate::readyReadSlot ( )

protectedslot

Definition at line 375 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
     // Don't do in zerocopy case
     if (!downloadBuffer.isNull())
         return;
 
     if (readBufferMaxSize) {
         if (bytesEmitted < readBufferMaxSize) {
             qint64 sizeEmitted = 0;
             while (httpReply->readAnyAvailable() && (sizeEmitted < (readBufferMaxSize-bytesEmitted))) {
                 if (httpReply->sizeNextBlock() > (readBufferMaxSize-bytesEmitted)) {
                     sizeEmitted = readBufferMaxSize-bytesEmitted;
                     bytesEmitted += sizeEmitted;
                     pendingDownloadData->fetchAndAddRelease(1);
                     emit downloadData(httpReply->read(sizeEmitted));
                 } else {
                     sizeEmitted = httpReply->sizeNextBlock();
                     bytesEmitted += sizeEmitted;
                     pendingDownloadData->fetchAndAddRelease(1);
                     emit downloadData(httpReply->readAny());
                 }
             }
         } else {
             // We need to wait until we empty data from the read buffer in the reply.
         }
     } else {
         while (httpReply->readAnyAvailable()) {
             pendingDownloadData->fetchAndAddRelease(1);
             emit downloadData(httpReply->readAny());
         }
     }
 }

◆ sslConfigurationChanged

void QHttpThreadDelegate::sslConfigurationChanged ( const QSslConfiguration )

signal

Referenced by finishedSlot(), finishedWithErrorSlot(), headerChangedSlot(), and sslErrorsSlot().

◆ sslErrors

void QHttpThreadDelegate::sslErrors	(	const QList< QSslError > &	,
		bool *	,
		QList< QSslError > *
	)

signal

Referenced by sslErrorsSlot(), and startRequest().

◆ sslErrorsSlot

void QHttpThreadDelegate::sslErrorsSlot ( const QList< QSslError > & errors )

protectedslot

Definition at line 587 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
     emit sslConfigurationChanged(httpReply->sslConfiguration());
 
     bool ignoreAll = false;
     QList<QSslError> specificErrors;
     emit sslErrors(errors, &ignoreAll, &specificErrors);
     if (ignoreAll)
         httpReply->ignoreSslErrors();
     if (!specificErrors.isEmpty())
         httpReply->ignoreSslErrors(specificErrors);
 }

◆ startRequest

void QHttpThreadDelegate::startRequest ( )

slot

Definition at line 240 of file qhttpthreaddelegate.cpp.

 {
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::startRequest() thread=" << QThread::currentThreadId();
 #endif
     // Check QThreadStorage for the QNetworkAccessCache
     // If not there, create this connection cache
     if (!connections.hasLocalData()) {
         connections.setLocalData(new QNetworkAccessCache());
     }
 
     // check if we have an open connection to this host
     QUrl urlCopy = httpRequest.url();
     urlCopy.setPort(urlCopy.port(ssl ? 443 : 80));
 
 #ifndef QT_NO_NETWORKPROXY
     if (transparentProxy.type() != QNetworkProxy::NoProxy)
         cacheKey = makeCacheKey(urlCopy, &transparentProxy);
     else if (cacheProxy.type() != QNetworkProxy::NoProxy)
         cacheKey = makeCacheKey(urlCopy, &cacheProxy);
     else
 #endif
         cacheKey = makeCacheKey(urlCopy, 0);
 
 
     // the http object is actually a QHttpNetworkConnection
     httpConnection = static_cast<QNetworkAccessCachedHttpConnection *>(connections.localData()->requestEntryNow(cacheKey));
     if (httpConnection == 0) {
         // no entry in cache; create an object
         // the http object is actually a QHttpNetworkConnection
 #ifdef QT_NO_BEARERMANAGEMENT
         httpConnection = new QNetworkAccessCachedHttpConnection(urlCopy.host(), urlCopy.port(), ssl);
 #else
         httpConnection = new QNetworkAccessCachedHttpConnection(urlCopy.host(), urlCopy.port(), ssl, networkSession);
 #endif
 #ifndef QT_NO_OPENSSL
         // Set the QSslConfiguration from this QNetworkRequest.
         if (ssl && incomingSslConfiguration != QSslConfiguration::defaultConfiguration()) {
             httpConnection->setSslConfiguration(incomingSslConfiguration);
         }
 #endif
 
 #ifndef QT_NO_NETWORKPROXY
         httpConnection->setTransparentProxy(transparentProxy);
         httpConnection->setCacheProxy(cacheProxy);
 #endif
 
         // cache the QHttpNetworkConnection corresponding to this cache key
         connections.localData()->addEntry(cacheKey, httpConnection);
     }
 
 
     // Send the request to the connection
     httpReply = httpConnection->sendRequest(httpRequest);
     httpReply->setParent(this);
 
     // Connect the reply signals that we need to handle and then forward
     if (synchronous) {
         connect(httpReply,SIGNAL(headerChanged()), this, SLOT(synchronousHeaderChangedSlot()));
         connect(httpReply,SIGNAL(finished()), this, SLOT(synchronousFinishedSlot()));
         connect(httpReply,SIGNAL(finishedWithError(QNetworkReply::NetworkError, const QString)),
                 this, SLOT(synchronousFinishedWithErrorSlot(QNetworkReply::NetworkError,QString)));
 
         connect(httpReply, SIGNAL(authenticationRequired(QHttpNetworkRequest,QAuthenticator*)),
                 this, SLOT(synchronousAuthenticationRequiredSlot(QHttpNetworkRequest,QAuthenticator*)));
         connect(httpReply, SIGNAL(proxyAuthenticationRequired(QNetworkProxy,QAuthenticator*)),
                 this, SLOT(synchronousProxyAuthenticationRequiredSlot(QNetworkProxy,QAuthenticator*)));
 
         // Don't care about ignored SSL errors for now in the synchronous HTTP case.
     } else if (!synchronous) {
         connect(httpReply,SIGNAL(headerChanged()), this, SLOT(headerChangedSlot()));
         connect(httpReply,SIGNAL(finished()), this, SLOT(finishedSlot()));
         connect(httpReply,SIGNAL(finishedWithError(QNetworkReply::NetworkError, const QString)),
                 this, SLOT(finishedWithErrorSlot(QNetworkReply::NetworkError,QString)));
         // some signals are only interesting when normal asynchronous style is used
         connect(httpReply,SIGNAL(readyRead()), this, SLOT(readyReadSlot()));
         connect(httpReply,SIGNAL(dataReadProgress(int, int)), this, SLOT(dataReadProgressSlot(int,int)));
 #ifndef QT_NO_OPENSSL
         connect(httpReply,SIGNAL(sslErrors(const QList<QSslError>)), this, SLOT(sslErrorsSlot(QList<QSslError>)));
 #endif
 
         // In the asynchronous HTTP case we can just forward those signals
         // Connect the reply signals that we can directly forward
         connect(httpReply, SIGNAL(authenticationRequired(QHttpNetworkRequest,QAuthenticator*)),
                 this, SIGNAL(authenticationRequired(QHttpNetworkRequest,QAuthenticator*)));
         connect(httpReply, SIGNAL(proxyAuthenticationRequired(QNetworkProxy,QAuthenticator*)),
                 this, SIGNAL(proxyAuthenticationRequired(QNetworkProxy,QAuthenticator*)));
     }
 
     connect(httpReply, SIGNAL(cacheCredentials(QHttpNetworkRequest,QAuthenticator*)),
             this, SLOT(cacheCredentialsSlot(QHttpNetworkRequest,QAuthenticator*)));
 }

◆ startRequestSynchronously

void QHttpThreadDelegate::startRequestSynchronously ( )

slot

Definition at line 214 of file qhttpthreaddelegate.cpp.

 {
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::startRequestSynchronously() thread=" << QThread::currentThreadId();
 #endif
     synchronous = true;
 
     QEventLoop synchronousRequestLoop;
     this->synchronousRequestLoop = &synchronousRequestLoop;
 
     // Worst case timeout
     QTimer::singleShot(30*1000, this, SLOT(abortRequest()));
 
     QMetaObject::invokeMethod(this, "startRequest", Qt::QueuedConnection);
     synchronousRequestLoop.exec();
 
     connections.localData()->releaseEntry(cacheKey);
     connections.setLocalData(0);
 
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::startRequestSynchronously() thread=" << QThread::currentThreadId() << "finished";
 #endif
 }

◆ synchronousAuthenticationRequiredSlot

void QHttpThreadDelegate::synchronousAuthenticationRequiredSlot	(	const QHttpNetworkRequest &	request,
		QAuthenticator *	a
	)

protectedslot

Definition at line 604 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
     Q_UNUSED(request);
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::synchronousAuthenticationRequiredSlot() thread=" << QThread::currentThreadId();
 #endif
 
     // Ask the credential cache
     QNetworkAuthenticationCredential credential = authenticationManager->fetchCachedCredentials(httpRequest.url(), a);
     if (!credential.isNull()) {
         a->setUser(credential.user);
         a->setPassword(credential.password);
     }
 
     // Disconnect this connection now since we only want to ask the authentication cache once.
     QObject::disconnect(httpReply, SIGNAL(authenticationRequired(QHttpNetworkRequest,QAuthenticator*)),
         this, SLOT(synchronousAuthenticationRequiredSlot(QHttpNetworkRequest,QAuthenticator*)));
 }

◆ synchronousFinishedSlot

void QHttpThreadDelegate::synchronousFinishedSlot ( )

protectedslot

Definition at line 446 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::synchronousFinishedSlot() thread=" << QThread::currentThreadId() << "result=" << httpReply->statusCode();
 #endif
     if (httpReply->statusCode() >= 400) {
             // it's an error reply
             QString msg = QLatin1String(QT_TRANSLATE_NOOP("QNetworkReply",
                                                           "Error downloading %1 - server replied: %2"));
             incomingErrorDetail = msg.arg(QString::fromAscii(httpRequest.url().toEncoded()), httpReply->reasonPhrase());
             incomingErrorCode = statusCodeFromHttp(httpReply->statusCode(), httpRequest.url());
     }
 
     synchronousDownloadData = httpReply->readAll();
 
     QMetaObject::invokeMethod(httpReply, "deleteLater", Qt::QueuedConnection);
     QMetaObject::invokeMethod(synchronousRequestLoop, "quit", Qt::QueuedConnection);
     httpReply = 0;
 }

◆ synchronousFinishedWithErrorSlot

void QHttpThreadDelegate::synchronousFinishedWithErrorSlot	(	QNetworkReply::NetworkError	errorCode,
		const QString &	detail = `QString()`
	)

protectedslot

Definition at line 492 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::synchronousFinishedWithErrorSlot() thread=" << QThread::currentThreadId() << "error=" << errorCode << detail;
 #endif
     incomingErrorCode = errorCode;
     incomingErrorDetail = detail;
 
     QMetaObject::invokeMethod(httpReply, "deleteLater", Qt::QueuedConnection);
     QMetaObject::invokeMethod(synchronousRequestLoop, "quit", Qt::QueuedConnection);
     httpReply = 0;
 }

◆ synchronousHeaderChangedSlot

void QHttpThreadDelegate::synchronousHeaderChangedSlot ( )

protectedslot

Definition at line 552 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::synchronousHeaderChangedSlot() thread=" << QThread::currentThreadId();
 #endif
     // Store the information we need in this object, the QNetworkAccessHttpBackend will later read it
     incomingHeaders = httpReply->header();
     incomingStatusCode = httpReply->statusCode();
     incomingReasonPhrase = httpReply->reasonPhrase();
     isPipeliningUsed = httpReply->isPipeliningUsed();
     incomingContentLength = httpReply->contentLength();
 }

◆ synchronousProxyAuthenticationRequiredSlot

void QHttpThreadDelegate::synchronousProxyAuthenticationRequiredSlot	(	const QNetworkProxy &	p,
		QAuthenticator *	a
	)

protectedslot

Definition at line 627 of file qhttpthreaddelegate.cpp.

Referenced by startRequest().

 {
     if (!httpReply)
         return;
 
 #ifdef QHTTPTHREADDELEGATE_DEBUG
     qDebug() << "QHttpThreadDelegate::synchronousProxyAuthenticationRequiredSlot() thread=" << QThread::currentThreadId();
 #endif
     // Ask the credential cache
     QNetworkAuthenticationCredential credential = authenticationManager->fetchCachedProxyCredentials(p, a);
     if (!credential.isNull()) {
         a->setUser(credential.user);
         a->setPassword(credential.password);
     }
 
     // Disconnect this connection now since we only want to ask the authentication cache once.
     QObject::disconnect(httpReply, SIGNAL(proxyAuthenticationRequired(QNetworkProxy,QAuthenticator*)),
         this, SLOT(synchronousProxyAuthenticationRequiredSlot(QNetworkProxy,QAuthenticator*)));
 }

Properties

◆ authenticationManager

QSharedPointer<QNetworkAccessAuthenticationManager> QHttpThreadDelegate::authenticationManager

Definition at line 105 of file qhttpthreaddelegate_p.h.

Referenced by cacheCredentialsSlot(), QNetworkAccessHttpBackend::postRequest(), synchronousAuthenticationRequiredSlot(), and synchronousProxyAuthenticationRequiredSlot().

◆ bytesEmitted

qint64 QHttpThreadDelegate::bytesEmitted

Definition at line 97 of file qhttpthreaddelegate_p.h.

Referenced by readBufferFreed(), and readyReadSlot().

◆ cacheKey

QByteArray QHttpThreadDelegate::cacheKey

protected

Definition at line 126 of file qhttpthreaddelegate_p.h.

Referenced by startRequest(), and startRequestSynchronously().

◆ cacheProxy

QNetworkProxy QHttpThreadDelegate::cacheProxy

Definition at line 102 of file qhttpthreaddelegate_p.h.

Referenced by QNetworkAccessHttpBackend::postRequest(), and startRequest().

◆ connections

QThreadStorage< QNetworkAccessCache * > QHttpThreadDelegate::connections

staticprotected

Definition at line 177 of file qhttpthreaddelegate_p.h.

Referenced by QNetworkAccessCachedHttpConnection::dispose(), startRequest(), and startRequestSynchronously().

◆ downloadBuffer

QSharedPointer<char> QHttpThreadDelegate::downloadBuffer

protected

Definition at line 123 of file qhttpthreaddelegate_p.h.

Referenced by dataReadProgressSlot(), headerChangedSlot(), and readyReadSlot().

◆ downloadBufferMaximumSize

qint64 QHttpThreadDelegate::downloadBufferMaximumSize

Definition at line 95 of file qhttpthreaddelegate_p.h.

Referenced by headerChangedSlot(), and QNetworkAccessHttpBackend::postRequest().

◆ httpConnection

QNetworkAccessCachedHttpConnection* QHttpThreadDelegate::httpConnection

protected

Definition at line 125 of file qhttpthreaddelegate_p.h.

Referenced by startRequest().

◆ httpReply

QHttpNetworkReply* QHttpThreadDelegate::httpReply

protected

Definition at line 127 of file qhttpthreaddelegate_p.h.

Referenced by abortRequest(), finishedSlot(), finishedWithErrorSlot(), headerChangedSlot(), readBufferSizeChanged(), readyReadSlot(), sslErrorsSlot(), startRequest(), synchronousAuthenticationRequiredSlot(), synchronousFinishedSlot(), synchronousFinishedWithErrorSlot(), synchronousHeaderChangedSlot(), and synchronousProxyAuthenticationRequiredSlot().

◆ httpRequest

QHttpNetworkRequest QHttpThreadDelegate::httpRequest

Definition at line 94 of file qhttpthreaddelegate_p.h.

Referenced by finishedSlot(), QNetworkAccessHttpBackend::postRequest(), startRequest(), synchronousAuthenticationRequiredSlot(), and synchronousFinishedSlot().

◆ incomingContentLength

qint64 QHttpThreadDelegate::incomingContentLength

Definition at line 114 of file qhttpthreaddelegate_p.h.

Referenced by headerChangedSlot(), QNetworkAccessHttpBackend::postRequest(), and synchronousHeaderChangedSlot().

◆ incomingErrorCode

QNetworkReply::NetworkError QHttpThreadDelegate::incomingErrorCode

Definition at line 115 of file qhttpthreaddelegate_p.h.

Referenced by abortRequest(), QNetworkAccessHttpBackend::postRequest(), synchronousFinishedSlot(), and synchronousFinishedWithErrorSlot().

◆ incomingErrorDetail

QString QHttpThreadDelegate::incomingErrorDetail

Definition at line 116 of file qhttpthreaddelegate_p.h.

Referenced by QNetworkAccessHttpBackend::postRequest(), synchronousFinishedSlot(), and synchronousFinishedWithErrorSlot().

◆ incomingHeaders

QList<QPair<QByteArray,QByteArray> > QHttpThreadDelegate::incomingHeaders

Definition at line 110 of file qhttpthreaddelegate_p.h.

Referenced by headerChangedSlot(), QNetworkAccessHttpBackend::postRequest(), and synchronousHeaderChangedSlot().

◆ incomingReasonPhrase

QString QHttpThreadDelegate::incomingReasonPhrase

Definition at line 112 of file qhttpthreaddelegate_p.h.

Referenced by headerChangedSlot(), QNetworkAccessHttpBackend::postRequest(), and synchronousHeaderChangedSlot().

◆ incomingSslConfiguration

QSslConfiguration QHttpThreadDelegate::incomingSslConfiguration

Definition at line 92 of file qhttpthreaddelegate_p.h.

Referenced by QNetworkAccessHttpBackend::postRequest(), and startRequest().

◆ incomingStatusCode

int QHttpThreadDelegate::incomingStatusCode

Definition at line 111 of file qhttpthreaddelegate_p.h.

Referenced by headerChangedSlot(), QNetworkAccessHttpBackend::postRequest(), and synchronousHeaderChangedSlot().

◆ isPipeliningUsed

bool QHttpThreadDelegate::isPipeliningUsed

Definition at line 113 of file qhttpthreaddelegate_p.h.

Referenced by headerChangedSlot(), QNetworkAccessHttpBackend::postRequest(), and synchronousHeaderChangedSlot().

◆ networkSession

QSharedPointer<QNetworkSession> QHttpThreadDelegate::networkSession

Definition at line 118 of file qhttpthreaddelegate_p.h.

Referenced by QNetworkAccessHttpBackend::postRequest(), and startRequest().

◆ pendingDownloadData

QSharedPointer<QAtomicInt> QHttpThreadDelegate::pendingDownloadData

Definition at line 99 of file qhttpthreaddelegate_p.h.

Referenced by finishedSlot(), QNetworkAccessHttpBackend::postRequest(), and readyReadSlot().

◆ pendingDownloadProgress

QSharedPointer<QAtomicInt> QHttpThreadDelegate::pendingDownloadProgress

Definition at line 100 of file qhttpthreaddelegate_p.h.

Referenced by dataReadProgressSlot(), and QNetworkAccessHttpBackend::postRequest().

◆ readBufferMaxSize

qint64 QHttpThreadDelegate::readBufferMaxSize

Definition at line 96 of file qhttpthreaddelegate_p.h.

Referenced by readBufferFreed(), readBufferSizeChanged(), and readyReadSlot().

◆ ssl

bool QHttpThreadDelegate::ssl

Definition at line 90 of file qhttpthreaddelegate_p.h.

Referenced by finishedSlot(), finishedWithErrorSlot(), headerChangedSlot(), QNetworkAccessHttpBackend::postRequest(), and startRequest().

◆ synchronous

bool QHttpThreadDelegate::synchronous

Definition at line 106 of file qhttpthreaddelegate_p.h.

Referenced by abortRequest(), QNetworkAccessHttpBackend::postRequest(), startRequest(), and startRequestSynchronously().

◆ synchronousDownloadData

QByteArray QHttpThreadDelegate::synchronousDownloadData

Definition at line 109 of file qhttpthreaddelegate_p.h.

Referenced by QNetworkAccessHttpBackend::postRequest(), and synchronousFinishedSlot().

◆ synchronousRequestLoop

QEventLoop* QHttpThreadDelegate::synchronousRequestLoop

protected

Definition at line 130 of file qhttpthreaddelegate_p.h.

Referenced by abortRequest(), startRequestSynchronously(), synchronousFinishedSlot(), and synchronousFinishedWithErrorSlot().

◆ transparentProxy

QNetworkProxy QHttpThreadDelegate::transparentProxy

Definition at line 103 of file qhttpthreaddelegate_p.h.

Referenced by QNetworkAccessHttpBackend::postRequest(), and startRequest().

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

/src/network/access/qhttpthreaddelegate_p.h
/src/network/access/qhttpthreaddelegate.cpp

Public Variables
QSharedPointer< QNetworkAccessAuthenticationManager >	authenticationManager

qint64	bytesEmitted

QNetworkProxy	cacheProxy

qint64	downloadBufferMaximumSize

QHttpNetworkRequest	httpRequest

qint64	incomingContentLength

QNetworkReply::NetworkError	incomingErrorCode

QString	incomingErrorDetail

QList< QPair< QByteArray, QByteArray > >	incomingHeaders

QString	incomingReasonPhrase

QSslConfiguration	incomingSslConfiguration

int	incomingStatusCode

bool	isPipeliningUsed

QSharedPointer< QNetworkSession >	networkSession

QSharedPointer< QAtomicInt >	pendingDownloadData

QSharedPointer< QAtomicInt >	pendingDownloadProgress

qint64	readBufferMaxSize

bool	ssl

bool	synchronous

QByteArray	synchronousDownloadData

QNetworkProxy	transparentProxy

Public Slots

Signals

Public Functions

Public Variables

Protected Slots

Protected Variables

Static Protected Variables

Additional Inherited Members

Detailed Description

Constructors and Destructors

◆ QHttpThreadDelegate()

◆ ~QHttpThreadDelegate()

Functions

◆ abortRequest

◆ authenticationRequired

◆ cacheCredentialsSlot

◆ dataReadProgressSlot

◆ downloadData

◆ downloadFinished

◆ downloadMetaData

◆ downloadProgress

◆ error

◆ finishedSlot

◆ finishedWithErrorSlot

◆ headerChangedSlot

◆ proxyAuthenticationRequired

◆ readBufferFreed

◆ readBufferSizeChanged

◆ readyReadSlot

◆ sslConfigurationChanged

◆ sslErrors

◆ sslErrorsSlot

◆ startRequest

◆ startRequestSynchronously

◆ synchronousAuthenticationRequiredSlot

◆ synchronousFinishedSlot

◆ synchronousFinishedWithErrorSlot

◆ synchronousHeaderChangedSlot

◆ synchronousProxyAuthenticationRequiredSlot

Properties

◆ authenticationManager

◆ bytesEmitted

◆ cacheKey

◆ cacheProxy

◆ connections

◆ downloadBuffer

◆ downloadBufferMaximumSize

◆ httpConnection

◆ httpReply

◆ httpRequest

◆ incomingContentLength

◆ incomingErrorCode

◆ incomingErrorDetail

◆ incomingHeaders

◆ incomingReasonPhrase

◆ incomingSslConfiguration

◆ incomingStatusCode

◆ isPipeliningUsed

◆ networkSession

◆ pendingDownloadData

◆ pendingDownloadProgress

◆ readBufferMaxSize

◆ ssl

◆ synchronous

◆ synchronousDownloadData

◆ synchronousRequestLoop

◆ transparentProxy