Changeset 09800e9 for src/libcfa/concurrency/kernel

Timestamp:

May 29, 2018, 4:17:30 PM (6 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, with_gc

Children:

6c7099a

Parents:

8ebbfc4

Message:

First draft at locks in Cforall

File:

• src/libcfa/concurrency/kernel (modified) (1 diff)

src/libcfa/concurrency/kernel

@@ -43 +43 @@
 extern struct cluster * mainCluster;
 
-enum FinishOpCode { No_Action, Release, Schedule, Release_Schedule, Release_Multi, Release_Multi_Schedule };
+enum FinishOpCode { No_Action, Release, Schedule, Release_Schedule, Release_Multi, Release_Multi_Schedule, Callback };
+
+typedef void (*__finish_callback_fptr_t)(void);
 
 //TODO use union, many of these fields are mutually exclusive (i.e. MULTI vs NOMULTI)
 struct FinishAction {
         FinishOpCode action_code;
+        /*
+        // Union of possible actions
+        union {
+                // Option 1 : locks and threads
+                struct {
+                        // 1 thread or N thread
+                        union {
+                                thread_desc * thrd;
+                                struct {
+                                        thread_desc ** thrds;
+                                        unsigned short thrd_count;
+                                };
+                        };
+                        // 1 lock or N lock
+                        union {
+                                __spinlock_t * lock;
+                                struct {
+                                        __spinlock_t ** locks;
+                                        unsigned short lock_count;
+                                };
+                        };
+                };
+                // Option 2 : action pointer
+                __finish_callback_fptr_t callback;
+        };
+        /*/
         thread_desc * thrd;
+        thread_desc ** thrds;
+        unsigned short thrd_count;
         __spinlock_t * lock;
         __spinlock_t ** locks;
         unsigned short lock_count;
-        thread_desc ** thrds;
-        unsigned short thrd_count;
+        __finish_callback_fptr_t callback;
+        //*/
 };
 static inline void ?{}(FinishAction & this) {