blob: 5d38fcfe4af0d45918a9476137b86c9f7ad59537 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
/*******************************************************************************
*
* File name: CThreadWrapper.cpp
* Language: Visual C++
* Description: CThreadWrapper class definitions
* The class implements OS independent thread wrapper.
* The class contains methods for suspending resuming and waiting for threads.
* The implementations of the methods is linux dependent,
* but the interface of the functions is same as the appropriate
* WIN32 implementation.
*
*
* Copyright (C) ST-Ericsson SA 2011
* License terms: 3-clause BSD license
*
*******************************************************************************/
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//
#include <string>
#include <signal.h>
#include "Types.h"
#include "CThreadWrapper.h"
#include "CCriticalSection.h"
// ******************************************************************************
// Name: CThreadWrapper()
// Desc: CEventObject constructor which initializes the class members
// Ret:
// ******************************************************************************
CThreadWrapper::CThreadWrapper(void *(*pStartAddress)(void *), void *pArgument)
{
m_pStartAddress = pStartAddress;
m_pArgument = pArgument;
m_tid = (pthread_t)0;
m_ThreadEndedEvt = new CEventObject();
}
// ******************************************************************************
// Name: ~CThreadWrapper()
// Desc: CEventObject destructor
// Ret:
// ******************************************************************************
CThreadWrapper::~CThreadWrapper()
{
delete m_ThreadEndedEvt;
}
// ******************************************************************************
// Name: Wait()
// Desc: Waits for the thread to finish its job
// Ret: WAIT_OBJECT_0 on success and EAIT_TIMEOUT otherwise
// ******************************************************************************
DWORD CThreadWrapper::Wait(DWORD dwMilliseconds)
{
if (m_tid != 0) {
return m_ThreadEndedEvt->Wait(dwMilliseconds);
} else {
return WAIT_OBJECT_0;
}
}
// ******************************************************************************
// Name: ResumeThread()
// Desc: Resumes the thread. Should be called after the thread is created
// Ret:
// ******************************************************************************
void CThreadWrapper::ResumeThread()
{
pthread_create(&m_tid, NULL, CThreadWrapper::ThreadFunc, this);
}
// ******************************************************************************
// Name: ResumeThread()
// Desc: Suspends the running thread.
// Ret:
// ******************************************************************************
void CThreadWrapper::SuspendThread()
{
// this will stop all active threads
pthread_kill(m_tid, SIGSTOP);
}
// ******************************************************************************
// Name: WaitToDie()
// Desc: Waits 1000ms for thread to die
// Ret:
// ******************************************************************************
void CThreadWrapper::WaitToDie(DWORD dwMilliseconds)
{
CThreadWrapper::Wait(dwMilliseconds);
}
// ******************************************************************************
// Name: ThreadFunc()
// Desc: Sets event when the thread finishes its job
// Ret:
// ******************************************************************************
void *CThreadWrapper::ThreadFunc(void *arg)
{
CThreadWrapper *pthis = (CThreadWrapper *)arg;
pthis->m_pStartAddress(pthis->m_pArgument);
// Thread has finished, set appropriate event here
pthis->m_ThreadEndedEvt->SetEvent();
pthread_detach(pthread_self());
pthis->m_tid = (pthread_t)0;
return NULL;
}
// ******************************************************************************
// Name: GetThreadId()
// Desc: Returns the thread ID
// Ret: Thread ID
// ******************************************************************************
DWORD CThreadWrapper::GetThreadId()
{
return (long long)m_tid;
}
|
