source: src/libcfa/concurrency/coroutine @ 9236060

aaron-thesisarm-ehcleanup-dtorsdeferred_resndemanglerjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerresolv-newwith_gc
Last change on this file since 9236060 was 9236060, checked in by Rob Schluntz <rschlunt@…>, 4 years ago

Merge branch 'master' into references

  • Property mode set to 100644
File size: 4.1 KB
Line 
1//                              - *- Mode: CFA - *-
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// coroutine --
9//
10// Author           : Thierry Delisle
11// Created On       : Mon Nov 28 12:27:26 2016
12// Last Modified By : Peter A. Buhr
13// Last Modified On : Sat Jul 22 09:57:17 2017
14// Update Count     : 2
15//
16
17#pragma once
18
19#include <assert.h>
20#include "invoke.h"
21
22//-----------------------------------------------------------------------------
23// Coroutine trait
24// Anything that implements this trait can be resumed.
25// Anything that is resumed is a coroutine.
26trait is_coroutine(dtype T) {
27      void main(T & this);
28      coroutine_desc * get_coroutine(T & this);
29};
30
31#define DECL_COROUTINE(X) static inline coroutine_desc* get_coroutine(X& this) { return &this.__cor; } void main(X& this)
32
33//-----------------------------------------------------------------------------
34// Ctors and dtors
35void ?{}(coStack_t & this);
36void ?{}(coroutine_desc & this);
37void ?{}(coroutine_desc & this, const char * name);
38void ^?{}(coStack_t & this);
39void ^?{}(coroutine_desc & this);
40
41//-----------------------------------------------------------------------------
42// Public coroutine API
43static inline void suspend();
44
45forall(dtype T | is_coroutine(T))
46static inline void resume(T & cor);
47
48forall(dtype T | is_coroutine(T))
49void prime(T & cor);
50
51//-----------------------------------------------------------------------------
52// PRIVATE exposed because of inline
53
54// Start coroutine routines
55extern "C" {
56      forall(dtype T | is_coroutine(T))
57      void CtxInvokeCoroutine(T * this);
58
59      forall(dtype T | is_coroutine(T))
60      void CtxStart(T * this, void ( *invoke)(T *));
61}
62
63// Get current coroutine
64extern thread_local coroutine_desc * volatile this_coroutine;
65
66// Private wrappers for context switch and stack creation
67extern void CoroutineCtxSwitch(coroutine_desc * src, coroutine_desc * dst);
68extern void create_stack( coStack_t * this, unsigned int storageSize );
69
70// Suspend implementation inlined for performance
71static inline void suspend() {
72        coroutine_desc * src = this_coroutine;          // optimization
73
74        assertf( src->last != 0,
75                "Attempt to suspend coroutine \"%.256s\" (%p) that has never been resumed.\n"
76                "Possible cause is a suspend executed in a member called by a coroutine user rather than by the coroutine main.",
77                src->name, src );
78        assertf( src->last->state != Halted,
79                "Attempt by coroutine \"%.256s\" (%p) to suspend back to terminated coroutine \"%.256s\" (%p).\n"
80                "Possible cause is terminated coroutine's main routine has already returned.",
81                src->name, src, src->last->name, src->last );
82
83        CoroutineCtxSwitch( src, src->last );
84}
85
86// Resume implementation inlined for performance
87forall(dtype T | is_coroutine(T))
88static inline void resume(T & cor) {
89        coroutine_desc * src = this_coroutine;          // optimization
90        coroutine_desc * dst = get_coroutine(cor);
91
92        if( unlikely(!dst->stack.base) ) {
93                create_stack(&dst->stack, dst->stack.size);
94                CtxStart(&cor, CtxInvokeCoroutine);
95        }
96
97        // not resuming self ?
98        if ( src != dst ) {
99                assertf( dst->state != Halted ,
100                        "Attempt by coroutine %.256s (%p) to resume terminated coroutine %.256s (%p).\n"
101                        "Possible cause is terminated coroutine's main routine has already returned.",
102                        src->name, src, dst->name, dst );
103
104                // set last resumer
105                dst->last = src;
106        } // if
107
108        // always done for performance testing
109        CoroutineCtxSwitch( src, dst );
110}
111
112static inline void resume(coroutine_desc * dst) {
113        coroutine_desc * src = this_coroutine;          // optimization
114
115        // not resuming self ?
116        if ( src != dst ) {
117                assertf( dst->state != Halted ,
118                        "Attempt by coroutine %.256s (%p) to resume terminated coroutine %.256s (%p).\n"
119                        "Possible cause is terminated coroutine's main routine has already returned.",
120                        src->name, src, dst->name, dst );
121
122                // set last resumer
123                dst->last = src;
124        } // if
125
126        // always done for performance testing
127        CoroutineCtxSwitch( src, dst );
128}
129
130// Local Variables: //
131// mode: c //
132// tab-width: 4 //
133// End: //
Note: See TracBrowser for help on using the repository browser.