source: src/libcfa/concurrency/thread.c @ 5510027

ADTaaron-thesisarm-ehast-experimentalcleanup-dtorsdeferred_resndemanglerenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerpthread-emulationqualifiedEnumwith_gc
Last change on this file since 5510027 was a1a17a74, checked in by Thierry Delisle <tdelisle@…>, 6 years ago

Moved thread list to cluster, all concurrency object should be accessible through gdb

  • Property mode set to 100644
File size: 3.5 KB
Line 
1//
2// Cforall Version 1.0.0 Copyright (C) 2016 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// thread.c --
8//
9// Author           : Thierry Delisle
10// Created On       : Tue Jan 17 12:27:26 2017
11// Last Modified By : Peter A. Buhr
12// Last Modified On : Fri Mar 30 17:19:52 2018
13// Update Count     : 8
14//
15
16#include "thread"
17
18#include "kernel_private.h"
19
20#define __CFA_INVOKE_PRIVATE__
21#include "invoke.h"
22
23extern "C" {
24        #include <fenv.h>
25        #include <stddef.h>
26}
27
28//extern volatile thread_local processor * this_processor;
29
30//-----------------------------------------------------------------------------
31// Thread ctors and dtors
32void ?{}(thread_desc & this, const char * const name, cluster & cl, void * storage, size_t storageSize ) with( this ) {
33        self_cor{ name, storage, storageSize };
34        verify(&self_cor);
35        curr_cor = &self_cor;
36        self_mon.owner = &this;
37        self_mon.recursion = 1;
38        self_mon_p = &self_mon;
39        curr_cluster = &cl;
40        next = NULL;
41
42        node.next = NULL;
43        node.prev = NULL;
44        doregister(curr_cluster, this);
45
46        monitors{ &self_mon_p, 1, (fptr_t)0 };
47}
48
49void ^?{}(thread_desc& this) with( this ) {
50        unregister(curr_cluster, this);
51        ^self_cor{};
52}
53
54forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T&); } )
55void ?{}( scoped(T)& this ) with( this ) {
56        handle{};
57        __thrd_start(handle);
58}
59
60forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
61void ?{}( scoped(T)& this, P params ) with( this ) {
62        handle{ params };
63        __thrd_start(handle);
64}
65
66forall( dtype T | sized(T) | is_thread(T) )
67void ^?{}( scoped(T)& this ) with( this ) {
68        ^handle{};
69}
70
71//-----------------------------------------------------------------------------
72// Starting and stopping threads
73forall( dtype T | is_thread(T) )
74void __thrd_start( T& this ) {
75        coroutine_desc* thrd_c = get_coroutine(this);
76        thread_desc   * thrd_h = get_thread   (this);
77        thrd_c->last = TL_GET( this_coroutine );
78
79        // __cfaabi_dbg_print_safe("Thread start : %p (t %p, c %p)\n", this, thrd_c, thrd_h);
80
81        disable_interrupts();
82        create_stack(&thrd_c->stack, thrd_c->stack.size);
83        kernelTLS.this_coroutine = thrd_c;
84        CtxStart(&this, CtxInvokeThread);
85        assert( thrd_c->last->stack.context );
86        CtxSwitch( thrd_c->last->stack.context, thrd_c->stack.context );
87
88        ScheduleThread(thrd_h);
89        enable_interrupts( __cfaabi_dbg_ctx );
90}
91
92extern "C" {
93        // KERNEL ONLY
94        void __finish_creation(void) {
95                coroutine_desc* thrd_c = kernelTLS.this_coroutine;
96                ThreadCtxSwitch( thrd_c, thrd_c->last );
97        }
98}
99
100void yield( void ) {
101        // Safety note : This could cause some false positives due to preemption
102      verify( TL_GET( preemption_state.enabled ) );
103        BlockInternal( TL_GET( this_thread ) );
104        // Safety note : This could cause some false positives due to preemption
105      verify( TL_GET( preemption_state.enabled ) );
106}
107
108void yield( unsigned times ) {
109        for( unsigned i = 0; i < times; i++ ) {
110                yield();
111        }
112}
113
114// KERNEL ONLY
115void ThreadCtxSwitch(coroutine_desc* src, coroutine_desc* dst) {
116        // set state of current coroutine to inactive
117        src->state = src->state == Halted ? Halted : Inactive;
118        dst->state = Active;
119
120        // set new coroutine that the processor is executing
121        // and context switch to it
122        kernelTLS.this_coroutine = dst;
123        assert( src->stack.context );
124        CtxSwitch( src->stack.context, dst->stack.context );
125        kernelTLS.this_coroutine = src;
126
127        // set state of new coroutine to active
128        dst->state = dst->state == Halted ? Halted : Inactive;
129        src->state = Active;
130}
131
132// Local Variables: //
133// mode: c //
134// tab-width: 4 //
135// End: //
Note: See TracBrowser for help on using the repository browser.