- File:
-
- 1 edited
-
src/libcfa/concurrency/coroutine.c (modified) (3 diffs)
Legend:
- Unmodified
- Added
- Removed
-
src/libcfa/concurrency/coroutine.c
rde6319f rb10affd 39 39 //----------------------------------------------------------------------------- 40 40 // Coroutine ctors and dtors 41 void ?{}( coStack_t & this, void * storage, size_t storageSize ) with( this ) { 42 size = storageSize == 0 ? 65000 : storageSize; // size of stack 43 this.storage = storage; // pointer to stack 44 limit = NULL; // stack grows towards stack limit 45 base = NULL; // base of stack 46 context = NULL; // address of cfa_context_t 47 top = NULL; // address of top of storage 48 userStack = storage != NULL; 41 void ?{}(coStack_t& this) with( this ) { 42 size = 65000; // size of stack 43 storage = NULL; // pointer to stack 44 limit = NULL; // stack grows towards stack limit 45 base = NULL; // base of stack 46 context = NULL; // address of cfa_context_t 47 top = NULL; // address of top of storage 48 userStack = false; 49 } 50 51 void ?{}(coStack_t& this, size_t size) { 52 this{}; 53 this.size = size; 54 55 create_stack(&this, this.size); 56 } 57 58 void ?{}(coroutine_desc& this) { 59 this{ "Anonymous Coroutine" }; 60 } 61 62 void ?{}(coroutine_desc& this, const char * name) with( this ) { 63 this.name = name; 64 errno_ = 0; 65 state = Start; 66 starter = NULL; 67 last = NULL; 68 } 69 70 void ?{}(coroutine_desc& this, size_t size) { 71 this{}; 72 (this.stack){size}; 49 73 } 50 74 51 75 void ^?{}(coStack_t & this) { 52 if ( ! this.userStack && this.storage ) { 53 __cfaabi_dbg_debug_do( 54 if ( mprotect( this.storage, pageSize, PROT_READ | PROT_WRITE ) == -1 ) { 55 abort( "(coStack_t *)%p.^?{}() : internal error, mprotect failure, error(%d) %s.", &this, errno, strerror( errno ) ); 56 } 57 ); 58 free( this.storage ); 59 } 60 } 61 62 void ?{}( coroutine_desc & this, const char * name, void * storage, size_t storageSize ) with( this ) { 63 (this.stack){storage, storageSize}; 64 this.name = name; 65 errno_ = 0; 66 state = Start; 67 starter = NULL; 68 last = NULL; 76 if ( ! this.userStack && this.storage ) { 77 __cfaabi_dbg_debug_do( 78 if ( mprotect( this.storage, pageSize, PROT_READ | PROT_WRITE ) == -1 ) { 79 abort( "(coStack_t *)%p.^?{}() : internal error, mprotect failure, error(%d) %s.", &this, errno, strerror( errno ) ); 80 } 81 ); 82 free( this.storage ); 83 } 69 84 } 70 85 … … 75 90 forall(dtype T | is_coroutine(T)) 76 91 void prime(T& cor) { 77 78 92 coroutine_desc* this = get_coroutine(cor); 93 assert(this->state == Start); 79 94 80 81 95 this->state = Primed; 96 resume(cor); 82 97 } 83 98 84 99 // Wrapper for co 85 100 void CoroutineCtxSwitch(coroutine_desc* src, coroutine_desc* dst) { 86 87 101 verify( TL_GET( preemption_state ).enabled || TL_GET( this_processor )->do_terminate ); 102 disable_interrupts(); 88 103 89 90 104 // set state of current coroutine to inactive 105 src->state = src->state == Halted ? Halted : Inactive; 91 106 92 93 107 // set new coroutine that task is executing 108 TL_SET( this_coroutine, dst ); 94 109 95 96 97 98 110 // context switch to specified coroutine 111 assert( src->stack.context ); 112 CtxSwitch( src->stack.context, dst->stack.context ); 113 // when CtxSwitch returns we are back in the src coroutine 99 114 100 101 115 // set state of new coroutine to active 116 src->state = Active; 102 117 103 104 118 enable_interrupts( __cfaabi_dbg_ctx ); 119 verify( TL_GET( preemption_state ).enabled || TL_GET( this_processor )->do_terminate ); 105 120 } //ctxSwitchDirect 106 121 107 122 void create_stack( coStack_t* this, unsigned int storageSize ) with( *this ) { 108 109 123 //TEMP HACK do this on proper kernel startup 124 if(pageSize == 0ul) pageSize = sysconf( _SC_PAGESIZE ); 110 125 111 126 size_t cxtSize = libCeiling( sizeof(machine_context_t), 8 ); // minimum alignment 112 127 113 if ( !storage ) { 114 __cfaabi_dbg_print_safe("Kernel : Creating stack of size %zu for stack obj %p\n", cxtSize + size + 8, this); 128 if ( (intptr_t)storage == 0 ) { 129 userStack = false; 130 size = libCeiling( storageSize, 16 ); 131 // use malloc/memalign because "new" raises an exception for out-of-memory 115 132 116 userStack = false; 117 size = libCeiling( storageSize, 16);118 // use malloc/memalign because "new" raises an exception for out-of-memory 133 // assume malloc has 8 byte alignment so add 8 to allow rounding up to 16 byte alignment 134 __cfaabi_dbg_debug_do( storage = memalign( pageSize, cxtSize + size + pageSize ) ); 135 __cfaabi_dbg_no_debug_do( storage = malloc( cxtSize + size + 8 ) ); 119 136 120 // assume malloc has 8 byte alignment so add 8 to allow rounding up to 16 byte alignment 121 __cfaabi_dbg_debug_do( storage = memalign( pageSize, cxtSize + size + pageSize ) ); 122 __cfaabi_dbg_no_debug_do( storage = malloc( cxtSize + size + 8 ) ); 137 __cfaabi_dbg_debug_do( 138 if ( mprotect( storage, pageSize, PROT_NONE ) == -1 ) { 139 abort( "(uMachContext &)%p.createContext() : internal error, mprotect failure, error(%d) %s.", this, (int)errno, strerror( (int)errno ) ); 140 } // if 141 ); 123 142 124 __cfaabi_dbg_debug_do( 125 if ( mprotect( storage, pageSize, PROT_NONE ) == -1 ) { 126 abort( "(uMachContext &)%p.createContext() : internal error, mprotect failure, error(%d) %s.", this, (int)errno, strerror( (int)errno ) ); 127 } // if 128 ); 143 if ( (intptr_t)storage == 0 ) { 144 abort( "Attempt to allocate %zd bytes of storage for coroutine or task execution-state but insufficient memory available.", size ); 145 } // if 129 146 130 if ( (intptr_t)storage == 0 ) { 131 abort( "Attempt to allocate %zd bytes of storage for coroutine or task execution-state but insufficient memory available.", size ); 132 } // if 147 __cfaabi_dbg_debug_do( limit = (char *)storage + pageSize ); 148 __cfaabi_dbg_no_debug_do( limit = (char *)libCeiling( (unsigned long)storage, 16 ) ); // minimum alignment 133 149 134 __cfaabi_dbg_debug_do( limit = (char *)storage + pageSize ); 135 __cfaabi_dbg_no_debug_do( limit = (char *)libCeiling( (unsigned long)storage, 16 ) ); // minimum alignment 150 } else { 151 assertf( ((size_t)storage & (libAlign() - 1)) != 0ul, "Stack storage %p for task/coroutine must be aligned on %d byte boundary.", storage, (int)libAlign() ); 152 userStack = true; 153 size = storageSize - cxtSize; 136 154 137 } else { 138 __cfaabi_dbg_print_safe("Kernel : stack obj %p using user stack %p(%u bytes)\n", this, storage, storageSize); 155 if ( size % 16 != 0u ) size -= 8; 139 156 140 assertf( ((size_t)storage & (libAlign() - 1)) == 0ul, "Stack storage %p for task/coroutine must be aligned on %d byte boundary.", storage, (int)libAlign() ); 141 userStack = true; 142 size = storageSize - cxtSize;157 limit = (char *)libCeiling( (unsigned long)storage, 16 ); // minimum alignment 158 } // if 159 assertf( size >= MinStackSize, "Stack size %zd provides less than minimum of %d bytes for a stack.", size, MinStackSize ); 143 160 144 if ( size % 16 != 0u ) size -= 8; 145 146 limit = (char *)libCeiling( (unsigned long)storage, 16 ); // minimum alignment 147 } // if 148 assertf( size >= MinStackSize, "Stack size %zd provides less than minimum of %d bytes for a stack.", size, MinStackSize ); 149 150 base = (char *)limit + size; 151 context = base; 152 top = (char *)context + cxtSize; 161 base = (char *)limit + size; 162 context = base; 163 top = (char *)context + cxtSize; 153 164 } 154 165 … … 156 167 // is not inline (We can't inline Cforall in C) 157 168 extern "C" { 158 159 160 169 void __suspend_internal(void) { 170 suspend(); 171 } 161 172 162 163 173 void __leave_coroutine(void) { 174 coroutine_desc * src = TL_GET( this_coroutine ); // optimization 164 175 165 166 167 168 169 170 171 172 176 assertf( src->starter != 0, 177 "Attempt to suspend/leave coroutine \"%.256s\" (%p) that has never been resumed.\n" 178 "Possible cause is a suspend executed in a member called by a coroutine user rather than by the coroutine main.", 179 src->name, src ); 180 assertf( src->starter->state != Halted, 181 "Attempt by coroutine \"%.256s\" (%p) to suspend/leave back to terminated coroutine \"%.256s\" (%p).\n" 182 "Possible cause is terminated coroutine's main routine has already returned.", 183 src->name, src, src->starter->name, src->starter ); 173 184 174 175 185 CoroutineCtxSwitch( src, src->starter ); 186 } 176 187 } 177 188
Note:
See TracChangeset
for help on using the changeset viewer.
