#include <stdio.h>
#include <unistd.h>
-#include <sched.h>
#include <pthread.h>
+#include <errno.h>
+#include "wx/thread.h"
+#include "wx/module.h"
+#include "wx/utils.h"
enum thread_state {
STATE_IDLE = 0,
// Static variables
/////////////////////////////////////////////////////////////////////////////
-#include "thread.h"
-
static pthread_t p_mainid;
wxMutex wxMainMutex; // controls access to all GUI functions
pthread_mutex_t p_mutex;
};
-wxMutex::wxMutex(void)
+wxMutex::wxMutex()
{
p_internal = new wxMutexInternal;
pthread_mutex_init(&(p_internal->p_mutex), NULL);
- m_locked = false;
+ m_locked = 0;
}
-wxMutex::~wxMutex(void)
+wxMutex::~wxMutex()
{
- if (m_locked)
- pthread_mutex_unlock(&(p_internal->p_mutex));
+ if (m_locked > 0)
+ wxDebugMsg("wxMutex warning: freeing a locked mutex (%d locks)\n",
+ m_locked);
+
pthread_mutex_destroy(&(p_internal->p_mutex));
delete p_internal;
}
-wxMutexError wxMutex::Lock(void)
+wxMutexError wxMutex::Lock()
{
int err;
err = pthread_mutex_lock(&(p_internal->p_mutex));
- switch (err) {
- case EDEADLK: return MUTEX_DEAD_LOCK;
- }
+ if (err == EDEADLK)
+ return MUTEX_DEAD_LOCK;
m_locked++;
return MUTEX_NO_ERROR;
}
-wxMutexError wxMutex::TryLock(void)
+wxMutexError wxMutex::TryLock()
{
int err;
return MUTEX_NO_ERROR;
}
-wxMutexError wxMutex::Unlock(void)
+wxMutexError wxMutex::Unlock()
{
- if (m_locked > 0) m_locked--;
+ if (m_locked > 0)
+ m_locked--;
+ else
+ return MUTEX_UNLOCKED;
pthread_mutex_unlock(&(p_internal->p_mutex));
return MUTEX_NO_ERROR;
}
pthread_cond_t p_condition;
};
-wxCondition::wxCondition(void)
+wxCondition::wxCondition()
{
p_internal = new wxConditionInternal;
pthread_cond_init(&(p_internal->p_condition), NULL);
}
-wxCondition::~wxCondition(void)
+wxCondition::~wxCondition()
{
pthread_cond_destroy(&(p_internal->p_condition));
delete p_internal;
return (pthread_cond_timedwait(&(p_internal->p_condition), &(mutex.p_internal->p_mutex), &tspec) != ETIMEDOUT);
}
-void wxCondition::Signal(void)
+void wxCondition::Signal()
{
pthread_cond_signal(&(p_internal->p_condition));
}
-void wxCondition::Broadcast(void)
+void wxCondition::Broadcast()
{
pthread_cond_broadcast(&(p_internal->p_condition));
}
p_internal->prio = prio;
}
-int wxThread::GetPriority(void)
+int wxThread::GetPriority() const
{
return p_internal->prio;
}
pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
}
-wxThreadError wxThread::Destroy(void)
+wxThreadError wxThread::Destroy()
{
int res = 0;
return status;
}
-unsigned long wxThread::GetID()
+unsigned long wxThread::GetID() const
{
return (unsigned long)p_internal->thread_id;
}
pthread_testcancel();
}
-bool wxThread::IsMain(void)
+bool wxThread::IsMain()
{
return (bool)pthread_equal(pthread_self(), p_mainid);
}
class wxThreadModule : public wxModule {
DECLARE_DYNAMIC_CLASS(wxThreadModule)
public:
- virtual bool OnInit(void) {
+ virtual bool OnInit() {
wxThreadGuiInit();
p_mainid = pthread_self();
wxMainMutex.Lock();
return TRUE;
}
- virtual void OnExit(void) {
+ virtual void OnExit() {
wxMainMutex.Unlock();
wxThreadGuiExit();
}