#include <qfuturewatcher_p.h>

Inheritance diagram for QFutureWatcherBasePrivate:

Public Functions
void	callOutInterfaceDisconnected ()

void	postCallOutEvent (const QFutureCallOutEvent &callOutEvent)

	QFutureWatcherBasePrivate ()

void	sendCallOutEvent (QFutureCallOutEvent *event)

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 Functions inherited from QFutureCallOutInterface
virtual	~QFutureCallOutInterface ()

Public Variables
bool	finished

int	maximumPendingResultsReady

QList< QFutureCallOutEvent * >	pendingCallOutEvents

QAtomicInt	pendingResultsReady

QAtomicInt	resultAtConnected

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 66 of file qfuturewatcher_p.h.

Constructors and Destructors

◆ QFutureWatcherBasePrivate()

QFutureWatcherBasePrivate::QFutureWatcherBasePrivate ( )

Warning: This function is not part of the public interface.

Definition at line 437 of file qfuturewatcher.cpp.

     : maximumPendingResultsReady(QThread::idealThreadCount() * 2),
       resultAtConnected(0)
 { }

Functions

◆ callOutInterfaceDisconnected()

void QFutureWatcherBasePrivate::callOutInterfaceDisconnected ( )

virtual

Implements QFutureCallOutInterface.

Definition at line 478 of file qfuturewatcher.cpp.

 {
     QCoreApplication::removePostedEvents(q_func(), QEvent::FutureCallOut);
 }

◆ postCallOutEvent()

void QFutureWatcherBasePrivate::postCallOutEvent ( const QFutureCallOutEvent & callOutEvent )

virtual

Implements QFutureCallOutInterface.

Definition at line 466 of file qfuturewatcher.cpp.

 {
     Q_Q(QFutureWatcherBase);
 
     if (callOutEvent.callOutType == QFutureCallOutEvent::ResultsReady) {
         if (pendingResultsReady.fetchAndAddRelaxed(1) >= maximumPendingResultsReady)
             q->futureInterface().d->internal_setThrottled(true);
     }
 
     QCoreApplication::postEvent(q, callOutEvent.clone());
 }

◆ sendCallOutEvent()

void QFutureWatcherBasePrivate::sendCallOutEvent ( QFutureCallOutEvent * event )

Definition at line 483 of file qfuturewatcher.cpp.

 {
     Q_Q(QFutureWatcherBase);
 
     switch (event->callOutType) {
         case QFutureCallOutEvent::Started:
             emit q->started();
         break;
         case QFutureCallOutEvent::Finished:
             finished = true;
             emit q->finished();
         break;
         case QFutureCallOutEvent::Canceled:
             pendingResultsReady = 0;
             emit q->canceled();
         break;
         case QFutureCallOutEvent::Paused:
             if (q->futureInterface().isCanceled())
                 break;
             emit q->paused();
         break;
         case QFutureCallOutEvent::Resumed:
             if (q->futureInterface().isCanceled())
                 break;
             emit q->resumed();
         break;
         case QFutureCallOutEvent::ResultsReady: {
             if (q->futureInterface().isCanceled())
                 break;
 
             if (pendingResultsReady.fetchAndAddRelaxed(-1) <= maximumPendingResultsReady)
                 q->futureInterface().setThrottled(false);
 
             const int beginIndex = event->index1;
             const int endIndex = event->index2;
 
             emit q->resultsReadyAt(beginIndex, endIndex);
 
             if (int(resultAtConnected) <= 0)
                 break;
 
             for (int i = beginIndex; i < endIndex; ++i)
                 emit q->resultReadyAt(i);
 
         } break;
         case QFutureCallOutEvent::Progress:
             if (q->futureInterface().isCanceled())
                 break;
 
             emit q->progressValueChanged(event->index1);
             if (!event->text.isNull()) // ###
                 q->progressTextChanged(event->text);
         break;
         case QFutureCallOutEvent::ProgressRange:
             emit q->progressRangeChanged(event->index1, event->index2);
         break;
         default: break;
     }
 }

Properties

◆ finished

bool QFutureWatcherBasePrivate::finished

Definition at line 84 of file qfuturewatcher_p.h.

Referenced by sendCallOutEvent().

◆ maximumPendingResultsReady

int QFutureWatcherBasePrivate::maximumPendingResultsReady

Definition at line 81 of file qfuturewatcher_p.h.

Referenced by postCallOutEvent(), and sendCallOutEvent().

◆ pendingCallOutEvents

QList<QFutureCallOutEvent *> QFutureWatcherBasePrivate::pendingCallOutEvents

Definition at line 79 of file qfuturewatcher_p.h.

◆ pendingResultsReady

QAtomicInt QFutureWatcherBasePrivate::pendingResultsReady

Definition at line 80 of file qfuturewatcher_p.h.

Referenced by postCallOutEvent(), and sendCallOutEvent().

◆ resultAtConnected

QAtomicInt QFutureWatcherBasePrivate::resultAtConnected

Definition at line 83 of file qfuturewatcher_p.h.