KisTileDataSwapper Class Reference

#include <kis_tile_data_swapper.h>

Inheritance diagram for KisTileDataSwapper:

Public Member Functions
void	checkFreeMemory ()
void	kick ()
	KisTileDataSwapper (KisTileDataStore *store)
void	terminateSwapper ()
void	testingRereadConfig ()
	~KisTileDataSwapper () override
Public Member Functions inherited from Private
	Private (KisCanvas2 *c)

Public Attributes
QMutex	cycleLock
KisStoreLimits	limits
QSemaphore	semaphore
QAtomicInt	shouldExitFlag
KisTileDataStore *	store
Public Attributes inherited from Private
KisCanvas2 *	canvas
int	displayedFrame
int	intendedFrame

Private Member Functions
void	doJob ()
template<class strategy >
qint64	pass (qint64 needToFreeMetric)
void	run () override
void	waitForWork ()

Private Attributes
Private *const	m_d

Static Private Attributes
static const qint32	DELAY = 0.7 * SEC
static const qint32	TIMEOUT = -1

Detailed Description

Definition at line 36 of file kis_tile_data_swapper.cpp.

Constructor & Destructor Documentation

KisTileDataSwapper()

KisTileDataSwapper::KisTileDataSwapper

(

KisTileDataStore *

store

)

Definition at line 46 of file kis_tile_data_swapper.cpp.

    : QThread(),
      m_d(new Private())
{
    m_d->shouldExitFlag = 0;
    m_d->store = store;
}

References m_d, and store.

~KisTileDataSwapper()

KisTileDataSwapper::~KisTileDataSwapper ( )

override

Definition at line 54 of file kis_tile_data_swapper.cpp.

{
    delete m_d;
}

References m_d.

Member Function Documentation

checkFreeMemory()

void KisTileDataSwapper::checkFreeMemory

(

)

Definition at line 92 of file kis_tile_data_swapper.cpp.

{
//    dbgKrita <<"check memory: high limit -" << m_d->limits.emergencyThreshold() <<"in mem -" << m_d->store->numTilesInMemory();
    if(m_d->store->memoryMetric() > m_d->limits.emergencyThreshold())
        doJob();
}

References doJob(), and m_d.

doJob()

void KisTileDataSwapper::doJob ( )

private

In emergency case usual threads have access to this function as well

Definition at line 99 of file kis_tile_data_swapper.cpp.

{
    QMutexLocker locker(&m_d->cycleLock);
 
    qint32 memoryMetric = m_d->store->memoryMetric();
 
    DEBUG_ACTION("Started swap cycle");
    DEBUG_VALUE(m_d->store->numTiles());
    DEBUG_VALUE(m_d->store->numTilesInMemory());
    DEBUG_VALUE(memoryMetric);
 
    DEBUG_VALUE(m_d->limits.softLimitThreshold());
    DEBUG_VALUE(m_d->limits.hardLimitThreshold());
 
 
    if(memoryMetric > m_d->limits.softLimitThreshold()) {
        qint32 softFree =  memoryMetric - m_d->limits.softLimit();
        DEBUG_VALUE(softFree);
        DEBUG_ACTION("\t pass0");
        memoryMetric -= pass<SoftSwapStrategy>(softFree);
        DEBUG_VALUE(memoryMetric);
 
        if(memoryMetric > m_d->limits.hardLimitThreshold()) {
            qint32 hardFree =  memoryMetric - m_d->limits.hardLimit();
            DEBUG_VALUE(hardFree);
            DEBUG_ACTION("\t pass1");
            memoryMetric -= pass<AggressiveSwapStrategy>(hardFree);
            DEBUG_VALUE(memoryMetric);
        }
    }
}

References DEBUG_ACTION, DEBUG_VALUE, and m_d.

kick()

void KisTileDataSwapper::kick

(

)

Definition at line 59 of file kis_tile_data_swapper.cpp.

{
    m_d->semaphore.release();
}

References m_d.

pass()

template<class strategy >

qint64 KisTileDataSwapper::pass ( qint64 needToFreeMetric )

private

Definition at line 185 of file kis_tile_data_swapper.cpp.

{
    qint64 freedMetric = 0;
    QList<KisTileData*> additionalCandidates;
 
    typename strategy::iterator *iter =
        strategy::beginIteration(m_d->store);
 
    KisTileData *item = 0;
 
    while (iter->hasNext()) {
        item = iter->next();
 
        if (freedMetric >= needToFreeMetric) break;
 
        if (!strategy::isInteresting(item)) continue;
 
        if (strategy::swapOutFirst(item)) {
            if (iter->trySwapOut(item)) {
                freedMetric += item->pixelSize();
            }
        }
        else {
            item->markOld();
            additionalCandidates.append(item);
        }
 
    }
 
    Q_FOREACH (item, additionalCandidates) {
        if (freedMetric >= needToFreeMetric) break;
 
        if (iter->trySwapOut(item)) {
            freedMetric += item->pixelSize();
        }
    }
 
    strategy::endIteration(m_d->store, iter);
 
    return freedMetric;
}

References m_d, KisTileData::markOld(), and KisTileData::pixelSize().

run()

void KisTileDataSwapper::run ( )

overrideprivate

Definition at line 78 of file kis_tile_data_swapper.cpp.

{
    while (1) {
        waitForWork();
 
        if (m_d->shouldExitFlag)
            return;
 
        QThread::msleep(DELAY);
 
        doJob();
    }
}

References DELAY, doJob(), m_d, and waitForWork().

terminateSwapper()

void KisTileDataSwapper::terminateSwapper

(

)

Definition at line 64 of file kis_tile_data_swapper.cpp.

{
    unsigned long exitTimeout = 100;
    do {
        m_d->shouldExitFlag = true;
        kick();
    } while(!wait(exitTimeout));
}

References kick(), and m_d.

testingRereadConfig()

void KisTileDataSwapper::testingRereadConfig

(

)

Definition at line 227 of file kis_tile_data_swapper.cpp.

{
    m_d->limits = KisStoreLimits();
}

References m_d.

waitForWork()

void KisTileDataSwapper::waitForWork ( )

private

Definition at line 73 of file kis_tile_data_swapper.cpp.

{
    m_d->semaphore.tryAcquire(1, TIMEOUT);
}

References m_d, and TIMEOUT.

Member Data Documentation

cycleLock

QMutex KisTileDataSwapper::cycleLock

Definition at line 43 of file kis_tile_data_swapper.cpp.

DELAY

const qint32 KisTileDataSwapper::DELAY = 0.7 * SEC

staticprivate

Definition at line 42 of file kis_tile_data_swapper.h.

limits

KisStoreLimits KisTileDataSwapper::limits

Definition at line 42 of file kis_tile_data_swapper.cpp.

m_d

Private* const KisTileDataSwapper::m_d

private

Definition at line 46 of file kis_tile_data_swapper.h.

semaphore

QSemaphore KisTileDataSwapper::semaphore

Definition at line 39 of file kis_tile_data_swapper.cpp.

shouldExitFlag

QAtomicInt KisTileDataSwapper::shouldExitFlag

Definition at line 40 of file kis_tile_data_swapper.cpp.

store

KisTileDataStore* KisTileDataSwapper::store

Definition at line 41 of file kis_tile_data_swapper.cpp.

TIMEOUT

const qint32 KisTileDataSwapper::TIMEOUT = -1

staticprivate

Definition at line 41 of file kis_tile_data_swapper.h.

---

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

• libs/image/tiles3/swap/kis_tile_data_swapper.cpp
• libs/image/tiles3/swap/kis_tile_data_swapper.h