Thu, 26 Jan 2017 18:53:52 +0100
more windows porting
1 | 1 | /* |
2 | * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. | |
3 | * | |
4 | * Copyright 2008 Sun Microsystems, Inc. All rights reserved. | |
5 | * | |
6 | * THE BSD LICENSE | |
7 | * | |
8 | * Redistribution and use in source and binary forms, with or without | |
9 | * modification, are permitted provided that the following conditions are met: | |
10 | * | |
11 | * Redistributions of source code must retain the above copyright notice, this | |
12 | * list of conditions and the following disclaimer. | |
13 | * Redistributions in binary form must reproduce the above copyright notice, | |
14 | * this list of conditions and the following disclaimer in the documentation | |
15 | * and/or other materials provided with the distribution. | |
16 | * | |
17 | * Neither the name of the nor the names of its contributors may be | |
18 | * used to endorse or promote products derived from this software without | |
19 | * specific prior written permission. | |
20 | * | |
21 | * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | |
22 | * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | |
23 | * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | |
24 | * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER | |
25 | * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, | |
26 | * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, | |
27 | * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; | |
28 | * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, | |
29 | * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR | |
30 | * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF | |
31 | * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
32 | */ | |
33 | ||
34 | /* | |
35 | * systhr.c: Abstracted threading mechanisms | |
36 | * | |
37 | * Rob McCool | |
38 | */ | |
39 | ||
40 | ||
41 | #include "systhr.h" | |
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
42 | //include "ereport.h" |
1 | 43 | |
40 | 44 | //include "prinit.h" |
45 | //include "prthread.h" | |
41
bb7a1f5a8b48
added Linux support
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
40
diff
changeset
|
46 | //include "private/pprthred.h" |
1 | 47 | |
48 | #include "systems.h" | |
49 | ||
50 | #ifdef XP_UNIX | |
51 | #include <poll.h> | |
52 | #endif | |
53 | ||
54 | #define DEFAULT_STACKSIZE (64*1024) | |
55 | ||
56 | static unsigned long _systhr_stacksize = DEFAULT_STACKSIZE; | |
57 | ||
58 | NSAPI_PUBLIC | |
59 | void systhread_set_default_stacksize(unsigned long size) | |
60 | { | |
61 | _systhr_stacksize = size; | |
62 | } | |
63 | ||
64 | ||
161
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
65 | #ifdef XP_UNIX |
1 | 66 | |
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
67 | SYS_THREAD systhread_start(int prio, int stksz, thrstartfunc fn, void *arg) { |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
68 | pthread_t thr = 0; |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
69 | pthread_attr_t attr; |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
70 | |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
71 | pthread_attr_init(&attr); |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
72 | if(stksz) { |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
73 | pthread_attr_setstacksize(&attr, stksz); |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
74 | } |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
75 | |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
76 | if(pthread_create(&thr, &attr, (posix_thrstartfunc)fn, arg) != 0) { |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
77 | /* error */ |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
78 | } |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
79 | |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
80 | return thr; |
1 | 81 | } |
82 | ||
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
83 | SYS_THREAD systhread_current(void) { |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
84 | return pthread_self(); |
1 | 85 | } |
86 | ||
40 | 87 | void systhread_yield(void) { |
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
88 | sched_yield(); |
1 | 89 | } |
90 | ||
91 | ||
40 | 92 | void systhread_timerset(int usec) { |
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
93 | |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
94 | } |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
95 | |
40 | 96 | SYS_THREAD systhread_attach(void) { |
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
97 | /* TODO: what to do? */ |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
98 | return 0; |
1 | 99 | } |
100 | ||
40 | 101 | void systhread_detach(SYS_THREAD thr) { |
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
102 | pthread_detach(thr); |
1 | 103 | } |
104 | ||
40 | 105 | void systhread_terminate(SYS_THREAD thr) { |
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
106 | //PR_Interrupt((PRThread *)thr); |
1 | 107 | } |
108 | ||
40 | 109 | void systhread_sleep(int msec) { |
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
110 | if(msec > 0) { |
41
bb7a1f5a8b48
added Linux support
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
40
diff
changeset
|
111 | poll(NULL, 0, msec); |
29
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
112 | } else { |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
113 | sched_yield(); |
e8619defde14
added event handler
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
14
diff
changeset
|
114 | } |
1 | 115 | } |
116 | ||
40 | 117 | NSAPI_PUBLIC int systhread_newkey() { |
118 | pthread_key_t key; | |
119 | pthread_key_create(&key, NULL); | |
120 | ||
121 | return (int)key; // TODO: don't use int | |
122 | } | |
123 | ||
124 | NSAPI_PUBLIC void* systhread_getdata(int key) { | |
125 | return pthread_getspecific((pthread_key_t)key); | |
126 | } | |
127 | ||
128 | NSAPI_PUBLIC void systhread_setdata(int key, void *data) { | |
129 | pthread_setspecific((pthread_key_t)key, data); | |
130 | } | |
131 | ||
1 | 132 | NSAPI_PUBLIC void systhread_init(char *name) |
133 | { | |
40 | 134 | //if (!PR_Initialized()) { |
135 | // PR_Init(PR_USER_THREAD, PR_PRIORITY_NORMAL, 256); | |
136 | //} | |
1 | 137 | // XXX: ruslan - this bug can potentially exist on all plafroms due to |
138 | // possible priority inversion on NSPR spin locks. This code will | |
139 | // need to be remove as we get new NSPR drop | |
140 | // <WORKAROUND> | |
141 | /* VB: This is to fix bug# 364813 coupled with NSPR not wanting to patch | |
142 | their problems. The fix is to prevent NSPR itself from | |
143 | using atomic stacks. | |
144 | */ | |
145 | // ruslan: this problem exists on DEC also. We will roll it back when | |
146 | // we have the right fix from NSPR group. It has smth. to do with | |
147 | // atomic operations on DEC, it's an assembly code which is different | |
148 | // for every platform. NSPR_FD_CACHE_SIZE_HIGH env var will cause the | |
149 | // same effect as this fix. Debug version of NSPR always works as it doesn't | |
150 | // have FD stack. | |
151 | ||
40 | 152 | //int maxPRFdCache = 8192; |
153 | //PR_SetFDCacheSize(0, maxPRFdCache); | |
1 | 154 | // </WORKAROUND> |
155 | } | |
156 | ||
40 | 157 | NSAPI_PUBLIC void systhread_dummy(void) { |
161
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
158 | |
1 | 159 | } |
161
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
160 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
161 | #endif |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
162 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
163 | #ifdef XP_WIN32 |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
164 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
165 | SYS_THREAD systhread_start(int prio, int stksz, thrstartfunc fn, void *arg) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
166 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
167 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
168 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
169 | SYS_THREAD systhread_current(void) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
170 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
171 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
172 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
173 | void systhread_yield(void) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
174 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
175 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
176 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
177 | void systhread_timerset(int usec) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
178 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
179 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
180 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
181 | SYS_THREAD systhread_attach(void) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
182 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
183 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
184 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
185 | void systhread_detach(SYS_THREAD thr) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
186 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
187 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
188 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
189 | void systhread_terminate(SYS_THREAD thr) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
190 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
191 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
192 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
193 | void systhread_sleep(int msec) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
194 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
195 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
196 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
197 | NSAPI_PUBLIC int systhread_newkey() { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
198 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
199 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
200 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
201 | NSAPI_PUBLIC void* systhread_getdata(int key) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
202 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
203 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
204 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
205 | NSAPI_PUBLIC void systhread_setdata(int key, void *data) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
206 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
207 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
208 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
209 | NSAPI_PUBLIC void systhread_init(char *name) |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
210 | { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
211 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
212 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
213 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
214 | NSAPI_PUBLIC void systhread_dummy(void) { |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
215 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
216 | } |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
217 | |
aadda87bad1b
more windows porting
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
41
diff
changeset
|
218 | #endif |