/***************************************************************************                          thread.cpp  -  description                             -------------------    begin                : Fri Jul 20 2001    copyright            : (C) 2001 by Mark    email                : alben@yeah.net ***************************************************************************//*************************************************************************** *                                                                         * *   This program is free software; you can redistribute it and/or modify  * *   it under the terms of the GNU General Public License as published by  * *   the Free Software Foundation; either version 2 of the License, or     * *   (at your option) any later version.                                   * *                                                                         * ***************************************************************************/#include <errno.h>#include "thread.h"CThMutex::CThMutex(){	pthread_mutex_init(&m_tMutex, NULL);}CThMutex::~CThMutex(){	int iResult = pthread_mutex_destroy(&m_tMutex);	if (iResult)		throw CThreadException(strerror(iResult), __FILE__, __LINE__);}bool CThMutex::Lock(){	int iResult = pthread_mutex_lock(&m_tMutex);	if (iResult)		throw CThreadException(strerror(iResult), __FILE__, __LINE__);		return true;}bool CThMutex::TryLock(){	int iResult = pthread_mutex_trylock(&m_tMutex);	if (iResult)	{		if (iResult == EBUSY)			return false;							throw CThreadException(strerror(iResult), __FILE__, __LINE__);	}					return true;}bool CThMutex::Unlock(){	int iResult = pthread_mutex_unlock(&m_tMutex);	if (iResult)		throw CThreadException(strerror(iResult), __FILE__, __LINE__);					return true;}CThSem::CThSem(int iValue){	if (sem_init(&m_tSem, 0, iValue) < 0)		throw CThreadException(strerror(errno), __FILE__, __LINE__);}CThSem::~CThSem(){	if (sem_destroy(&m_tSem) < 0)		throw CThreadException(strerror(errno), __FILE__, __LINE__);			}	bool CThSem::Wait(){	sem_wait(&m_tSem);	return true;}bool CThSem::TryWait(){	if (sem_trywait(&m_tSem) < 0)	{		if (errno == EAGAIN)			return false;					throw CThreadException(strerror(errno), __FILE__, __LINE__);	}		return true;}bool CThSem::Post(){	if (sem_post(&m_tSem) < 0)		throw CThreadException(strerror(errno), __FILE__, __LINE__);		return true;}		int CThSem::GetValue(){	int iValue;	sem_getvalue(&m_tSem, &iValue);	return iValue;}		CThCond::CThCond(){	pthread_cond_init(&m_tCond, NULL);}CThCond::~CThCond(){	int iResult = pthread_cond_destroy(&m_tCond);	if (iResult)		throw CThreadException(strerror(iResult), __FILE__, __LINE__);}	bool CThCond::Signal(){	pthread_cond_signal(&m_tCond);	return true;}bool CThCond::Broadcast(){	pthread_cond_broadcast(&m_tCond);	return true;}bool CThCond::Wait(CThMutex& stThMutex){	pthread_cond_wait(&m_tCond, &stThMutex.m_tMutex);	return true;}bool CThCond::TimedWait(CThMutex& stThMutex, const struct timespec* pstAbsTime){	int iResult = pthread_cond_timedwait(&m_tCond, &stThMutex.m_tMutex, pstAbsTime);	if (iResult)	{		if (iResult == ETIMEDOUT || iResult == EINTR)			return false;					throw CThreadException(strerror(iResult), __FILE__, __LINE__);	}		return true;}CThRWLock::CThRWLock(bool bWriterFirst, int iMaxReader)		: m_bWriterFirst(bWriterFirst), m_iMaxReader(iMaxReader){	m_iWaitingReader = 0;	m_iWaitingWriter = 0;	m_iHoldingLock = 0;}CThRWLock::~CThRWLock(){	if (m_iWaitingReader != 0 || m_iWaitingWriter != 0 || m_iHoldingLock != 0)		throw CThreadException("RWLock is busy.", __FILE__, __LINE__);}	bool CThRWLock::ReadLock(){	m_stMutex.Lock();	while ( (m_iHoldingLock < 0) || (m_iMaxReader > 0 && m_iHoldingLock == m_iMaxReader)			|| (m_bWriterFirst && m_iWaitingWriter > 0) )	{		m_iWaitingReader++;		m_stReaderCond.Wait(m_stMutex);		m_iWaitingReader--;	}		m_iHoldingLock++;	m_stMutex.Unlock();	return true;}bool CThRWLock::WriteLock(){	m_stMutex.Lock();	while (m_iHoldingLock != 0)	{		m_iWaitingWriter++;		m_stWriterCond.Wait(m_stMutex);		m_iWaitingWriter--;	}		m_iHoldingLock = -1;	m_stMutex.Unlock();	return true;}bool CThRWLock::Unlock(){	m_stMutex.Lock();	if (m_iHoldingLock == -1)		m_iHoldingLock = 0;	else if (m_iHoldingLock > 0)		m_iHoldingLock--;	else		throw CThreadException("unknown lock status while unlocking.", __FILE__, __LINE__);			if (m_bWriterFirst)	{		if (m_iWaitingWriter > 0)		{			if (m_iHoldingLock == 0)				m_stWriterCond.Signal();		}		else if (m_iWaitingReader > 0)		{			m_stReaderCond.Broadcast();		}	}	else	{		if (m_iWaitingWriter > 0 && m_iHoldingLock == 0)			m_stWriterCond.Signal();		else if (m_iWaitingReader > 0)			m_stReaderCond.Broadcast();	}		m_stMutex.Unlock();	return true;}typedef void* (*tc_thread_func)(void*);void* ThreadRun(CThread* pstThread){	try	{		pstThread->Run();	}	catch (CException& e)	{		pstThread->OnException(e);	}	pstThread->m_bStart = false;	pstThread->OnEnd();	return NULL;}CThread::CThread(bool bDetach){	m_bDetach = bDetach;	m_bStart = false;		pthread_attr_init(&m_tThreadAttr);	if (m_bDetach)		pthread_attr_setdetachstate(&m_tThreadAttr, PTHREAD_CREATE_DETACHED);	else		pthread_attr_setdetachstate(&m_tThreadAttr, PTHREAD_CREATE_JOINABLE);}CThread::~CThread(){	pthread_attr_destroy(&m_tThreadAttr);	OnDelete();}	void CThread::Start(){	if (m_bStart)		return;			int iResult = pthread_create(&m_tThread, &m_tThreadAttr, (tc_thread_func)ThreadRun, this);	if (iResult)		throw CThreadException(strerror(iResult), __FILE__, __LINE__);		m_bStart = true;}void CThread::OnDelete(){	int iResult;		if (m_bStart && pthread_self() != m_tThread)	//end by another thread	{		iResult = pthread_cancel(m_tThread);		if (iResult)			throw CThreadException(strerror(iResult), __FILE__, __LINE__);				if (!m_bDetach)		{			iResult = pthread_join(m_tThread, NULL);			if (iResult)				throw CThreadException(strerror(iResult), __FILE__, __LINE__);		}	}}