QSBR Class Reference

#include <qsbr.h>

Classes
struct	Action

Public Member Functions
template<class T >
void	enqueue (void(T::*pmf)(), T *target, bool migration=false)
void	flush ()
void	lockRawPointerAccess ()
bool	sanityRawPointerAccessLocked () const
void	unlockRawPointerAccess ()
void	update ()

Private Member Functions
void	releasePoolSafely (KisLocklessStack< Action > *pool, bool force=false)

Private Attributes
KisLocklessStack< Action >	m_migrationReclaimActions
KisLocklessStack< Action >	m_pendingActions
QAtomicInt	m_rawPointerUsers

Detailed Description

Definition at line 18 of file qsbr.h.

Member Function Documentation

enqueue()

template<class T >

void QSBR::enqueue ( void(T::*)() pmf, T * target, bool migration = false )

inline

Definition at line 71 of file qsbr.h.

    {
        struct Closure {
            void (T::*pmf)();
            T* target;
 
            static void thunk(void* param)
            {
                Closure* self = (Closure*) param;
                CALL_MEMBER(*self->target, self->pmf)();
            }
        };
 
        Closure closure = {pmf, target};
 
        if (migration) {
            m_migrationReclaimActions.push(Action(Closure::thunk, &closure, sizeof(closure)));
        } else {
            m_pendingActions.push(Action(Closure::thunk, &closure, sizeof(closure)));
        }
    }

References CALL_MEMBER, m_migrationReclaimActions, m_pendingActions, target(), and void().

flush()

void QSBR::flush ( )

inline

Definition at line 99 of file qsbr.h.

    {
        releasePoolSafely(&m_pendingActions, true);
        releasePoolSafely(&m_migrationReclaimActions, true);
    }

References m_migrationReclaimActions, m_pendingActions, and releasePoolSafely().

lockRawPointerAccess()

void QSBR::lockRawPointerAccess ( )

inline

Definition at line 105 of file qsbr.h.

    {
        m_rawPointerUsers.ref();
    }

References m_rawPointerUsers.

releasePoolSafely()

void QSBR::releasePoolSafely ( KisLocklessStack< Action > * pool, bool force = false )

inlineprivate

Definition at line 43 of file qsbr.h.

                                                                               {
        KisLocklessStack<Action> tmp;
        tmp.mergeFrom(*pool);
        if (tmp.isEmpty()) return;
 
        if (force || tmp.size() > 4096) {
            while (m_rawPointerUsers.loadAcquire());
 
            Action action;
            while (tmp.pop(action)) {
                action();
            }
        } else {
            if (!m_rawPointerUsers.loadAcquire()) {
                Action action;
                while (tmp.pop(action)) {
                    action();
                }
            } else {
                // push elements back to the source
                pool->mergeFrom(tmp);
            }
        }
    }

References m_rawPointerUsers, and KisLocklessStack< T >::mergeFrom().

sanityRawPointerAccessLocked()

bool QSBR::sanityRawPointerAccessLocked ( ) const

inline

Definition at line 115 of file qsbr.h.

                                              {
        return m_rawPointerUsers.loadAcquire();
    }

References m_rawPointerUsers.

unlockRawPointerAccess()

void QSBR::unlockRawPointerAccess ( )

inline

Definition at line 110 of file qsbr.h.

    {
        m_rawPointerUsers.deref();
    }

References m_rawPointerUsers.

update()

void QSBR::update ( )

inline

Definition at line 93 of file qsbr.h.

    {
        releasePoolSafely(&m_pendingActions);
        releasePoolSafely(&m_migrationReclaimActions);
    }

References m_migrationReclaimActions, m_pendingActions, and releasePoolSafely().

Member Data Documentation

m_migrationReclaimActions

KisLocklessStack<Action> QSBR::m_migrationReclaimActions

private

Definition at line 41 of file qsbr.h.

m_pendingActions

KisLocklessStack<Action> QSBR::m_pendingActions

private

Definition at line 40 of file qsbr.h.

m_rawPointerUsers

QAtomicInt QSBR::m_rawPointerUsers

private

Definition at line 39 of file qsbr.h.

---

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

• libs/image/3rdparty/lock_free_map/qsbr.h