Changeset 7768b8d for libcfa/src/concurrency/kernel.hfa

Timestamp:

Nov 26, 2019, 3:19:20 PM (5 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

30763fd

Parents:

21184e3

Message:

First step at adding the new ready queue to Cforall

File:

• libcfa/src/concurrency/kernel.hfa (modified) (3 diffs)

libcfa/src/concurrency/kernel.hfa

@@ -106 +106 @@
         // Cluster from which to get threads
         struct cluster * cltr;
+        unsigned int id;
 
         // Name of the processor
@@ -157 +158 @@
 }
 
+
+//-----------------------------------------------------------------------------
+// Cluster Tools
+struct __processor_id;
+
+// Reader-Writer lock protecting the ready-queue
+struct __clusterRWLock_t {
+        // total cachelines allocated
+        unsigned int max;
+
+        // cachelines currently in use
+        volatile unsigned int alloc;
+
+        // cachelines ready to itereate over
+        // (!= to alloc when thread is in second half of doregister)
+        volatile unsigned int ready;
+
+        // writer lock
+        volatile bool lock;
+
+        // data pointer
+        __processor_id * data;
+};
+
+void  ?{}(__clusterRWLock_t & this);
+void ^?{}(__clusterRWLock_t & this);
+
+// Underlying sub quues of the ready queue
+struct __attribute__((aligned(128))) __intrusive_ready_queue_t {
+        // spin lock protecting the queue
+        volatile bool lock;
+
+        // anchor for the head and the tail of the queue
+        struct __sentinel_t {
+                struct thread_desc * next;
+                struct thread_desc * prev;
+                unsigned long long ts;
+        } before, after;
+
+        // Optional statistic counters
+        #ifndef __CFA_NO_SCHED_STATS__
+                struct __attribute__((aligned(64))) {
+                        // difference between number of push and pops
+                        ssize_t diff;
+
+                        // total number of pushes and pops
+                        size_t  push;
+                        size_t  pop ;
+                } stat;
+        #endif
+};
+
+void  ?{}(__intrusive_ready_queue_t & this);
+void ^?{}(__intrusive_ready_queue_t & this);
+
 //-----------------------------------------------------------------------------
 // Cluster
 struct cluster {
         // Ready queue locks
-        __spinlock_t ready_queue_lock;
+        __clusterRWLock_t ready_lock;
 
         // Ready queue for threads
-        __queue_t(thread_desc) ready_queue;
+        __intrusive_ready_queue_t ready_queue;
 
         // Name of the cluster
@@ -174 +230 @@
         // List of processors
         __spinlock_t proc_list_lock;
-        __dllist_t(struct processor) procs;
         __dllist_t(struct processor) idles;
-        unsigned int nprocessors;
 
         // List of threads