Changes in src/libcfa/concurrency/coroutine.c [c40e7c5:b69ea6b]

File:

• src/libcfa/concurrency/coroutine.c (modified) (5 diffs)

src/libcfa/concurrency/coroutine.c

@@ -10 +10 @@
 // Created On       : Mon Nov 28 12:27:26 2016
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Fri Jul 21 22:34:57 2017
-// Update Count     : 1
+// Last Modified On : Thu Feb  8 16:10:31 2018
+// Update Count     : 4
 //
 
@@ -77 +77 @@
                 __cfaabi_dbg_debug_do(
                         if ( mprotect( this.storage, pageSize, PROT_READ | PROT_WRITE ) == -1 ) {
-                                abortf( "(coStack_t *)%p.^?{}() : internal error, mprotect failure, error(%d) %s.", &this, errno, strerror( errno ) );
+                                abort( "(coStack_t *)%p.^?{}() : internal error, mprotect failure, error(%d) %s.", &this, errno, strerror( errno ) );
                         }
                 );
@@ -99 +99 @@
 // Wrapper for co
 void CoroutineCtxSwitch(coroutine_desc* src, coroutine_desc* dst) {
-        // THREAD_GETMEM( This )->disableInterrupts();
+        verify( preemption.enabled || this_processor->do_terminate );
+        disable_interrupts();
 
         // set state of current coroutine to inactive
@@ -115 +116 @@
         src->state = Active;
 
-        // THREAD_GETMEM( This )->enableInterrupts();
+        enable_interrupts( __cfaabi_dbg_ctx );
+        verify( preemption.enabled || this_processor->do_terminate );
 } //ctxSwitchDirect
 
@@ -135 +137 @@
                 __cfaabi_dbg_debug_do(
                         if ( mprotect( storage, pageSize, PROT_NONE ) == -1 ) {
-                                abortf( "(uMachContext &)%p.createContext() : internal error, mprotect failure, error(%d) %s.", this, (int)errno, strerror( (int)errno ) );
+                                abort( "(uMachContext &)%p.createContext() : internal error, mprotect failure, error(%d) %s.", this, (int)errno, strerror( (int)errno ) );
                         } // if
                 );
 
                 if ( (intptr_t)storage == 0 ) {
-                        abortf( "Attempt to allocate %d bytes of storage for coroutine or task execution-state but insufficient memory available.", size );
+                        abort( "Attempt to allocate %zd bytes of storage for coroutine or task execution-state but insufficient memory available.", size );
                 } // if