#include <kis_update_scheduler.h>

Inheritance diagram for KisTestableUpdateScheduler:

Public Member Functions
	KisTestableUpdateScheduler (KisProjectionUpdateListener *projectionUpdateListener, qint32 threadCount)

void	processQueues ()

KisUpdaterContext *	updaterContext ()

Public Member Functions inherited from KisUpdateScheduler
void	addJob (KisStrokeId id, KisStrokeJobData *data) override

void	addSpontaneousJob (KisSpontaneousJob *spontaneousJob)

qreal	balancingRatio () const

void	barrierLock ()

void	blockUpdates ()

bool	cancelStroke (KisStrokeId id) override

void	continueUpdate (const QRect &rect)

int	currentLevelOfDetail () const

void	doSomeUsefulWork ()

void	endStroke (KisStrokeId id) override

void	explicitRegenerateLevelOfDetail ()

void	fullRefreshAsync (KisNodeSP root, const QRect &rc, const QRect &cropRect)

void	fullRefreshAsync (KisNodeSP root, const QVector< QRect > &rects, const QRect &cropRect, KisProjectionUpdateFlags flags)

bool	hasUpdatesRunning () const

void	immediateLockForReadOnly ()

bool	isIdle ()

	KisUpdateScheduler (KisProjectionUpdateListener projectionUpdateListener, QObject parent=0)

KisPostExecutionUndoAdapter *	lodNPostExecutionUndoAdapter () const

KisLodPreferences	lodPreferences () const

	Private (KisUpdateScheduler _q, KisProjectionUpdateListener p)

void	setLod0ToNStrokeStrategyFactory (const KisLodSyncStrokeStrategyFactory &factory)

void	setLodPreferences (const KisLodPreferences &value)

void	setPostSyncLod0GUIPlaneRequestForResumeCallback (const std::function< void()> &callback)

void	setProgressProxy (KoProgressProxy *progressProxy)

void	setPurgeRedoStateCallback (const std::function< void()> &callback)

void	setSuspendResumeUpdatesStrokeStrategyFactory (const KisSuspendResumeStrategyPairFactory &factory)

void	setThreadsLimit (int value)

void	spareThreadAppeared ()

KisStrokeId	startStroke (KisStrokeStrategy *strokeStrategy) override

int	threadsLimit () const

bool	tryBarrierLock ()

bool	tryCancelCurrentStrokeAsync ()

UndoResult	tryUndoLastStrokeAsync ()

void	unblockUpdates ()

void	unlock (bool resetLodLevels=true)

void	updateProjection (KisNodeSP node, const QRect &rc, const QRect &cropRect)

void	updateProjection (KisNodeSP node, const QVector< QRect > &rects, const QRect &cropRect, KisProjectionUpdateFlags flags)

void	waitForDone ()

bool	wrapAroundModeSupported () const

	~KisUpdateScheduler () override

Public Member Functions inherited from Private
	Private (KisCanvas2 *c)

Public Member Functions inherited from KisStrokesFacade
virtual	~KisStrokesFacade ()

Additional Inherited Members
Public Attributes inherited from KisUpdateScheduler
qreal	defaultBalancingRatio = 1.0

bool	processingBlocked = false

KisQueuesProgressUpdater *	progressUpdater = 0

KisProjectionUpdateListener *	projectionUpdateListener

KisUpdateScheduler *	q

KisStrokesQueue	strokesQueue

KisUpdaterContext	updaterContext

KisLazyWaitCondition	updatesFinishedCondition

QAtomicInt	updatesLockCounter

KisSimpleUpdateQueue	updatesQueue

QReadWriteLock	updatesStartLock

Public Attributes inherited from Private
KisCanvas2 *	canvas

int	displayedFrame

int	intendedFrame

Protected Slots inherited from KisUpdateScheduler
void	updateSettings ()

Protected Member Functions inherited from KisUpdateScheduler
void	connectSignals ()

	KisUpdateScheduler ()

void	processQueues ()

Protected Attributes inherited from KisUpdateScheduler
Private *const	m_d

Detailed Description

Definition at line 252 of file kis_update_scheduler.h.

Constructor & Destructor Documentation

◆ KisTestableUpdateScheduler()

KisTestableUpdateScheduler::KisTestableUpdateScheduler	(	KisProjectionUpdateListener *	projectionUpdateListener,
		qint32	threadCount )

Definition at line 447 of file kis_update_scheduler.cpp.

{
    updateSettings();
    m_d->projectionUpdateListener = projectionUpdateListener;
 
    setThreadsLimit(threadCount);
    m_d->updaterContext.setTestingMode(true);
 
    connectSignals();
}

References KisUpdateScheduler::connectSignals(), KisUpdateScheduler::m_d, KisUpdateScheduler::projectionUpdateListener, KisUpdateScheduler::setThreadsLimit(), and KisUpdateScheduler::updateSettings().

Member Function Documentation

◆ processQueues()

void KisUpdateScheduler::processQueues ( )

Definition at line 227 of file kis_update_scheduler.cpp.

{
    wakeUpWaitingThreads();
 
    if(m_d->processingBlocked) return;
 
    if(m_d->strokesQueue.needsExclusiveAccess()) {
        DEBUG_BALANCING_METRICS("STROKES", "X");
        m_d->strokesQueue.processQueue(m_d->updaterContext,
                                        !m_d->updatesQueue.isEmpty());
 
        if(!m_d->strokesQueue.needsExclusiveAccess()) {
            tryProcessUpdatesQueue();
        }
    }
    else if(m_d->balancingRatio() * m_d->strokesQueue.sizeMetric() > m_d->updatesQueue.sizeMetric()) {
        DEBUG_BALANCING_METRICS("STROKES", "N");
        m_d->strokesQueue.processQueue(m_d->updaterContext,
                                        !m_d->updatesQueue.isEmpty());
        tryProcessUpdatesQueue();
    }
    else {
        DEBUG_BALANCING_METRICS("UPDATES", "N");
        tryProcessUpdatesQueue();
        m_d->strokesQueue.processQueue(m_d->updaterContext,
                                        !m_d->updatesQueue.isEmpty());
 
    }
 
    progressUpdate();
}

◆ updaterContext()

KisUpdaterContext * KisTestableUpdateScheduler::updaterContext ( )

Definition at line 459 of file kis_update_scheduler.cpp.

{
    return &m_d->updaterContext;
}

References KisUpdateScheduler::m_d.

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

libs/image/kis_update_scheduler.h
libs/image/kis_update_scheduler.cpp