QWaitConditionPrivate Class Reference

Public Member Functions
void	wait ()
QWaitConditionEvent *	pre ()
void	wait (QWaitConditionEvent *wce)
void	post (QWaitConditionEvent *wce)

Public Attributes
pthread_mutex_t	mutex
pthread_cond_t	cond
int	waiters
int	wakeups
QMutex	mtx
EventQueue	queue
EventQueue	freeQueue

Detailed Description

Definition at line 54 of file qwaitcondition_unix.cpp.

Member Function Documentation

void QWaitConditionPrivate::post

(

QWaitConditionEvent *

wce

)

Definition at line 110 of file qwaitcondition_win32.cpp.

{
    mtx.lock();

    // remove 'wce' from the queue
    int idx = queue.find(wce);
    ASSERT(idx!=-1);
    queue.take(idx);
    ResetEvent(wce->event);
    freeQueue.append(wce);

    // wakeups delivered after the timeout should be forwarded to the next waiter
    if (wce->wokenUp && !queue.isEmpty())
    {
        QWaitConditionEvent *other = queue.getFirst();
        SetEvent(other->event);
        other->wokenUp = TRUE;
    }

    mtx.unlock();
}

QWaitConditionEvent * QWaitConditionPrivate::pre

(

)

Definition at line 83 of file qwaitcondition_win32.cpp.

{
    mtx.lock();
    QWaitConditionEvent *wce =
        freeQueue.isEmpty() ? new QWaitConditionEvent : freeQueue.take(0);
    wce->priority = GetThreadPriority(GetCurrentThread());
    wce->wokenUp = FALSE;

    // insert 'wce' into the queue (sorted by priority)
    uint index = 0;
    for (; index < queue.count(); ++index)
    {
        QWaitConditionEvent *current = queue.at(index);
        if (current->priority < wce->priority)
            break;
    }
    queue.insert(index, wce);
    mtx.unlock();

    return wce;
}

void QWaitConditionPrivate::wait ( )

inline

Definition at line 62 of file qwaitcondition_unix.cpp.

    {
        int code;
        for (;;)
        {
            code = pthread_cond_wait(&cond, &mutex);
            if (code == 0 && wakeups == 0) 
            {
                // many vendors warn of spurios wakeups from
                // pthread_cond_wait(), especially after signal delivery,
                // even though POSIX doesn't allow for it... sigh
                continue;
            }
            break;
        }

        --waiters;
        if (code == 0)
        {
            --wakeups;
        }
        else
        {
            report_error(code, "QWaitCondition::wait()", "cv wait");
        }
        report_error(pthread_mutex_unlock(&mutex), "QWaitCondition::wait()", "mutex unlock");
    }

void QWaitConditionPrivate::wait

(

QWaitConditionEvent *

wce

)

Definition at line 105 of file qwaitcondition_win32.cpp.

{
    WaitForSingleObject(wce->event, INFINITE);
}

Member Data Documentation

pthread_cond_t QWaitConditionPrivate::cond

Definition at line 58 of file qwaitcondition_unix.cpp.

EventQueue QWaitConditionPrivate::freeQueue

Definition at line 76 of file qwaitcondition_win32.cpp.

QMutex QWaitConditionPrivate::mtx

Definition at line 74 of file qwaitcondition_win32.cpp.

pthread_mutex_t QWaitConditionPrivate::mutex

Definition at line 57 of file qwaitcondition_unix.cpp.

EventQueue QWaitConditionPrivate::queue

Definition at line 75 of file qwaitcondition_win32.cpp.

int QWaitConditionPrivate::waiters

Definition at line 59 of file qwaitcondition_unix.cpp.

int QWaitConditionPrivate::wakeups

Definition at line 60 of file qwaitcondition_unix.cpp.

---

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

• doxygen-1.8.11/qtools/qwaitcondition_unix.cpp
• doxygen-1.8.11/qtools/qwaitcondition_win32.cpp