source: src/libcfa/concurrency/invoke.h@ 695e00d

ADT aaron-thesis arm-eh ast-experimental cleanup-dtors deferred_resn demangler enum forall-pointer-decay jacob/cs343-translation jenkins-sandbox new-ast new-ast-unique-expr new-env no_list persistent-indexer pthread-emulation qualifiedEnum resolv-new with_gc
Last change on this file since 695e00d was 6b224a52, checked in by Thierry Delisle <tdelisle@…>, 8 years ago

Merge branch 'master' of plg.uwaterloo.ca:software/cfa/cfa-cc

  • Property mode set to 100644
File size: 5.5 KB
RevLine 
[8def349]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// invoke.h --
8//
9// Author : Thierry Delisle
10// Created On : Tue Jan 17 12:27:26 2016
[6b0b624]11// Last Modified By : Peter A. Buhr
12// Last Modified On : Fri Jul 21 22:28:56 2017
13// Update Count : 1
[8def349]14//
15
[5c81105]16#include <stdbool.h>
17#include <stdint.h>
[78b3f52]18
[5c81105]19#ifdef __CFORALL__
20extern "C" {
21#endif
22
23#if ! defined(__CFA_INVOKE_PRIVATE__)
[78b3f52]24#ifndef _INVOKE_H_
25#define _INVOKE_H_
26
[596f987b]27 #define unlikely(x) __builtin_expect(!!(x), 0)
[8def349]28 #define thread_local _Thread_local
[bd98b58]29
[90c4df0]30 typedef void (*fptr_t)();
31
[db6f06a]32 struct spinlock {
33 volatile int lock;
[1c273d0]34 #ifdef __CFA_DEBUG__
[b227f68]35 const char * prev_name;
36 void* prev_thrd;
[1c273d0]37 #endif
[db6f06a]38 };
39
[5ea06d6]40 struct __thread_queue_t {
[348006f]41 struct thread_desc * head;
42 struct thread_desc ** tail;
[bd98b58]43 };
44
[0c78741]45 struct __condition_stack_t {
46 struct __condition_criterion_t * top;
[690f13c]47 };
48
[bd98b58]49 #ifdef __CFORALL__
50 extern "Cforall" {
[242a902]51 void ?{}( struct __thread_queue_t & );
[5ea06d6]52 void append( struct __thread_queue_t *, struct thread_desc * );
53 struct thread_desc * pop_head( struct __thread_queue_t * );
[90c4df0]54 struct thread_desc * remove( struct __thread_queue_t *, struct thread_desc ** );
[db6f06a]55
[242a902]56 void ?{}( struct __condition_stack_t & );
[0c78741]57 void push( struct __condition_stack_t *, struct __condition_criterion_t * );
58 struct __condition_criterion_t * pop( struct __condition_stack_t * );
[690f13c]59
[242a902]60 void ?{}(spinlock & this);
61 void ^?{}(spinlock & this);
[bd98b58]62 }
63 #endif
[596f987b]64
65 struct coStack_t {
[5ea06d6]66 unsigned int size; // size of stack
67 void *storage; // pointer to stack
68 void *limit; // stack grows towards stack limit
69 void *base; // base of stack
70 void *context; // address of cfa_context_t
71 void *top; // address of top of storage
72 bool userStack; // whether or not the user allocated the stack
[5c81105]73 };
[78b3f52]74
[ee897e4b]75 enum coroutine_state { Halted, Start, Inactive, Active, Primed };
[78b3f52]76
[c3acb841]77 struct coroutine_desc {
[5ea06d6]78 struct coStack_t stack; // stack information of the coroutine
79 const char *name; // textual name for coroutine/task, initialized by uC++ generated code
80 int errno_; // copy of global UNIX variable errno
81 enum coroutine_state state; // current execution status for coroutine
82 struct coroutine_desc *starter; // first coroutine to resume this one
83 struct coroutine_desc *last; // last coroutine to resume this one
[5c81105]84 };
[78b3f52]85
[cb0e6de]86 struct monitor_desc {
[5ea06d6]87 struct spinlock lock; // spinlock to protect internal data
88 struct thread_desc * owner; // current owner of the monitor
89 struct __thread_queue_t entry_queue; // queue of threads that are blocked waiting for the monitor
[0c78741]90 struct __condition_stack_t signal_stack; // stack of conditions to run next once we exit the monitor
[5ea06d6]91 unsigned int recursion; // monitor routines can be called recursively, we need to keep track of that
[97e3296]92
93 struct __acceptable_t * acceptables; // list of acceptable functions, null if any
94 unsigned short acceptable_count; // number of acceptable functions
95 short accepted_index; // the index of the accepted function, -1 if none
96 };
[cb0e6de]97
[348006f]98 struct thread_desc {
[90c4df0]99 // Core threading fields
[5ea06d6]100 struct coroutine_desc cor; // coroutine body used to store context
101 struct monitor_desc mon; // monitor body used for mutual exclusion
[90c4df0]102
103 // Link lists fields
[5ea06d6]104 struct thread_desc * next; // instrusive link field for threads
[90c4df0]105
106 // Current status related to monitors
[5ea06d6]107 struct monitor_desc ** current_monitors; // currently held monitors
108 unsigned short current_monitor_count; // number of currently held monitors
[90c4df0]109 fptr_t current_monitor_func; // last function that acquired monitors
[97e3296]110 };
[8118303]111
[5c81105]112#endif //_INVOKE_H_
113#else //! defined(__CFA_INVOKE_PRIVATE__)
114#ifndef _INVOKE_PRIVATE_H_
115#define _INVOKE_PRIVATE_H_
[b227f68]116
[596f987b]117 struct machine_context_t {
[5c81105]118 void *SP;
119 void *FP;
120 void *PC;
121 };
[78b3f52]122
[5c81105]123 // assembler routines that performs the context switch
[b58a5772]124 extern void CtxInvokeStub( void );
[eb2e723]125 void CtxSwitch( void * from, void * to ) asm ("CtxSwitch");
[f32e53e]126
127 #if defined( __x86_64__ )
128 #define CtxGet( ctx ) __asm__ ( \
129 "movq %%rsp,%0\n" \
130 "movq %%rbp,%1\n" \
131 : "=rm" (ctx.SP), "=rm" (ctx.FP) )
132 #elif defined( __i386__ )
133 #define CtxGet( ctx ) __asm__ ( \
134 "movl %%esp,%0\n" \
135 "movl %%ebp,%1\n" \
136 : "=rm" (ctx.SP), "=rm" (ctx.FP) )
137 #endif
[78b3f52]138
[5c81105]139#endif //_INVOKE_PRIVATE_H_
140#endif //! defined(__CFA_INVOKE_PRIVATE__)
141#ifdef __CFORALL__
142}
143#endif
[6b0b624]144
145// Local Variables: //
146// mode: c //
147// tab-width: 4 //
148// End: //
Note: See TracBrowser for help on using the repository browser.