source: src/libcfa/concurrency/kernel @ 8def349

aaron-thesisarm-ehcleanup-dtorsdeferred_resndemanglerjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerresolv-newwith_gc
Last change on this file since 8def349 was 8def349, checked in by Thierry Delisle <tdelisle@…>, 5 years ago

cfa now supports processors which represent kernel threads, allowing basic parallelism

  • Property mode set to 100644
File size: 2.4 KB
Line 
1//                              -*- Mode: CFA -*-
2//
3// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
4//
5// The contents of this file are covered under the licence agreement in the
6// file "LICENCE" distributed with Cforall.
7//
8// threads --
9//
10// Author           : Thierry Delisle
11// Created On       : Tue Jan 17 12:27:26 2016
12// Last Modified By : Thierry Delisle
13// Last Modified On : --
14// Update Count     : 0
15//
16
17#ifndef KERNEL_H
18#define KERNEL_H
19
20#include <stdbool.h>
21
22#include "invoke.h"
23
24extern "C" {
25#include <pthread.h>
26}
27
28//-----------------------------------------------------------------------------
29// Cluster
30struct cluster {
31        simple_thread_list ready_queue;
32        pthread_spinlock_t lock;
33};
34
35void ?{}(cluster * this);
36void ^?{}(cluster * this);
37
38//-----------------------------------------------------------------------------
39// Processor
40struct processor {
41        struct processorCtx_t * ctx;
42        cluster * cltr;
43        coroutine * current_coroutine;
44        thread_h * current_thread;
45        pthread_t kernel_thread;
46        simple_lock lock;
47        volatile bool terminated;
48};
49
50void ?{}(processor * this);
51void ?{}(processor * this, cluster * cltr);
52void ^?{}(processor * this);
53
54
55//-----------------------------------------------------------------------------
56// Locks
57
58void ?{}(simple_lock * this);
59void ^?{}(simple_lock * this);
60
61void lock( simple_lock * );
62void unlock( simple_lock * );
63
64struct pthread_spinlock_guard {
65        pthread_spinlock_t * lock;
66};
67
68static inline void ?{}( pthread_spinlock_guard * this, pthread_spinlock_t * lock ) {
69        this->lock = lock;
70        pthread_spin_lock( this->lock );
71}
72
73static inline void ^?{}( pthread_spinlock_guard * this ) {
74        pthread_spin_unlock( this->lock );
75}
76
77// //Simple spinlock implementation from
78// //http://stackoverflow.com/questions/1383363/is-my-spin-lock-implementation-correct-and-optimal
79// //Not optimal but correct
80// #define VOL
81
82// struct simple_spinlock {
83//      VOL int lock;
84// };
85
86// extern VOL int __sync_lock_test_and_set( VOL int *, VOL int);
87// extern void __sync_synchronize();
88
89// static inline void lock( simple_spinlock * this ) {
90//     while (__sync_lock_test_and_set(&this->lock, 1)) {
91//         // Do nothing. This GCC builtin instruction
92//         // ensures memory barrier.
93//     }
94// }
95
96// static inline void unlock( simple_spinlock * this ) {
97//     __sync_synchronize(); // Memory barrier.
98//     this->lock = 0;
99// }
100
101#endif //KERNEL_H
102
103// Local Variables: //
104// mode: c //
105// tab-width: 4 //
106// End: //
Note: See TracBrowser for help on using the repository browser.