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

ADTast-experimentalenumforall-pointer-decaypthread-emulationqualifiedEnum
Last change on this file since abcae55 was abcae55, checked in by Thierry Delisle <tdelisle@…>, 3 years ago

Removed last_cpu (and small spacing changes)

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