142 lines
3.5 KiB
C++
142 lines
3.5 KiB
C++
#include "stdafx.h"
|
|
#include "Thread.h"
|
|
#ifndef _WIN32
|
|
#include <unistd.h>
|
|
#include <pthread.h>
|
|
#include <sys/syscall.h>
|
|
#endif
|
|
|
|
CThread::CThread(CTHREAD_START_ROUTINE lpStartAddress) :
|
|
m_StartAddress(lpStartAddress),
|
|
m_lpThreadParameter(NULL),
|
|
m_thread(NULL),
|
|
#ifndef _WIN32
|
|
m_running(false),
|
|
#endif
|
|
m_threadID(0)
|
|
{
|
|
WriteTrace(TraceThread, TraceDebug, "Start");
|
|
WriteTrace(TraceThread, TraceDebug, "Done");
|
|
}
|
|
|
|
CThread::~CThread()
|
|
{
|
|
WriteTrace(TraceThread, TraceDebug, "Start");
|
|
if (CThread::GetCurrentThreadId() == m_threadID)
|
|
{
|
|
WriteTrace(TraceThread, TraceError, "Deleting from thread!!!");
|
|
}
|
|
if (CThread::GetCurrentThreadId() != m_threadID && isRunning())
|
|
{
|
|
Terminate();
|
|
}
|
|
#ifdef _WIN32
|
|
CloseHandle(m_thread);
|
|
#endif
|
|
WriteTrace(TraceThread, TraceDebug, "Done");
|
|
}
|
|
|
|
bool CThread::Start(void * lpThreadParameter)
|
|
{
|
|
WriteTrace(TraceThread, TraceDebug, "Start");
|
|
m_lpThreadParameter = lpThreadParameter;
|
|
#ifdef _WIN32
|
|
m_thread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadWrapper, this, 0, (LPDWORD)&m_threadID);
|
|
#else
|
|
pthread_t * thread_id = new pthread_t;
|
|
|
|
m_thread = (void*)thread_id;
|
|
|
|
int res = pthread_create(thread_id, NULL, (void *(*)(void *))ThreadWrapper, this);
|
|
#endif
|
|
WriteTrace(TraceThread, TraceDebug, "Done");
|
|
return true;
|
|
}
|
|
|
|
void * CThread::ThreadWrapper (CThread * _this)
|
|
{
|
|
WriteTrace(TraceThread, TraceDebug, "Start");
|
|
_this->m_threadID = CThread::GetCurrentThreadId();
|
|
#ifndef _WIN32
|
|
_this->m_running = true;
|
|
WriteTrace(TraceThread, TraceDebug, "Thread is running");
|
|
#endif
|
|
void * res = NULL;
|
|
try
|
|
{
|
|
res = (void *)_this->m_StartAddress(_this->m_lpThreadParameter);
|
|
}
|
|
catch (...)
|
|
{
|
|
//WriteTrace(TraceUserInterface, TraceError, "Unhandled Exception ");
|
|
}
|
|
#ifndef _WIN32
|
|
_this->m_running = false;
|
|
WriteTrace(TraceThread, TraceDebug, "Thread is finished");
|
|
#endif
|
|
#ifdef _WIN32
|
|
CloseHandle(_this->m_thread);
|
|
#else
|
|
pthread_t * thread_id = (pthread_t *)_this->m_thread;
|
|
delete thread_id;
|
|
#endif
|
|
_this->m_thread = NULL;
|
|
WriteTrace(TraceThread, TraceDebug, "Done");
|
|
return res;
|
|
}
|
|
|
|
bool CThread::isRunning(void) const
|
|
{
|
|
WriteTrace(TraceThread, TraceDebug, "Start");
|
|
if (m_thread == NULL)
|
|
{
|
|
WriteTrace(TraceThread, TraceDebug, "Done (res: false), m_thread is null");
|
|
return false;
|
|
}
|
|
#ifndef _WIN32
|
|
WriteTrace(TraceThread, TraceDebug, "Done (res: %s)", m_running ? "true" : "false");
|
|
return m_running;
|
|
#endif
|
|
#ifdef _WIN32
|
|
DWORD ExitCode;
|
|
if (GetExitCodeThread(m_thread, &ExitCode))
|
|
{
|
|
if (ExitCode == STILL_ACTIVE)
|
|
{
|
|
WriteTrace(TraceThread, TraceDebug, "Done (res: true)");
|
|
return true;
|
|
}
|
|
}
|
|
WriteTrace(TraceThread, TraceDebug, "Done (res: false)");
|
|
return false;
|
|
#else
|
|
return true;
|
|
#endif
|
|
}
|
|
|
|
void CThread::Terminate(void)
|
|
{
|
|
WriteTrace(TraceThread, TraceDebug, "Start");
|
|
if (isRunning())
|
|
{
|
|
#ifdef _WIN32
|
|
WriteTrace(TraceThread, TraceDebug, "Terminating thread");
|
|
TerminateThread(m_thread, 0);
|
|
#else
|
|
WriteTrace(TraceThread, TraceError, "Need to fix");
|
|
#endif
|
|
}
|
|
WriteTrace(TraceThread, TraceDebug, "Done");
|
|
}
|
|
|
|
uint32_t CThread::GetCurrentThreadId(void)
|
|
{
|
|
#ifdef _WIN32
|
|
return ::GetCurrentThreadId();
|
|
#elif defined(SYS_gettid) || defined(__NR_gettid)
|
|
return syscall(__NR_gettid); /* GLIBC has no implementation of gettid(). */
|
|
#else
|
|
return gettid();
|
|
#endif
|
|
}
|