source: src/libcfa/concurrency/invoke.h@ cb0e6de

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 cb0e6de was cb0e6de, checked in by Thierry Delisle <tdelisle@…>, 9 years ago

Threads now use monitor semantics to wait until completion

  • Property mode set to 100644
File size: 3.7 KB
Line 
1// -*- Mode: C -*-
2//
3// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
4//
5// The contents of this file are covered under the licence agreement in the
6// file "LICENCE" distributed with Cforall.
7//
8// invoke.h --
9//
10// Author : Thierry Delisle
11// Created On : Tue Jan 17 12:27:26 2016
12// Last Modified By : Thierry Delisle
13// Last Modified On : --
14// Update Count : 0
15//
16
17#include <stdbool.h>
18#include <stdint.h>
19
20#ifdef __CFORALL__
21extern "C" {
22#endif
23
24#if ! defined(__CFA_INVOKE_PRIVATE__)
25#ifndef _INVOKE_H_
26#define _INVOKE_H_
27
28 #define unlikely(x) __builtin_expect(!!(x), 0)
29 #define thread_local _Thread_local
30
31 struct spinlock {
32 volatile int lock;
33 };
34
35 struct simple_thread_list {
36 struct thread_desc * head;
37 struct thread_desc ** tail;
38 };
39
40 struct signal_once {
41 volatile bool condition;
42 struct spinlock lock;
43 struct simple_thread_list blocked;
44 };
45
46 #ifdef __CFORALL__
47 extern "Cforall" {
48 void ?{}( struct simple_thread_list * );
49 void append( struct simple_thread_list *, struct thread_desc * );
50 struct thread_desc * pop_head( struct simple_thread_list * );
51
52 void ?{}(spinlock * this);
53 void ^?{}(spinlock * this);
54
55 void ?{}(signal_once * this);
56 void ^?{}(signal_once * this);
57 }
58 #endif
59
60 struct coStack_t {
61 unsigned int size; // size of stack
62 void *storage; // pointer to stack
63 void *limit; // stack grows towards stack limit
64 void *base; // base of stack
65 void *context; // address of cfa_context_t
66 void *top; // address of top of storage
67 bool userStack; // whether or not the user allocated the stack
68 };
69
70 enum coroutine_state { Halted, Start, Inactive, Active, Primed };
71
72 struct coroutine_desc {
73 struct coStack_t stack; // stack information of the coroutine
74 const char *name; // textual name for coroutine/task, initialized by uC++ generated code
75 int errno_; // copy of global UNIX variable errno
76 enum coroutine_state state; // current execution status for coroutine
77 struct coroutine_desc *starter; // first coroutine to resume this one
78 struct coroutine_desc *last; // last coroutine to resume this one
79 };
80
81 struct monitor_desc {
82 struct spinlock lock;
83 struct thread_desc * owner;
84 struct simple_thread_list entry_queue;
85 unsigned int recursion;
86 };
87
88 struct thread_desc {
89 struct coroutine_desc cor; // coroutine body used to store context
90 struct monitor_desc mon;
91 struct signal_once terminated; // indicate if execuation state is not halted
92 struct thread_desc * next; // instrusive link field for threads
93 };
94
95#endif //_INVOKE_H_
96#else //! defined(__CFA_INVOKE_PRIVATE__)
97#ifndef _INVOKE_PRIVATE_H_
98#define _INVOKE_PRIVATE_H_
99
100 struct machine_context_t {
101 void *SP;
102 void *FP;
103 void *PC;
104 };
105
106 // assembler routines that performs the context switch
107 extern void CtxInvokeStub( void );
108 void CtxSwitch( void * from, void * to ) asm ("CtxSwitch");
109 void CtxGet( void * this ) asm ("CtxGet");
110
111#endif //_INVOKE_PRIVATE_H_
112#endif //! defined(__CFA_INVOKE_PRIVATE__)
113#ifdef __CFORALL__
114}
115#endif
Note: See TracBrowser for help on using the repository browser.