]>
Commit | Line | Data |
---|---|---|
1 | ///////////////////////////////////////////////////////////////////////////// | |
2 | // Name: threadsgi.cpp | |
3 | // Purpose: wxThread (SGI) Implementation | |
4 | // Author: Original from Wolfram Gloger/Guilhem Lavaux | |
5 | // Modified by: | |
6 | // Created: 04/22/98 | |
7 | // RCS-ID: $Id$ | |
8 | // Copyright: (c) Wolfram Gloger (1996, 1997); Guilhem Lavaux (1998) | |
9 | // Licence: wxWindows licence | |
10 | ///////////////////////////////////////////////////////////////////////////// | |
11 | #if defined(__GNUG__) && !defined(NO_GCC_PRAGMA) | |
12 | #pragma implementation "thread.h" | |
13 | #endif | |
14 | ||
15 | // For compilers that support precompilation, includes "wx.h". | |
16 | #include "wx/wxprec.h" | |
17 | ||
18 | #include "wx/thread.h" | |
19 | #include <stdio.h> | |
20 | #include <unistd.h> | |
21 | ||
22 | #include <signal.h> | |
23 | #include <sys/wait.h> | |
24 | #include <sys/prctl.h> | |
25 | #include "wx/module.h" | |
26 | #include "wx/utils.h" | |
27 | #include "wx/log.h" | |
28 | ||
29 | #include "gdk/gdk.h" | |
30 | #include "gtk/gtk.h" | |
31 | ||
32 | enum thread_state | |
33 | { | |
34 | STATE_IDLE = 0, | |
35 | STATE_RUNNING, | |
36 | STATE_CANCELED, | |
37 | STATE_EXITED | |
38 | }; | |
39 | ||
40 | ///////////////////////////////////////////////////////////////////////////// | |
41 | // Static variables | |
42 | ///////////////////////////////////////////////////////////////////////////// | |
43 | ||
44 | static int p_mainid; | |
45 | wxMutex *wxMainMutex; | |
46 | ||
47 | #include "threadgui.inc" | |
48 | ||
49 | ///////////////////////////////////////////////////////////////////////////// | |
50 | // Unix implementations (SGI threads) | |
51 | ///////////////////////////////////////////////////////////////////////////// | |
52 | ||
53 | class wxMutexInternal { | |
54 | public: | |
55 | abilock_t p_mutex; | |
56 | }; | |
57 | ||
58 | wxMutex::wxMutex() | |
59 | { | |
60 | m_locked = 0; | |
61 | p_internal = new wxMutexInternal; | |
62 | init_lock(&(p_internal->p_mutex)); | |
63 | } | |
64 | ||
65 | wxMutex::~wxMutex() | |
66 | { | |
67 | if (m_locked > 0) | |
68 | wxLogDebug( "wxMutex warning: freeing a locked mutex (%d locks)\n", m_locked ); | |
69 | delete p_internal; | |
70 | } | |
71 | ||
72 | wxMutexError wxMutex::Lock() | |
73 | { | |
74 | spin_lock(&(p_internal->p_mutex)); | |
75 | m_locked++; | |
76 | return wxMUTEX_NO_ERROR; | |
77 | } | |
78 | ||
79 | wxMutexError wxMutex::TryLock() | |
80 | { | |
81 | if (acquire_lock(&(p_internal->p_mutex)) != 0) | |
82 | return wxMUTEX_BUSY; | |
83 | m_locked++; | |
84 | return wxMUTEX_NO_ERROR; | |
85 | } | |
86 | ||
87 | wxMutexError wxMutex::Unlock() | |
88 | { | |
89 | if (m_locked == 0) | |
90 | return wxMUTEX_UNLOCKED; | |
91 | release_lock(&(p_internal->p_mutex)); | |
92 | m_locked--; | |
93 | return wxMUTEX_NO_ERROR; | |
94 | } | |
95 | ||
96 | // GL: Don't know how it works on SGI. Wolfram ? | |
97 | ||
98 | wxCondition::wxCondition() {} | |
99 | wxCondition::~wxCondition() {} | |
100 | int wxCondition::Wait(wxMutex& WXUNUSED(mutex)) { return 0;} | |
101 | int wxCondition::Wait(wxMutex& WXUNUSED(mutex), unsigned long WXUNUSED(sec), | |
102 | unsigned long WXUNUSED(nsec)) { return 0; } | |
103 | int wxCondition::Signal() { return 0; } | |
104 | int wxCondition::Broadcast() { return 0; } | |
105 | ||
106 | class | |
107 | wxThreadPrivate { | |
108 | public: | |
109 | wxThreadPrivate() { thread_id = 0; state = STATE_IDLE; } | |
110 | ~wxThreadPrivate() {} | |
111 | static void SprocStart(void *ptr); | |
112 | static void SignalHandler(int sig); | |
113 | public: | |
114 | int state, thread_id; | |
115 | void* exit_status; | |
116 | }; | |
117 | ||
118 | void wxThreadPrivate::SprocStart(void *ptr) | |
119 | { | |
120 | void* status; | |
121 | ||
122 | wxThread *thr = (wxThread *)ptr; | |
123 | ||
124 | thr->p_internal->thread_id = getpid(); | |
125 | thr->p_internal->exit_status = 0; | |
126 | status = thr->Entry(); | |
127 | thr->Exit(status); | |
128 | } | |
129 | ||
130 | void wxThread::Exit(void* status) | |
131 | { | |
132 | wxThread* ptr = this; | |
133 | THREAD_SEND_EXIT_MSG(ptr); | |
134 | p_internal->state = STATE_EXITED; | |
135 | p_internal->exit_status = status; | |
136 | _exit(0); | |
137 | } | |
138 | ||
139 | wxThreadError wxThread::Create() | |
140 | { | |
141 | if (p_internal->state != STATE_IDLE) | |
142 | return wxTHREAD_RUNNING; | |
143 | p_internal->state = STATE_RUNNING; | |
144 | if (sproc(p_internal->SprocStart, PR_SALL, this) < 0) { | |
145 | p_internal->state = STATE_IDLE; | |
146 | return wxTHREAD_NO_RESOURCE; | |
147 | } | |
148 | return wxTHREAD_NO_ERROR; | |
149 | } | |
150 | ||
151 | wxThreadError wxThread::Destroy() | |
152 | { | |
153 | if (p_internal->state == STATE_RUNNING) | |
154 | p_internal->state = STATE_CANCELED; | |
155 | ||
156 | return wxTHREAD_NO_ERROR; | |
157 | } | |
158 | ||
159 | wxThreadError wxThread::Pause() | |
160 | { | |
161 | return wxTHREAD_NO_ERROR; | |
162 | } | |
163 | ||
164 | wxThreadError wxThread::Resume() | |
165 | { | |
166 | return wxTHREAD_NO_ERROR; | |
167 | } | |
168 | ||
169 | void *wxThread::Join() | |
170 | { | |
171 | if (p_internal->state != STATE_IDLE) { | |
172 | bool do_unlock = wxThread::IsMain(); | |
173 | int stat; | |
174 | ||
175 | if (do_unlock) | |
176 | wxMainMutex->Unlock(); | |
177 | waitpid(p_internal->thread_id, &stat, 0); | |
178 | if (do_unlock) | |
179 | wxMainMutex->Lock(); | |
180 | if (!WIFEXITED(stat) && !WIFSIGNALED(stat)) | |
181 | return 0; | |
182 | p_internal->state = STATE_IDLE; | |
183 | return p_internal->exit_status; | |
184 | } | |
185 | return 0; | |
186 | } | |
187 | ||
188 | unsigned long wxThread::GetID() const | |
189 | { | |
190 | return (unsigned long)p_internal->thread_id; | |
191 | } | |
192 | ||
193 | void wxThread::TestDestroy() | |
194 | { | |
195 | if (p_internal->state == STATE_CANCELED) { | |
196 | p_internal->exit_status = 0; | |
197 | _exit(0); | |
198 | } | |
199 | } | |
200 | ||
201 | void wxThread::SetPriority(int prio) | |
202 | { | |
203 | } | |
204 | ||
205 | int wxThread::GetPriority() const | |
206 | { | |
207 | return 0; | |
208 | } | |
209 | ||
210 | bool wxThread::IsMain() | |
211 | { | |
212 | return (int)getpid() == main_id; | |
213 | } | |
214 | ||
215 | bool wxThread::IsAlive() const | |
216 | { | |
217 | return (p_internal->state == STATE_RUNNING); | |
218 | } | |
219 | ||
220 | bool wxThread::IsRunning() const | |
221 | { | |
222 | return (p_internal->state == STATE_RUNNING); | |
223 | } | |
224 | ||
225 | wxThread::wxThread() | |
226 | { | |
227 | p_internal = new wxThreadPrivate(); | |
228 | } | |
229 | ||
230 | wxThread::~wxThread() | |
231 | { | |
232 | Cancel(); | |
233 | Join(); | |
234 | delete p_internal; | |
235 | } | |
236 | ||
237 | // The default callback just joins the thread and throws away the result. | |
238 | void wxThread::OnExit() | |
239 | { | |
240 | Join(); | |
241 | } | |
242 | ||
243 | // Global initialization | |
244 | ||
245 | class wxThreadModule : public wxModule | |
246 | { | |
247 | public: | |
248 | virtual bool OnInit(); | |
249 | virtual void OnExit(); | |
250 | ||
251 | private: | |
252 | DECLARE_DYNAMIC_CLASS(wxThreadModule) | |
253 | }; | |
254 | ||
255 | IMPLEMENT_DYNAMIC_CLASS(wxThreadModule, wxModule) | |
256 | ||
257 | bool wxThreadModule::OnInit() | |
258 | { | |
259 | wxMainMutex = new wxMutex(); | |
260 | wxThreadGuiInit(); | |
261 | p_mainid = (int)getpid(); | |
262 | wxMainMutex->Lock(); | |
263 | return TRUE; | |
264 | } | |
265 | ||
266 | void wxThreadModule::OnExit() | |
267 | { | |
268 | wxMainMutex->Unlock(); | |
269 | wxThreadGuiExit(); | |
270 | delete wxMainMutex; | |
271 | } | |
272 |