source: libcfa/src/concurrency/pthread.cfa @ 95dab9e

ADTast-experimentalpthread-emulation
Last change on this file since 95dab9e was 428adbc, checked in by z277zhu <z277zhu@…>, 21 months ago

fix pthread_sig* interpose problems; add test doc

Signed-off-by: z277zhu <z277zhu@…>
  • Property mode set to 100644
File size: 34.5 KB
Line 
1//
2// Cforall Version 1.0.0 Copyright (C) 2019 University of Waterloo
3//
4// The contents of this file are covered under the licence agreement in the
5// file "LICENCE" distributed with Cforall.
6//
7// pthread.cfa --
8//
9// Author           : Zhenyan Zhu
10// Created On       : Sat Aug 6 16:29:18 2022
11// Last Modified By :
12// Last Modified On :
13// Update Count     :
14//
15
16#define __cforall_thread__
17#define _GNU_SOURCE
18
19#include <pthread.h>
20#include <errno.h>
21#include "locks.hfa"
22#include "bits/stack.hfa"
23
24
25#pragma GCC diagnostic push
26#pragma GCC diagnostic ignored "-Wnonnull-compare"
27
28/* pthread key, pthread once inner routine mutual exclusion */
29static simple_owner_lock once_lock,key_lock,magic_mutex_check, concurrency_lock;
30
31//######################### Local Storage Helpers #########################
32
33#define PTHREADS_THR_MAX 256
34#define PTHREAD_KEYS_MAX 1024
35struct Pthread_values{
36    inline Seqable;
37    void* value;
38    bool in_use;
39};
40
41
42static Pthread_values *& Back( Pthread_values * n ) {
43    return (Pthread_values *)Back( (Seqable *)n );
44}
45static Pthread_values *& Next( Pthread_values * n ) {
46    return (Pthread_values *)Next( (Colable *)n );
47}
48
49struct Pthread_keys{
50    bool in_use;
51    void (*destructor)( void * );
52    Sequence(Pthread_values) threads;
53};  // Pthread keys
54
55static void ?{}(Pthread_keys& k){
56    //sout | "inited";
57    k.threads{};
58}
59
60// Create storage separately to ensure no constructors are called.
61//static char cfa_pthread_keys_storage[sizeof(Pthread_keys) * PTHREAD_KEYS_MAX] __attribute__((aligned (16))) = {0};
62static Pthread_keys cfa_pthread_keys_storage[PTHREAD_KEYS_MAX] __attribute__((aligned (16)));
63
64static void init_pthread_storage(){
65    for (int i = 0; i < PTHREAD_KEYS_MAX; i++){
66        cfa_pthread_keys_storage[i]{};
67    }
68}
69
70#define cfa_pthread_keys ((Pthread_keys *)cfa_pthread_keys_storage)
71
72/* Controlling the iterations of destructors for thread-specific data.  */
73#define _POSIX_THREAD_DESTRUCTOR_ITERATIONS     4
74/* Number of iterations this implementation does.  */
75#define PTHREAD_DESTRUCTOR_ITERATIONS   _POSIX_THREAD_DESTRUCTOR_ITERATIONS
76
77//######################### Parallelism Helpers #########################
78
79struct Pthread_kernel_threads{
80    inline Colable;
81    processor p;
82};
83
84Pthread_kernel_threads *& Next( Pthread_kernel_threads * n ) {
85    return (Pthread_kernel_threads *)Next( (Colable *)n );
86}
87
88static Stack(Pthread_kernel_threads) cfa_pthreads_kernel_threads;
89static bool cfa_pthreads_kernel_threads_zero = false;   // set to zero ?
90static int cfa_pthreads_no_kernel_threads = 1;  // number of kernel threads
91
92
93//######################### Cond Helpers #########################
94
95typedef pthread_cond_var(simple_owner_lock) cfa2pthr_cond_var_t;
96
97/* condvar helper routines */
98static void init(pthread_cond_t* pcond){
99    static_assert(sizeof(pthread_cond_t) >= sizeof(cfa2pthr_cond_var_t),"sizeof(pthread_t) < sizeof(cfa2pthr_cond_var_t)");
100    cfa2pthr_cond_var_t* _cond = (cfa2pthr_cond_var_t*)pcond;
101    ?{}(*_cond);
102}
103
104static cfa2pthr_cond_var_t* get(pthread_cond_t* pcond){
105    static_assert(sizeof(pthread_cond_t) >= sizeof(cfa2pthr_cond_var_t),"sizeof(pthread_t) < sizeof(cfa2pthr_cond_var_t)");
106    return (cfa2pthr_cond_var_t*)pcond;
107}
108
109static void destroy(pthread_cond_t* cond){
110    static_assert(sizeof(pthread_cond_t) >= sizeof(cfa2pthr_cond_var_t),"sizeof(pthread_t) < sizeof(cfa2pthr_cond_var_t)");
111    ^?{}(*get(cond));
112}
113
114
115//######################### Mutex Helper #########################
116
117/* mutex helper routines */
118static void mutex_check(pthread_mutex_t* t){
119        // Use double check to improve performance. Check is safe on x86; volatile prevents compiler reordering
120        volatile pthread_mutex_t *const mutex_ = t;
121        // SKULLDUGGERY: not a portable way to access the kind field, /usr/include/x86_64-linux-gnu/bits/pthreadtypes.h
122        int _lock_val = ((pthread_mutex_t *)mutex_)->__data.__lock;
123        // if pthread_mutex_t is initialized by PTHREAD_MUTEX_INITIALIZER, _lock_val should be 0
124        if ( _lock_val == 0 ) {                 // static initialized ?
125            lock(magic_mutex_check);    // race
126            _lock_val = ((pthread_mutex_t *)mutex_)->__data.__lock;
127            if ( _lock_val == 0 ) {             // static initialized ?
128                pthread_mutex_init( t, NULL );
129            } // if
130            unlock(magic_mutex_check);  // race
131        } // if
132} // mutex_check
133
134
135static void init(pthread_mutex_t* plock){
136    static_assert(sizeof(pthread_mutex_t) >= sizeof(simple_owner_lock),"sizeof(pthread_mutex_t) < sizeof(simple_owner_lock)");
137    simple_owner_lock* _lock = (simple_owner_lock*)plock;
138    ?{}(*_lock);
139}
140
141static simple_owner_lock* get(pthread_mutex_t* plock){
142    static_assert(sizeof(pthread_mutex_t) >= sizeof(simple_owner_lock),"sizeof(pthread_mutex_t) < sizeof(simple_owner_lock)");
143    return (simple_owner_lock*)plock;
144}
145
146static void destroy(pthread_mutex_t* plock){
147    static_assert(sizeof(pthread_mutex_t) >= sizeof(simple_owner_lock),"sizeof(pthread_mutex_t) < sizeof(simple_owner_lock)");
148    ^?{}(*get(plock));
149}
150
151//######################### Attr helpers #########################
152struct cfaPthread_attr_t {                                                              // thread attributes
153                int contentionscope;
154                int detachstate;
155                size_t stacksize;
156                void *stackaddr;
157                int policy;
158                int inheritsched;
159                struct sched_param param;
160} typedef cfaPthread_attr_t;
161
162static const cfaPthread_attr_t default_attrs{
163    0,
164    0,
165    (size_t)65000,
166    (void *)NULL,
167    0,
168    0,
169    {0}
170};
171
172
173/*
174static const cfaPthread_attr_t default_attrs = {
175    PTHREAD_SCOPE_SYSTEM,
176    PTHREAD_CREATE_JOINABLE,
177    (size_t)DEFAULT_STACK_SIZE,
178    (void *)NULL,
179    0,
180    PTHREAD_EXPLICIT_SCHED,
181    {0}
182};
183*/
184
185
186
187static cfaPthread_attr_t* get(const pthread_attr_t* attr){
188    static_assert(sizeof(pthread_attr_t) >= sizeof(cfaPthread_attr_t),"sizeof(pthread_attr_t) < sizeof(cfaPthread_attr_t)");
189    return (cfaPthread_attr_t*)attr;
190}
191
192
193//######################### Threads Helper #########################
194
195// exception for cancel_stack in pthread_exit
196exception pthread_exit_exp {};
197static vtable(pthread_exit_exp) exp;
198
199thread cfaPthread{
200    cfaPthread_attr_t attr;
201    pthread_t pthreadId;
202    void *joinval;                                                                              // pthreads return value
203        pthread_attr_t pthread_attr;                                            // pthread attributes
204    void *(*start_routine)(void *);                     // routine start
205    void *arg;                                                          // thread parameter                           
206    Pthread_values* pthreadData;
207    bool isTerminated;                                  // flag used for tryjoin
208};
209
210/* thread part routines */
211//  cfaPthread entry point
212void main(cfaPthread& _thread) with(_thread){
213    joinval =  start_routine(arg);
214    isTerminated = true;
215}
216
217// generate pthread_t by cfaPthread ptr
218static pthread_t create( cfaPthread *p ) {
219    static_assert(sizeof(pthread_t) >= sizeof(cfaPthread*),"sizeof(pthread_t) < sizeof(cfaPthread*)");
220        return (pthread_t)p;
221}
222
223static cfaPthread *lookup( pthread_t p ){
224    static_assert(sizeof(pthread_t) >= sizeof(cfaPthread*),"sizeof(pthread_t) < sizeof(cfaPthread*)");
225    return (cfaPthread*)p;
226}
227
228static void pthread_deletespecific_( Pthread_values* values )  { // see uMachContext::invokeTask
229    Pthread_values* value;
230    Pthread_keys* key;
231    bool destcalled = true;
232    if (values != NULL){
233        for ( int attempts = 0; attempts < PTHREAD_DESTRUCTOR_ITERATIONS && destcalled ; attempts += 1 ) {
234            destcalled = false;
235            lock(key_lock);
236            for (int i = 0; i < PTHREAD_KEYS_MAX; i++){
237                // for each valid key
238                if ( values[i].in_use){
239                    value = &values[i];
240                    key = &cfa_pthread_keys[i];
241                    value->in_use = false;
242                    remove(key->threads, *value);
243                    // if  a  key  value  has  a  non-NULL  destructor pointer,  and  the  thread  has  a  non-NULL  value associated with that key,
244                    // the value of the key is set to NULL, and then the function pointed to is called with the previously associated value as its sole argument.
245                    if (value->value != NULL && key->destructor != NULL){
246                        unlock(key_lock);
247                        key->destructor(value->value); // run destructor
248                        lock(key_lock);
249                        destcalled = true;
250                    }   // if
251                    value->value = NULL;
252                }   // if
253            }   // for
254            unlock(key_lock);
255        }   // for
256        free(values);
257    }   // if
258}
259
260static void ^?{}(cfaPthread & mutex t){
261    // delete pthread local storage
262    Pthread_values* values = t.pthreadData;
263    pthread_deletespecific_(values);
264}
265
266static void ?{}(cfaPthread &t, pthread_t* _thread, const pthread_attr_t * _attr,void *(*start_routine)(void *), void * arg) {
267   
268    // set up user thread stackSize
269    cfaPthread_attr_t * attr = get(_attr);
270    ((thread&)t){ attr ? attr->stacksize: DEFAULT_STACK_SIZE };
271
272    // initialize _thread & cfaPthread id
273    t.pthreadId = create(&t);
274    *_thread = t.pthreadId;
275
276    // if attr null, self attr will be set as default_attrs; else set to attr
277    t.attr = (attr != NULL ? *attr : default_attrs);
278
279    // init start routine and arguments
280    t.start_routine = start_routine;
281    t.arg = arg;
282    t.pthreadData = NULL;
283}   // not used
284
285
286extern "C"{
287    //######################### Pthread Attrs #########################
288
289    int pthread_attr_init(pthread_attr_t *attr) libcfa_public __THROW {
290        cfaPthread_attr_t* _attr = get(attr);
291        ?{}(*_attr);
292        *_attr = default_attrs;
293        return 0;
294    }
295    int pthread_attr_destroy(pthread_attr_t *attr) libcfa_public __THROW {
296        ^?{}(*get(attr));
297        return 0;
298    }
299   
300    int pthread_attr_setscope( pthread_attr_t *attr, int contentionscope ) libcfa_public __THROW {
301        get( attr )->contentionscope = contentionscope;
302        return 0;
303    } // pthread_attr_setscope
304
305    int pthread_attr_getscope( const pthread_attr_t *attr, int *contentionscope ) libcfa_public __THROW {
306        *contentionscope = get( attr )->contentionscope;
307        return 0;
308    } // pthread_attr_getscope
309
310    int pthread_attr_setdetachstate( pthread_attr_t *attr, int detachstate ) libcfa_public __THROW {
311        get( attr )->detachstate = detachstate;
312        return 0;
313    } // pthread_attr_setdetachstate
314
315    int pthread_attr_getdetachstate( const pthread_attr_t *attr, int *detachstate ) libcfa_public __THROW {
316        *detachstate = get( attr )->detachstate;
317        return 0;
318    } // pthread_attr_getdetachstate
319
320    int pthread_attr_setstacksize( pthread_attr_t *attr, size_t stacksize ) libcfa_public __THROW {
321        get( attr )->stacksize = stacksize;
322        return 0;
323    } // pthread_attr_setstacksize
324
325    int pthread_attr_getstacksize( const pthread_attr_t *attr, size_t *stacksize ) libcfa_public __THROW {
326        *stacksize = get( attr )->stacksize;
327        return 0;
328    } // pthread_attr_getstacksize
329
330    int pthread_attr_getguardsize( const pthread_attr_t * /* attr */, size_t * /* guardsize */ ) libcfa_public __THROW {
331            return 0;
332    } // pthread_attr_getguardsize
333
334    int pthread_attr_setguardsize( pthread_attr_t * /* attr */, size_t /* guardsize */ ) libcfa_public __THROW {
335            return 0;
336    } // pthread_attr_setguardsize
337
338    int pthread_attr_setstackaddr( pthread_attr_t *attr, void *stackaddr ) libcfa_public __THROW {
339        get( attr )->stackaddr = stackaddr;
340        return 0;
341    } // pthread_attr_setstackaddr
342
343    int pthread_attr_getstackaddr( const pthread_attr_t *attr, void **stackaddr ) libcfa_public __THROW {
344        *stackaddr = get( attr )->stackaddr;
345        return 0;
346    } // pthread_attr_getstackaddr
347
348    int pthread_attr_setstack( pthread_attr_t *attr, void *stackaddr, size_t stacksize ) libcfa_public __THROW {
349        get( attr )->stackaddr = stackaddr;
350        get( attr )->stacksize = stacksize;
351            return 0;
352    } // pthread_attr_setstack
353
354    int pthread_attr_getstack( const pthread_attr_t *attr, void **stackaddr, size_t *stacksize ) libcfa_public __THROW {
355        *stackaddr = get( attr )->stackaddr;
356        *stacksize = get( attr )->stacksize;
357        return 0;
358    } // pthread_attr_getstack
359
360    // Initialize thread attribute *attr with attributes corresponding to the
361    // already running thread threadID. It shall be called on unitialized attr
362    // and destroyed with pthread_attr_destroy when no longer needed.
363    int pthread_getattr_np( pthread_t threadID, pthread_attr_t *attr ) libcfa_public __THROW { // GNU extension
364        // race condition during copy
365        cfaPthread_attr_t* _attr = get(attr);
366        ?{}(*_attr);
367        if (_attr == NULL){
368            return ENOMEM;
369        }   // if
370        *_attr = lookup( threadID )->attr; // copy all fields
371            return 0;
372    } // pthread_getattr_np
373
374
375    //######################### Threads #########################
376
377    int pthread_create(pthread_t * _thread, const pthread_attr_t * attr, void *(*start_routine)(void *), void * arg) libcfa_public __THROW {
378        cfaPthread *t = alloc();
379        (*t){_thread, attr, start_routine, arg};
380        //init_user_pthread(*t, _thread, attr, start_routine, arg);
381        if (t == NULL) return EAGAIN; //no resource
382        return 0;
383    }   //pthread_create_
384
385
386    int pthread_join(pthread_t _thread, void **value_ptr) libcfa_public __THROW {
387        if (_thread == NULL) return EINVAL;   // if thread is invalid
388        if (_thread == pthread_self()) return EDEADLK;
389        cfaPthread* p = lookup(_thread);    // get user thr pointer   
390        try {
391            join(*p);
392        } catchResume (ThreadCancelled(cfaPthread) * cancel) {} // if thread called pthread_exit
393        if (value_ptr != NULL ) *value_ptr = p->joinval;   // fetch result
394        delete(p);
395        return 0;
396    }   //pthread_join_
397
398    int pthread_tryjoin_np(pthread_t _thread, void **value_ptr) libcfa_public __THROW {
399        if (_thread == NULL) return EINVAL;  // if thread is invalid
400        if (_thread == pthread_self()) return EDEADLK;
401        cfaPthread* p = lookup(_thread);
402        if (!p->isTerminated) return EBUSY; // thread not finished ?
403        join( *p );
404        if (value_ptr != NULL ) *value_ptr = p->joinval;
405        delete(p);
406        return 0;
407    }   //pthread_join_
408
409    pthread_t pthread_self(void) libcfa_public __THROW {
410        return (pthread_t)((char*)active_thread()-(sizeof(cfaPthread)-sizeof(thread$)));
411    }   //pthread_self_
412
413    void pthread_exit(void * status) libcfa_public __THROW {
414        pthread_t pid = pthread_self();
415        cfaPthread* _thread = (cfaPthread*)pid;
416        _thread->joinval = status;  // set return value
417        _thread->isTerminated = 1;  // set terminated flag
418        cancel_stack((pthread_exit_exp){&exp});
419    }   //pthread_exit_
420
421    int pthread_yield( void ) __THROW {                 // GNU extension
422        yield();
423        return 0;
424    }
425
426
427    //######################### Mutex #########################
428
429    int pthread_mutex_init(pthread_mutex_t *_mutex, const pthread_mutexattr_t *attr) libcfa_public __THROW {
430        if (_mutex == NULL) return EINVAL;
431
432        init(_mutex);
433        return 0;
434    }   //pthread_mutex_init_
435
436
437    int pthread_mutex_destroy(pthread_mutex_t *_mutex) libcfa_public __THROW{
438        if (_mutex == NULL){
439             return EINVAL;
440        }   // if mutex invalid
441        simple_owner_lock* _lock = get(_mutex);
442        if (_lock->owner != NULL){
443            return EBUSY;
444        }
445        destroy(_mutex);
446        return 0;
447    }   //pthread_mutex_destroy_
448
449    int pthread_mutex_lock(pthread_mutex_t *_mutex) libcfa_public __THROW{
450        if (_mutex == NULL) {
451            return EINVAL;
452        }   // if mutex invalid
453        mutex_check(_mutex);
454        simple_owner_lock* _lock = get(_mutex);
455        lock(*_lock);
456        return 0;
457    }   //pthread_mutex_lock_
458
459    int pthread_mutex_unlock(pthread_mutex_t *_mutex) libcfa_public __THROW{
460        if (_mutex == NULL) {
461            return EINVAL;
462        } // invalid mutex
463        simple_owner_lock* _lock = get(_mutex);
464        if (_lock->owner != active_thread()){
465            return EPERM;
466        } // current thread does not hold the mutex
467        unlock(*_lock);
468        return 0;
469    }   //pthread_mutex_unlock_
470
471    int pthread_mutex_trylock(pthread_mutex_t *_mutex) libcfa_public __THROW{
472        if (_mutex == NULL) {
473            return EINVAL;
474        }   // if mutex invalid
475        simple_owner_lock* _lock = get(_mutex);
476        if (_lock->owner != active_thread() && _lock->owner != NULL){
477            return EBUSY;
478        }   // if mutex is owned
479        lock(*_lock);
480        return 0;
481    }   //pthread_mutex_trylock_
482
483    //######################### Conditional Variable #########################
484
485    /* conditional variable routines */
486    int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr) libcfa_public __THROW {
487        if (cond == NULL) return EINVAL;
488        init(cond);
489        return 0;
490    }  //pthread_cond_init
491
492    int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *_mutex) libcfa_public __THROW {
493        if (cond == NULL || _mutex == NULL){
494            return EINVAL;
495        }   // invalid cond
496        wait(*get(cond), *get(_mutex));
497        return 0;
498    } // pthread_cond_wait
499
500    int pthread_cond_timedwait(pthread_cond_t * cond, pthread_mutex_t * _mutex, const struct timespec * abstime) libcfa_public __THROW {
501        if (cond == NULL || _mutex == NULL){
502            return EINVAL;
503        }   // invalid cond
504        wait(*get(cond), *get(_mutex), *abstime);
505        return 0;
506    } // pthread_cond_timedwait
507
508    int pthread_cond_signal(pthread_cond_t *cond) libcfa_public __THROW {
509        if (cond == NULL){
510            return EINVAL;
511        }   // invalid cond
512        return notify_one(*get(cond));
513    } // pthread_cond_signal
514
515    int pthread_cond_broadcast(pthread_cond_t *cond) libcfa_public __THROW {
516        if (cond == NULL){
517            return EINVAL;
518        }   // invalid cond
519        return notify_all(*get(cond));
520    } // pthread_cond_broadcast
521
522    int pthread_cond_destroy(pthread_cond_t *cond) libcfa_public __THROW {
523        if (cond == NULL){
524            return EINVAL;
525        }   // invalid cond
526        destroy(cond);
527        return 0;
528    } // pthread_cond_destroy
529
530
531
532    //######################### Local storage #########################
533
534    int pthread_once(pthread_once_t *once_control, void (*init_routine)(void)) libcfa_public __THROW {
535        static_assert(sizeof(pthread_once_t) >= sizeof(int),"sizeof(pthread_once_t) < sizeof(int)");
536        if (once_control == NULL){
537            return EINVAL;
538        }
539        if (init_routine == NULL){
540            return EINVAL;
541        }
542        lock(once_lock);
543        if ( *((int *)once_control) == 0 ) {
544            init_routine();
545            *((int *)once_control) = 1;
546            } // if
547        unlock(once_lock);
548        return 0;
549    } // pthread_once
550
551    int pthread_key_create( pthread_key_t *key, void (*destructor)( void * ) ) libcfa_public __THROW {
552        lock(key_lock);
553        for ( int i = 0; i < PTHREAD_KEYS_MAX; i += 1 ) {
554            if ( ! cfa_pthread_keys[i].in_use ) {
555                cfa_pthread_keys[i].in_use = true;
556                cfa_pthread_keys[i].destructor = destructor;
557                unlock( key_lock );
558                *key = i;
559                return 0;
560            } // if
561        } // for
562        unlock(key_lock);
563        return EAGAIN;
564    }   // pthread_key_create
565
566    int pthread_key_delete( pthread_key_t key ) libcfa_public __THROW {
567        lock(key_lock);
568        if ( key >= PTHREAD_KEYS_MAX || ! cfa_pthread_keys[key].in_use ) {
569            unlock( key_lock );
570            return EINVAL;
571        } // if
572        cfa_pthread_keys[key].in_use = false;
573        cfa_pthread_keys[key].destructor = NULL;
574
575        // Remove key from all threads with a value.
576        Pthread_values& p;
577        Sequence(Pthread_values)& head = cfa_pthread_keys[key].threads;
578        for ( SeqIter(Pthread_values) iter = { head }; iter | p; ) {
579            remove(head, p);
580            p.in_use = false;
581        }
582        unlock(key_lock);
583        return 0;
584    }   // pthread_key_delete
585
586    int pthread_setspecific( pthread_key_t key, const void *value ) libcfa_public __THROW {
587        // get current thread
588        cfaPthread* t = lookup(pthread_self());
589        // if current thread's pthreadData is NULL; initialize it
590        Pthread_values* values;
591        if (t->pthreadData == NULL){
592            values = anew( PTHREAD_KEYS_MAX);
593            t->pthreadData = values;
594            for (int i = 0;i < PTHREAD_KEYS_MAX; i++){
595                t->pthreadData[i].in_use = false;
596            }   // for
597        }   else {
598            values = t->pthreadData;
599        }   // if
600        // find corresponding key and set value
601        lock(key_lock);
602        // if invalid key
603        if ( key >= PTHREAD_KEYS_MAX || ! cfa_pthread_keys[key].in_use ) {
604            unlock( key_lock );
605            return EINVAL;
606        } // if
607        Pthread_values &entry = values[key];
608        if ( ! entry.in_use ) {
609            entry.in_use = true;
610            add(cfa_pthread_keys[key].threads, entry);
611        } // if
612        entry.value = (void *)value;
613        unlock(key_lock);
614        return 0;
615    } //pthread_setspecific
616
617    void* pthread_getspecific(pthread_key_t key) libcfa_public __THROW {
618        if (key >= PTHREAD_KEYS_MAX || ! cfa_pthread_keys[key].in_use) return NULL;
619
620        // get current thread
621        cfaPthread* t = lookup(pthread_self());
622        if (t->pthreadData == NULL) return NULL;
623        lock(key_lock);
624        Pthread_values &entry = ((Pthread_values *)t->pthreadData)[key];
625        if ( ! entry.in_use ) {
626            unlock( key_lock );
627            return NULL;
628        } // if
629            void *value = entry.value;
630        unlock(key_lock);
631
632        return value;
633    }   //pthread_get_specific
634
635    //######################### Parallelism #########################
636    void pthread_delete_kernel_threads_() libcfa_public __THROW {       // see uMain::~uMain
637        Pthread_kernel_threads& p;
638        for ( StackIter(Pthread_kernel_threads) iter = {cfa_pthreads_kernel_threads}; iter | p; ) {
639            delete(&p);
640        } // for
641    } // pthread_delete_kernel_threads_
642
643    int pthread_getconcurrency( void ) libcfa_public __THROW {  // XOPEN extension
644            return cfa_pthreads_kernel_threads_zero ? 0 : cfa_pthreads_no_kernel_threads;
645    } // pthread_getconcurrency
646
647    int pthread_setconcurrency( int new_level ) libcfa_public __THROW { // XOPEN extension
648      if ( new_level < 0 ) return EINVAL;
649      if ( new_level == 0 ) {
650        cfa_pthreads_kernel_threads_zero = true;        // remember set to zero, but ignore
651        return 0;                                       // do not do kernel thread management
652      } // exit
653      cfa_pthreads_kernel_threads_zero = false;
654      lock( concurrency_lock );
655      for ( ; new_level > cfa_pthreads_no_kernel_threads; cfa_pthreads_no_kernel_threads += 1 ) { // add processors ?
656        push(cfa_pthreads_kernel_threads, *new() );
657      } // for
658      for ( ; new_level < cfa_pthreads_no_kernel_threads; cfa_pthreads_no_kernel_threads -= 1 ) { // remove processors ?
659        delete(&pop(cfa_pthreads_kernel_threads));
660      } // for
661      unlock( concurrency_lock );
662      return 0;
663    } // pthread_setconcurrency
664
665    //######################### Signal #########################
666
667
668     int pthread_sigmask( int /* how */, const sigset_t * /* set */, sigset_t * /* oset */ ) libcfa_public __THROW {
669             return 0;
670     } // pthread_sigmask
671
672    int pthread_kill( pthread_t _thread __attribute__(( unused )), int sig ) libcfa_public __THROW {
673        if ( sig == 0 ) {
674            return 0;
675        } else {
676            abort( "pthread_kill : not implemented" );
677        } // if
678        return 0;
679    } // pthread_kill
680
681    int pthread_sigqueue(pthread_t , int sig, const union sigval) libcfa_public __THROW {
682        return 0;
683    } // pthread_sigqueue
684
685    //######################### Scheduling #########################
686    int pthread_detach( pthread_t threadID ) __THROW {
687        abort( "pthread_detach" );
688        return 0;
689    } // pthread_detach
690
691    int pthread_setschedparam( pthread_t /* thread */, int /* policy */, const struct sched_param * /* param */ ) libcfa_public __THROW {
692        abort( "pthread_setschedparam : not implemented" );
693        return 0;
694    } // pthread_setschedparam
695
696    int pthread_getschedparam( pthread_t /* thread */, int */* policy */, struct sched_param * /* param */ ) libcfa_public __THROW {
697        abort( "pthread_getschedparam : not implemented" );
698        return 0;
699    } // pthread_getschedparam
700
701     //######################### Mutex Attr #########################
702
703    int pthread_mutexattr_init( pthread_mutexattr_t * /* attr */ ) libcfa_public __THROW {
704            return 0;
705    } // pthread_mutexattr_init
706
707    int pthread_mutexattr_destroy( pthread_mutexattr_t * /* attr */ ) libcfa_public __THROW {
708        return 0;
709    } // pthread_mutexattr_destroy
710
711    int pthread_mutexattr_setpshared( pthread_mutexattr_t * /* attr */, int /* pshared */ ) libcfa_public __THROW {
712        return 0;
713    } // pthread_mutexattr_setpshared
714
715    int pthread_mutexattr_getpshared( const pthread_mutexattr_t * /* attr */, int * /* pshared */ ) libcfa_public __THROW {
716        return 0;
717    } // pthread_mutexattr_getpshared
718
719    int pthread_mutexattr_setprotocol( pthread_mutexattr_t * /* attr */, int /* protocol */ ) libcfa_public __THROW {
720        return 0;
721    } // pthread_mutexattr_setprotocol
722
723    int pthread_mutexattr_getprotocol( const pthread_mutexattr_t * /* attr */, int * /* protocol */ ) libcfa_public __THROW {
724        return 0;
725    } // pthread_mutexattr_getprotocol
726
727    int pthread_mutexattr_setprioceiling( pthread_mutexattr_t * /* attr */, int /* prioceiling */ ) libcfa_public __THROW {
728        return 0;
729    } // pthread_mutexattr_setprioceiling
730
731    int pthread_mutexattr_getprioceiling( const pthread_mutexattr_t * /* attr */, int * /* ceiling */ ) libcfa_public __THROW {
732        return 0;
733    } // pthread_mutexattr_getprioceiling
734
735    int pthread_mutex_setprioceiling( pthread_mutex_t * /* mutex */, int /* prioceiling */, int * /* old_ceiling */ ) libcfa_public __THROW {
736        return 0;
737    } // pthread_mutex_setprioceiling
738
739    int pthread_mutex_getprioceiling( const pthread_mutex_t * /* mutex */, int * /* ceiling */ ) libcfa_public __THROW {
740        return 0;
741    } // pthread_mutex_getprioceiling
742
743    int pthread_mutexattr_gettype( __const pthread_mutexattr_t * __restrict /* __attr */, int * __restrict /* __kind */ ) libcfa_public __THROW {
744        return 0;
745    } // pthread_mutexattr_gettype
746
747    int pthread_mutexattr_settype( pthread_mutexattr_t * /* __attr */, int /* __kind */ ) libcfa_public __THROW {
748        return 0;
749    } // pthread_mutexattr_settype
750
751    //######################### Mutex #########################
752
753    int pthread_mutex_timedlock( pthread_mutex_t *__restrict /* __mutex */, __const struct timespec *__restrict /* __abstime */ ) libcfa_public __THROW {
754            abort( "pthread_mutex_timedlock" );
755    } // pthread_mutex_timedlock
756
757    //######################### Condition #########################
758
759    int pthread_condattr_getclock( __const pthread_condattr_t * __restrict /* __attr */, __clockid_t *__restrict /* __clock_id */ ) libcfa_public __THROW {
760            abort( "pthread_condattr_getclock" );
761    } // pthread_condattr_getclock
762
763    int pthread_condattr_setclock( pthread_condattr_t * /* __attr */, __clockid_t /* __clock_id */ ) libcfa_public __THROW {
764            abort( "pthread_condattr_setclock" );
765    } // pthread_condattr_setclock
766
767    //######################### Spinlock #########################
768
769    int pthread_spin_init( pthread_spinlock_t * /* __lock */, int /*__pshared */ ) libcfa_public __THROW {
770            abort( "pthread_spin_init" );
771    } // pthread_spin_init
772
773    int pthread_spin_destroy( pthread_spinlock_t * /* __lock */ ) libcfa_public __THROW {
774            abort( "pthread_spin_destroy" );
775    } // pthread_spin_destroy
776
777    int pthread_spin_lock( pthread_spinlock_t * /* __lock */ ) libcfa_public __THROW {
778            abort( "pthread_spin_lock" );
779    } // pthread_spin_lock
780
781    int pthread_spin_trylock( pthread_spinlock_t * /* __lock */ ) libcfa_public __THROW {
782            abort( "pthread_spin_trylock" );
783    } // pthread_spin_trylock
784
785    int pthread_spin_unlock( pthread_spinlock_t * /* __lock */ ) libcfa_public __THROW {
786            abort( "pthread_spin_unlock" );
787    } // pthread_spin_unlock
788
789    //######################### Barrier #########################
790
791    int pthread_barrier_init( pthread_barrier_t *__restrict /* __barrier */, __const pthread_barrierattr_t *__restrict /* __attr */, unsigned int /* __count */ ) libcfa_public __THROW {
792            abort( "pthread_barrier_init" );
793    } // pthread_barrier_init
794
795    int pthread_barrier_destroy( pthread_barrier_t * /* __barrier */ ) libcfa_public  __THROW {
796            abort( "pthread_barrier_destroy" );
797    } // pthread_barrier_destroy
798
799    int pthread_barrier_wait( pthread_barrier_t * /* __barrier */ ) libcfa_public __THROW {
800            abort( "pthread_barrier_wait" );
801    } // pthread_barrier_wait
802
803    int pthread_barrierattr_init( pthread_barrierattr_t * /* __attr */ ) libcfa_public __THROW {
804            abort( "pthread_barrierattr_init" );
805    } // pthread_barrierattr_init
806
807    int pthread_barrierattr_destroy( pthread_barrierattr_t * /* __attr */ ) libcfa_public __THROW {
808            abort( "pthread_barrierattr_destroy" );
809    } // pthread_barrierattr_destroy
810
811    int pthread_barrierattr_getpshared( __const pthread_barrierattr_t * __restrict /* __attr */, int *__restrict /* __pshared */ ) libcfa_public __THROW {
812            abort( "pthread_barrierattr_getpshared" );
813    } // pthread_barrierattr_getpshared
814
815    int pthread_barrierattr_setpshared( pthread_barrierattr_t * /* __attr */, int /* __pshared */ ) libcfa_public __THROW {
816            abort( "pthread_barrierattr_setpshared" );
817    } // pthread_barrierattr_setpshared
818
819    //######################### Clock #########################
820
821    int pthread_getcpuclockid( pthread_t /* __thread_id */, __clockid_t * /* __clock_id */ ) libcfa_public __THROW {
822            abort( "pthread_getcpuclockid" );
823    } // pthread_getcpuclockid
824
825    // pthread_atfork()
826
827// UNIX98
828
829    //######################### Read/Write #########################
830
831    int pthread_rwlock_init( pthread_rwlock_t *__restrict /* __rwlock */, __const pthread_rwlockattr_t *__restrict /* __attr */ ) libcfa_public __THROW {
832            abort( "pthread_rwlock_init" );
833    } // pthread_rwlock_init
834
835    int pthread_rwlock_destroy( pthread_rwlock_t * /* __rwlock */ ) libcfa_public __THROW {
836            abort( "pthread_rwlock_destroy" );
837    } // pthread_rwlock_destroy
838
839    int pthread_rwlock_rdlock( pthread_rwlock_t * /* __rwlock */ ) libcfa_public __THROW {
840            abort( "pthread_rwlock_rdlock" );
841    } // pthread_rwlock_rdlock
842
843    int pthread_rwlock_tryrdlock( pthread_rwlock_t * /* __rwlock */ ) libcfa_public __THROW {
844            abort( "pthread_rwlock_tryrdlock" );
845    } // pthread_rwlock_tryrdlock
846
847    int pthread_rwlock_wrlock( pthread_rwlock_t * /* __rwlock */ ) libcfa_public __THROW {
848            abort( "pthread_rwlock_wrlock" );
849    } // pthread_rwlock_wrlock
850
851    int pthread_rwlock_trywrlock( pthread_rwlock_t * /* __rwlock */ ) libcfa_public __THROW {
852            abort( "pthread_rwlock_trywrlock" );
853    } // pthread_rwlock_trywrlock
854
855    int pthread_rwlock_unlock( pthread_rwlock_t * /* __rwlock */ ) libcfa_public __THROW {
856            abort( "pthread_rwlock_unlock" );
857    } // pthread_rwlock_unlock
858
859    int pthread_rwlockattr_init( pthread_rwlockattr_t * /* __attr */ ) libcfa_public __THROW {
860            abort( "pthread_rwlockattr_init" );
861    } // pthread_rwlockattr_init
862
863    int pthread_rwlockattr_destroy( pthread_rwlockattr_t * /*__attr */ ) libcfa_public __THROW {
864            abort( "pthread_rwlockattr_destroy" );
865    } // pthread_rwlockattr_destroy
866
867    int pthread_rwlockattr_getpshared( __const pthread_rwlockattr_t * __restrict /* __attr */, int *__restrict /* __pshared */ ) libcfa_public __THROW {
868            abort( "pthread_rwlockattr_getpshared" );
869    } // pthread_rwlockattr_getpshared
870
871    int pthread_rwlockattr_setpshared( pthread_rwlockattr_t * /* __attr */, int /* __pshared */ ) libcfa_public __THROW {
872            abort( "pthread_rwlockattr_setpshared" );
873    } // pthread_rwlockattr_setpshared
874
875    int pthread_rwlockattr_getkind_np( __const pthread_rwlockattr_t * /* __attr */, int * /* __pref */ ) libcfa_public __THROW {
876            abort( "pthread_rwlockattr_getkind_np" );
877    } // pthread_rwlockattr_getkind_np
878
879    int pthread_rwlockattr_setkind_np( pthread_rwlockattr_t * /* __attr */, int /* __pref */ ) libcfa_public __THROW {
880            abort( "pthread_rwlockattr_setkind_np" );
881    } // pthread_rwlockattr_setkind_np
882
883// UNIX98 + XOPEN
884
885    int pthread_rwlock_timedrdlock( pthread_rwlock_t *__restrict  /* __rwlock */, __const struct timespec *__restrict /* __abstime */ ) libcfa_public __THROW {
886            abort( "pthread_rwlock_timedrdlock" );
887    } // pthread_rwlock_timedrdlock
888
889    int pthread_rwlock_timedwrlock( pthread_rwlock_t *__restrict  /* __rwlock */, __const struct timespec *__restrict /* __abstime */ ) libcfa_public __THROW {
890            abort( "pthread_rwlock_timedwrlock" );
891    } // pthread_rwlock_timedwrlock
892
893// GNU
894
895    //######################### Parallelism #########################
896
897    int pthread_setaffinity_np( pthread_t /* __th */, size_t /* __cpusetsize */, __const cpu_set_t * /* __cpuset */ ) libcfa_public __THROW {
898            abort( "pthread_setaffinity_np" );
899    } // pthread_setaffinity_np
900
901    int pthread_getaffinity_np( pthread_t /* __th */, size_t /* __cpusetsize */, cpu_set_t * /* __cpuset */ ) libcfa_public __THROW {
902            abort( "pthread_getaffinity_np" );
903    } // pthread_getaffinity_np
904
905    int pthread_attr_setaffinity_np( pthread_attr_t * /* __attr */, size_t /* __cpusetsize */, __const cpu_set_t * /* __cpuset */ ) libcfa_public __THROW {
906            abort( "pthread_attr_setaffinity_np" );
907    } // pthread_attr_setaffinity_np
908
909    int pthread_attr_getaffinity_np( __const pthread_attr_t * /* __attr */, size_t /* __cpusetsize */, cpu_set_t * /* __cpuset */ ) libcfa_public __THROW {
910            abort( "pthread_attr_getaffinity_np" );
911    } // pthread_attr_getaffinity_np
912
913    //######################### Cancellation #########################
914
915    void _pthread_cleanup_push_defer( struct _pthread_cleanup_buffer * /* __buffer */, void( * /* __routine */ )( void * ), void * /* __arg */ ) libcfa_public __THROW {
916            abort( "_pthread_cleanup_push_defer" );
917    } // _pthread_cleanup_push_defer
918
919    void _pthread_cleanup_pop_restore( struct _pthread_cleanup_buffer * /* __buffer */, int /* __execute */ ) libcfa_public __THROW {
920            abort( "_pthread_cleanup_pop_restore" );
921    } // _pthread_cleanup_pop_res
922
923    int pthread_cancel( pthread_t threadID ) libcfa_public __THROW {
924        abort("pthread cancel not implemented");
925            return 0;
926    } // pthread_cancel
927
928    int pthread_setcancelstate( int state, int *oldstate ) libcfa_public __THROW {
929        abort("pthread_setcancelstate not implemented");
930            return 0;
931    } // pthread_setcancelstate
932
933    int pthread_setcanceltype( int type, int *oldtype ) libcfa_public __THROW {
934        abort("pthread_setcanceltype not implemented");
935            return 0;
936    } // pthread_setcanceltype
937} // extern "C"
938
939#pragma GCC diagnostic pop
940
Note: See TracBrowser for help on using the repository browser.