Changes in libcfa/src/concurrency/thread.cfa [5456537:fd54fef]

File:

• libcfa/src/concurrency/thread.cfa (modified) (7 diffs)

libcfa/src/concurrency/thread.cfa

@@ -39 +39 @@
         link.next = 0p;
         link.prev = 0p;
+        link.preferred = -1;
         #if defined( __CFA_WITH_VERIFY__ )
                 canary = 0x0D15EA5E0D15EA5Ep;
@@ -61 +62 @@
 }
 
+FORALL_DATA_INSTANCE(ThreadCancelled, (thread_t &), (thread_t))
+
 forall(T &)
 void copy(ThreadCancelled(T) * dst, ThreadCancelled(T) * src) {
@@ -70 +73 @@
 forall(T &)
 const char * msg(ThreadCancelled(T) *) {
-        return "ThreadCancelled(...)";
+        return "ThreadCancelled";
 }
 
 forall(T &)
 static void default_thread_cancel_handler(ThreadCancelled(T) & ) {
-        // Improve this error message, can I do formatting?
         abort( "Unhandled thread cancellation.\n" );
 }
 
-forall(T & | is_thread(T) | IS_EXCEPTION(ThreadCancelled, (T))
-    | { EHM_DEFAULT_VTABLE(ThreadCancelled, (T)); })
+forall(T & | is_thread(T) | IS_EXCEPTION(ThreadCancelled, (T)))
 void ?{}( thread_dtor_guard_t & this,
                 T & thrd, void(*cancelHandler)(ThreadCancelled(T) &)) {
-        $monitor * m = get_monitor(thrd);
+        $monitor * m = get_monitor(thrd);
         $thread * desc = get_thread(thrd);
 
@@ -102 +103 @@
         }
         desc->state = Cancelled;
-        void(*defaultResumptionHandler)(ThreadCancelled(T) &) =
+        void(*defaultResumptionHandler)(ThreadCancelled(T) &) = 
                 join ? cancelHandler : default_thread_cancel_handler;
 
+        ThreadCancelled(T) except;
         // TODO: Remove explitate vtable set once trac#186 is fixed.
-        ThreadCancelled(T) except;
-        except.virtual_table = &_default_vtable;
+        except.virtual_table = &get_exception_vtable(&except);
         except.the_thread = &thrd;
         except.the_exception = __cfaehm_cancellation_exception( cancellation );
-        // Why is this cast required?
-        throwResume (ThreadCancelled(T) &)except;
+        throwResume except;
 
         except.the_exception->virtual_table->free( except.the_exception );
@@ -134 +134 @@
         /* paranoid */ verify( this_thrd->context.SP );
 
-        schedule_thread$( this_thrd );
-        enable_interrupts();
+        __schedule_thread( this_thrd );
+        enable_interrupts( __cfaabi_dbg_ctx );
 }
 
@@ -158 +158 @@
 
 //-----------------------------------------------------------------------------
-forall(T & | is_thread(T) | IS_RESUMPTION_EXCEPTION(ThreadCancelled, (T))
-    | { EHM_DEFAULT_VTABLE(ThreadCancelled, (T)); })
+forall(T & | is_thread(T) | IS_RESUMPTION_EXCEPTION(ThreadCancelled, (T)))
 T & join( T & this ) {
         thread_dtor_guard_t guard = { this, defaultResumptionHandler };
@@ -168 +167 @@
         disable_interrupts();
         uint64_t ret = __tls_rand();
-        enable_interrupts();
+        enable_interrupts( __cfaabi_dbg_ctx );
         return ret;
 }