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

ADTast-experimental
Last change on this file since e4d7c1c was cd5b58f, checked in by Thierry Delisle <tdelisle@…>, 2 years ago

Changed node link in thread to use dlink called cltr_link

  • Property mode set to 100644
File size: 7.1 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 : Sat Feb 12 15:24:18 2022
13// Update Count     : 66
14//
15
16#define __cforall_thread__
17#define _GNU_SOURCE
18
19#include "thread.hfa"
20
21#include "exception.hfa"
22#include "kernel/private.hfa"
23#include "limits.hfa"
24
25#define __CFA_INVOKE_PRIVATE__
26#include "invoke.h"
27
28extern uint32_t __global_random_seed, __global_random_prime, __global_random_mask;
29
30#pragma GCC visibility push(default)
31
32//-----------------------------------------------------------------------------
33// Thread ctors and dtors
34void ?{}( thread$ & this, const char * const name, cluster & cl, void * storage, size_t storageSize ) with( this ) {
35        context{ 0p, 0p };
36        self_cor{ name, storage, storageSize };
37        ticket = TICKET_RUNNING;
38        state = Start;
39        preempted = __NO_PREEMPTION;
40        corctx_flag = false;
41        curr_cor = &self_cor;
42        self_mon.owner = &this;
43        self_mon.recursion = 1;
44        self_mon_p = &self_mon;
45        curr_cluster = &cl;
46        rdy_link.next = 0p;
47        rdy_link.ts   = MAX;
48        preferred = ready_queue_new_preferred();
49        last_proc = 0p;
50        random_state = __global_random_mask ? __global_random_prime : __global_random_prime ^ rdtscl();
51        #if defined( __CFA_WITH_VERIFY__ )
52                executing = 0p;
53                canary = 0x0D15EA5E0D15EA5Ep;
54        #endif
55
56        clh_node = malloc( );
57        *clh_node = false;
58
59        doregister(curr_cluster, this);
60        monitors{ &self_mon_p, 1, (fptr_t)0 };
61}
62
63void ^?{}(thread$& this) with( this ) {
64        #if defined( __CFA_WITH_VERIFY__ )
65                canary = 0xDEADDEADDEADDEADp;
66        #endif
67        free(clh_node);
68        unregister(curr_cluster, this);
69        ^self_cor{};
70}
71
72forall(T &)
73void copy(ThreadCancelled(T) * dst, ThreadCancelled(T) * src) {
74        dst->virtual_table = src->virtual_table;
75        dst->the_thread = src->the_thread;
76        dst->the_exception = src->the_exception;
77}
78
79forall(T &)
80const char * msg(ThreadCancelled(T) *) {
81        return "ThreadCancelled(...)";
82}
83
84forall(T &)
85static void default_thread_cancel_handler(ThreadCancelled(T) & ) {
86        // Improve this error message, can I do formatting?
87        abort( "Unhandled thread cancellation.\n" );
88}
89
90forall(T & | is_thread(T) | IS_EXCEPTION(ThreadCancelled(T))
91    | { EHM_DEFAULT_VTABLE(ThreadCancelled(T)); })
92void ?{}( thread_dtor_guard_t & this,
93                T & thrd, void(*cancelHandler)(ThreadCancelled(T) &)) {
94        monitor$ * m = get_monitor(thrd);
95        thread$ * desc = get_thread(thrd);
96
97        // Setup the monitor guard
98        void (*dtor)(T& mutex this) = ^?{};
99        bool join = cancelHandler != (void(*)(ThreadCancelled(T)&))0;
100        (this.mg){&m, (void(*)())dtor, join};
101
102
103        /* paranoid */ verifyf( Halted == desc->state || Cancelled == desc->state, "Expected thread to be Halted or Cancelled, was %d\n", (int)desc->state );
104
105        // After the guard set-up and any wait, check for cancellation.
106        struct _Unwind_Exception * cancellation = desc->self_cor.cancellation;
107        if ( likely( 0p == cancellation ) ) {
108                return;
109        } else if ( Cancelled == desc->state ) {
110                return;
111        }
112        desc->state = Cancelled;
113        void(*defaultResumptionHandler)(ThreadCancelled(T) &) =
114                join ? cancelHandler : default_thread_cancel_handler;
115
116        // TODO: Remove explitate vtable set once trac#186 is fixed.
117        ThreadCancelled(T) except;
118        except.virtual_table = &_default_vtable;
119        except.the_thread = &thrd;
120        except.the_exception = __cfaehm_cancellation_exception( cancellation );
121        // Why is this cast required?
122        throwResume (ThreadCancelled(T) &)except;
123
124        except.the_exception->virtual_table->free( except.the_exception );
125        free( cancellation );
126        desc->self_cor.cancellation = 0p;
127}
128
129void ^?{}( thread_dtor_guard_t & this ) {
130        ^(this.mg){};
131}
132
133//-----------------------------------------------------------------------------
134// Starting and stopping threads
135forall( T & | is_thread(T) )
136void __thrd_start( T & this, void (*main_p)(T &) ) {
137        thread$ * this_thrd = get_thread(this);
138
139        disable_interrupts();
140        __cfactx_start(main_p, get_coroutine(this), this, __cfactx_invoke_thread);
141
142        this_thrd->context.[SP, FP] = this_thrd->self_cor.context.[SP, FP];
143        /* paranoid */ verify( this_thrd->context.SP );
144
145        schedule_thread$( this_thrd, UNPARK_LOCAL );
146        enable_interrupts();
147}
148
149//-----------------------------------------------------------------------------
150// Support for threads that don't ues the thread keyword
151forall( T & | sized(T) | is_thread(T) | { void ?{}(T&); } )
152void ?{}( scoped(T)& this ) with( this ) {
153        handle{};
154        __thrd_start(handle, main);
155}
156
157forall( T &, P... | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
158void ?{}( scoped(T)& this, P params ) with( this ) {
159        handle{ params };
160        __thrd_start(handle, main);
161}
162
163forall( T & | sized(T) | is_thread(T) )
164void ^?{}( scoped(T)& this ) with( this ) {
165        ^handle{};
166}
167
168//-----------------------------------------------------------------------------
169forall(T & | is_thread(T) | IS_RESUMPTION_EXCEPTION(ThreadCancelled(T))
170        | { EHM_DEFAULT_VTABLE(ThreadCancelled(T)); })
171T & join( T & this ) {
172        thread_dtor_guard_t guard = { this, defaultResumptionHandler };
173        return this;
174}
175
176//-----------------------------------------------------------------------------
177bool migrate( thread$ * thrd, struct cluster & cl ) {
178
179        monitor$ * tmon = get_monitor(thrd);
180        monitor$ * __monitors[] = { tmon };
181        monitor_guard_t __guard = { __monitors, 1 };
182
183
184        {
185                // if nothing needs to be done, return false
186                if( thrd->curr_cluster == &cl ) return false;
187
188                // are we migrating ourself?
189                const bool local = thrd == active_thread();
190
191                /* paranoid */ verify( !local || &cl != active_cluster() );
192                /* paranoid */ verify( !local || thrd->curr_cluster == active_cluster() );
193                /* paranoid */ verify( !local || thrd->curr_cluster == active_processor()->cltr );
194                /* paranoid */ verify( local || tmon->signal_stack.top->owner->waiting_thread == thrd );
195                /* paranoid */ verify( local || tmon->signal_stack.top );
196
197                // make sure we aren't interrupted while doing this
198                // not as important if we aren't local
199                disable_interrupts();
200
201                // actually move the thread
202                unregister( thrd->curr_cluster, *thrd );
203                thrd->curr_cluster = &cl;
204                doregister( thrd->curr_cluster, *thrd );
205
206                // restore interrupts
207                enable_interrupts();
208
209                // if this is the local thread, we are still running on the old cluster
210                if(local) yield();
211
212                /* paranoid */ verify( !local || &cl == active_cluster() );
213                /* paranoid */ verify( !local || thrd->curr_cluster == active_cluster() );
214                /* paranoid */ verify( !local || thrd->curr_cluster == active_processor()->cltr );
215                /* paranoid */ verify(  local || tmon->signal_stack.top );
216                /* paranoid */ verify(  local || tmon->signal_stack.top->owner->waiting_thread == thrd );
217
218                return true;
219        }
220}
221
222//-----------------------------------------------------------------------------
223#define GENERATOR LCG
224
225void set_seed( uint32_t seed ) {
226        uint32_t & state = active_thread()->random_state;
227        state = __global_random_seed = seed;
228        GENERATOR( state );
229        __global_random_prime = state;
230        __global_random_mask = true;
231} // set_seed
232
233uint32_t prng( void ) {                                                                 // [0,UINT_MAX]
234        uint32_t & state = active_thread()->random_state;
235        return GENERATOR( state );
236} // prng
237
238// Local Variables: //
239// mode: c //
240// tab-width: 4 //
241// End: //
Note: See TracBrowser for help on using the repository browser.