source: src/libcfa/concurrency/invoke.h@ 0fc9756b

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 0fc9756b was f32e53e, checked in by Thierry Delisle <tdelisle@…>, 8 years ago

Converted CtxGet from asm function to asm statement for more robustness, should fix full build
  • Property mode set to 100644
File size: 4.9 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 __thread_queue_t {
36 struct thread_desc * head;
37 struct thread_desc ** tail;
38 };
39
40 struct __condition_stack_t {
41 struct __condition_criterion_t * top;
42 };
43
44 #ifdef __CFORALL__
45 extern "Cforall" {
46 void ?{}( struct __thread_queue_t * );
47 void append( struct __thread_queue_t *, struct thread_desc * );
48 struct thread_desc * pop_head( struct __thread_queue_t * );
49
50 void ?{}( struct __condition_stack_t * );
51 void push( struct __condition_stack_t *, struct __condition_criterion_t * );
52 struct __condition_criterion_t * pop( struct __condition_stack_t * );
53
54 void ?{}(spinlock * this);
55 void ^?{}(spinlock * this);
56 }
57 #endif
58
59 struct coStack_t {
60 unsigned int size; // size of stack
61 void *storage; // pointer to stack
62 void *limit; // stack grows towards stack limit
63 void *base; // base of stack
64 void *context; // address of cfa_context_t
65 void *top; // address of top of storage
66 bool userStack; // whether or not the user allocated the stack
67 };
68
69 enum coroutine_state { Halted, Start, Inactive, Active, Primed };
70
71 struct coroutine_desc {
72 struct coStack_t stack; // stack information of the coroutine
73 const char *name; // textual name for coroutine/task, initialized by uC++ generated code
74 int errno_; // copy of global UNIX variable errno
75 enum coroutine_state state; // current execution status for coroutine
76 struct coroutine_desc *starter; // first coroutine to resume this one
77 struct coroutine_desc *last; // last coroutine to resume this one
78 };
79
80 struct monitor_desc {
81 struct spinlock lock; // spinlock to protect internal data
82 struct thread_desc * owner; // current owner of the monitor
83 struct __thread_queue_t entry_queue; // queue of threads that are blocked waiting for the monitor
84 struct __condition_stack_t signal_stack; // stack of conditions to run next once we exit the monitor
85 struct monitor_desc * stack_owner; // if bulk acquiring was used we need to synchronize signals with an other monitor
86 unsigned int recursion; // monitor routines can be called recursively, we need to keep track of that
87 };
88
89 struct thread_desc {
90 struct coroutine_desc cor; // coroutine body used to store context
91 struct monitor_desc mon; // monitor body used for mutual exclusion
92 struct thread_desc * next; // instrusive link field for threads
93 struct monitor_desc ** current_monitors; // currently held monitors
94 unsigned short current_monitor_count; // number of currently held monitors
95 };
96
97#endif //_INVOKE_H_
98#else //! defined(__CFA_INVOKE_PRIVATE__)
99#ifndef _INVOKE_PRIVATE_H_
100#define _INVOKE_PRIVATE_H_
101
102 struct machine_context_t {
103 void *SP;
104 void *FP;
105 void *PC;
106 };
107
108 // assembler routines that performs the context switch
109 extern void CtxInvokeStub( void );
110 void CtxSwitch( void * from, void * to ) asm ("CtxSwitch");
111
112 #if defined( __x86_64__ )
113 #define CtxGet( ctx ) __asm__ ( \
114 "movq %%rsp,%0\n" \
115 "movq %%rbp,%1\n" \
116 : "=rm" (ctx.SP), "=rm" (ctx.FP) )
117 #elif defined( __i386__ )
118 #define CtxGet( ctx ) __asm__ ( \
119 "movl %%esp,%0\n" \
120 "movl %%ebp,%1\n" \
121 : "=rm" (ctx.SP), "=rm" (ctx.FP) )
122 #endif
123
124#endif //_INVOKE_PRIVATE_H_
125#endif //! defined(__CFA_INVOKE_PRIVATE__)
126#ifdef __CFORALL__
127}
128#endif
Note: See TracBrowser for help on using the repository browser.