source: libcfa/src/concurrency/thread.cfa @ ab5baab

arm-ehjacob/cs343-translationnew-ast-unique-expr
Last change on this file since ab5baab was ab5baab, checked in by Thierry Delisle <tdelisle@…>, 4 months ago

Attempt to fix the stack checker for when coroutines are interrupted at the wrong moment

  • Property mode set to 100644
File size: 4.9 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 : Wed Dec  4 09:17:49 2019
13// Update Count     : 9
14//
15
16#define __cforall_thread__
17
18#include "thread.hfa"
19
20#include "kernel_private.hfa"
21#include "exception.hfa"
22
23#define __CFA_INVOKE_PRIVATE__
24#include "invoke.h"
25
26//-----------------------------------------------------------------------------
27// Thread ctors and dtors
28void ?{}($thread & this, const char * const name, cluster & cl, void * storage, size_t storageSize ) with( this ) {
29        context{ 0p, 0p };
30        self_cor{ name, storage, storageSize };
31        ticket = TICKET_RUNNING;
32        state = Start;
33        preempted = __NO_PREEMPTION;
34        corctx_flag = false;
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        link.next = 0p;
41        link.ts   = 0;
42        preferred = -1u;
43        last_proc = 0p;
44        #if defined( __CFA_WITH_VERIFY__ )
45                canary = 0x0D15EA5E0D15EA5Ep;
46        #endif
47
48        seqable.next = 0p;
49        seqable.back = 0p;
50
51        node.next = 0p;
52        node.prev = 0p;
53        doregister(curr_cluster, this);
54
55        monitors{ &self_mon_p, 1, (fptr_t)0 };
56}
57
58void ^?{}($thread& this) with( this ) {
59        #if defined( __CFA_WITH_VERIFY__ )
60                canary = 0xDEADDEADDEADDEADp;
61        #endif
62        unregister(curr_cluster, this);
63        ^self_cor{};
64}
65
66forall(T &)
67void copy(ThreadCancelled(T) * dst, ThreadCancelled(T) * src) {
68        dst->virtual_table = src->virtual_table;
69        dst->the_thread = src->the_thread;
70        dst->the_exception = src->the_exception;
71}
72
73forall(T &)
74const char * msg(ThreadCancelled(T) *) {
75        return "ThreadCancelled(...)";
76}
77
78forall(T &)
79static void default_thread_cancel_handler(ThreadCancelled(T) & ) {
80        // Improve this error message, can I do formatting?
81        abort( "Unhandled thread cancellation.\n" );
82}
83
84forall(T & | is_thread(T) | IS_EXCEPTION(ThreadCancelled, (T))
85    | { EHM_DEFAULT_VTABLE(ThreadCancelled, (T)); })
86void ?{}( thread_dtor_guard_t & this,
87                T & thrd, void(*cancelHandler)(ThreadCancelled(T) &)) {
88        $monitor * m = get_monitor(thrd);
89        $thread * desc = get_thread(thrd);
90
91        // Setup the monitor guard
92        void (*dtor)(T& mutex this) = ^?{};
93        bool join = cancelHandler != (void(*)(ThreadCancelled(T)&))0;
94        (this.mg){&m, (void(*)())dtor, join};
95
96
97        /* paranoid */ verifyf( Halted == desc->state || Cancelled == desc->state, "Expected thread to be Halted or Cancelled, was %d\n", (int)desc->state );
98
99        // After the guard set-up and any wait, check for cancellation.
100        struct _Unwind_Exception * cancellation = desc->self_cor.cancellation;
101        if ( likely( 0p == cancellation ) ) {
102                return;
103        } else if ( Cancelled == desc->state ) {
104                return;
105        }
106        desc->state = Cancelled;
107        void(*defaultResumptionHandler)(ThreadCancelled(T) &) =
108                join ? cancelHandler : default_thread_cancel_handler;
109
110        // TODO: Remove explitate vtable set once trac#186 is fixed.
111        ThreadCancelled(T) except;
112        except.virtual_table = &_default_vtable;
113        except.the_thread = &thrd;
114        except.the_exception = __cfaehm_cancellation_exception( cancellation );
115        // Why is this cast required?
116        throwResume (ThreadCancelled(T) &)except;
117
118        except.the_exception->virtual_table->free( except.the_exception );
119        free( cancellation );
120        desc->self_cor.cancellation = 0p;
121}
122
123void ^?{}( thread_dtor_guard_t & this ) {
124        ^(this.mg){};
125}
126
127//-----------------------------------------------------------------------------
128// Starting and stopping threads
129forall( T & | is_thread(T) )
130void __thrd_start( T & this, void (*main_p)(T &) ) {
131        $thread * this_thrd = get_thread(this);
132
133        disable_interrupts();
134        __cfactx_start(main_p, get_coroutine(this), this, __cfactx_invoke_thread);
135
136        this_thrd->context.[SP, FP] = this_thrd->self_cor.context.[SP, FP];
137        /* paranoid */ verify( this_thrd->context.SP );
138
139        schedule_thread$( this_thrd );
140        enable_interrupts();
141}
142
143//-----------------------------------------------------------------------------
144// Support for threads that don't ues the thread keyword
145forall( T & | sized(T) | is_thread(T) | { void ?{}(T&); } )
146void ?{}( scoped(T)& this ) with( this ) {
147        handle{};
148        __thrd_start(handle, main);
149}
150
151forall( T &, P... | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
152void ?{}( scoped(T)& this, P params ) with( this ) {
153        handle{ params };
154        __thrd_start(handle, main);
155}
156
157forall( T & | sized(T) | is_thread(T) )
158void ^?{}( scoped(T)& this ) with( this ) {
159        ^handle{};
160}
161
162//-----------------------------------------------------------------------------
163forall(T & | is_thread(T) | IS_RESUMPTION_EXCEPTION(ThreadCancelled, (T))
164    | { EHM_DEFAULT_VTABLE(ThreadCancelled, (T)); })
165T & join( T & this ) {
166        thread_dtor_guard_t guard = { this, defaultResumptionHandler };
167        return this;
168}
169
170uint64_t thread_rand() {
171        disable_interrupts();
172        uint64_t ret = __tls_rand();
173        enable_interrupts();
174        return ret;
175}
176
177// Local Variables: //
178// mode: c //
179// tab-width: 4 //
180// End: //
Note: See TracBrowser for help on using the repository browser.