Changes in / [b6ec245:6e0f4bd]

Location:

src/libcfa/concurrency

Files:

• invoke.h (modified) (1 diff)
• kernel.c (modified) (1 diff)
• kernel_private.h (modified) (1 diff)
• thread.c (modified) (2 diffs)

src/libcfa/concurrency/invoke.h

@@ -134 +134 @@
                 // instrusive link field for threads
                 struct thread_desc * next;
+
+                __cfaabi_dbg_debug_do(
+                        // instrusive link field for debugging
+                        struct thread_desc * dbg_next;
+                        struct thread_desc * dbg_prev;
+                )
      };
 

src/libcfa/concurrency/kernel.c

@@ -611 +611 @@
 }
 
+//-----------------------------------------------------------------------------
+// Debug
+__cfaabi_dbg_debug_do(
+        struct {
+                thread_desc * tail;
+        } __cfaabi_dbg_thread_list = { NULL };
+
+        void __cfaabi_dbg_thread_register( thread_desc * thrd ) {
+                if( !__cfaabi_dbg_thread_list.tail ) {
+                        __cfaabi_dbg_thread_list.tail = thrd;
+                        return;
+                }
+                __cfaabi_dbg_thread_list.tail->dbg_next = thrd;
+                thrd->dbg_prev = __cfaabi_dbg_thread_list.tail;
+                __cfaabi_dbg_thread_list.tail = thrd;
+        }
+
+        void __cfaabi_dbg_thread_unregister( thread_desc * thrd ) {
+                thread_desc * prev = thrd->dbg_prev;
+                thread_desc * next = thrd->dbg_next;
+
+                if( next ) { next->dbg_prev = prev; }
+                else       {
+                        assert( __cfaabi_dbg_thread_list.tail == thrd );
+                        __cfaabi_dbg_thread_list.tail = prev;
+                }
+
+                if( prev ) { prev->dbg_next = next; }
+
+                thrd->dbg_prev = NULL;
+                thrd->dbg_next = NULL;
+        }
+)
 // Local Variables: //
 // mode: c //

src/libcfa/concurrency/kernel_private.h

@@ -85 +85 @@
 extern void ThreadCtxSwitch(coroutine_desc * src, coroutine_desc * dst);
 
+__cfaabi_dbg_debug_do(
+        extern void __cfaabi_dbg_thread_register  ( thread_desc * thrd );
+        extern void __cfaabi_dbg_thread_unregister( thread_desc * thrd );
+)
+
 //-----------------------------------------------------------------------------
 // Utils

src/libcfa/concurrency/thread.c

@@ -33 +33 @@
 void ?{}(thread_desc& this) {
         (this.self_cor){};
-        this.self_cor.name = "Anonymous Coroutine";
+        this.self_cor.name = "Anonymous Thread";
         this.self_mon.owner = &this;
         this.self_mon.recursion = 1;
         this.self_mon_p = &this.self_mon;
         this.next = NULL;
+        __cfaabi_dbg_debug_do(
+                this.dbg_next = NULL;
+                this.dbg_prev = NULL;
+                __cfaabi_dbg_thread_register(&this);
+        )
 
         (this.monitors){ &this.self_mon_p, 1, (fptr_t)0 };
@@ -43 +48 @@
 
 void ^?{}(thread_desc& this) {
+        __cfaabi_dbg_debug_do(
+                __cfaabi_dbg_thread_unregister(&this);
+        )
         ^(this.self_cor){};
 }