Changeset 69914cbc for libcfa/src/concurrency

Timestamp:

May 12, 2021, 4:30:27 PM (4 years ago)

Author:

Michael Brooks <mlbrooks@…>

Branches:

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

Children:

e2f601f

Parents:

67b421c

Message:

Replacing "Mike's old linked list" with "Mike's new linked list," including replatforming uses of the old one.

libcfa/src/containers/list.hfa ---[becomes]--> tests/zombies/linked-list-perf/mike-old.hfa
libcfa/src/containers/list2.hfa ---[becomes]--> libcfa/src/containers/list.hfa

There are no more multiple versions of "Mike's list" in libcfa, nor tests thereof.

The libcfa concurrency uses (alarm, kernel and ready_queue) are hereby ported to "Mike's new."

A best-effort port of executor, which was found not compiling with errors that seem unrelated to the linked list, is attempted too.

Location:

libcfa/src/concurrency

Files:

• alarm.hfa (modified) (3 diffs)
• kernel.cfa (modified) (1 diff)
• kernel.hfa (modified) (4 diffs)
• ready_queue.cfa (modified) (1 diff)

libcfa/src/concurrency/alarm.hfa

@@ -49 +49 @@
         Duration period;                        // if > 0 => period of alarm
 
-        DLISTED_MGD_IMPL_IN(alarm_node_t)
+        inline dlink(alarm_node_t);
 
         union {
@@ -60 +60 @@
         enum alarm_type type;           // true if this is not a user defined alarm
 };
-DLISTED_MGD_IMPL_OUT(alarm_node_t)
+P9_EMBEDDED( alarm_node_t, dlink(alarm_node_t) )
 
 void ?{}( alarm_node_t & this, $thread * thrd, Time alarm, Duration period );
@@ -67 +67 @@
 void ^?{}( alarm_node_t & this );
 
-typedef dlist(alarm_node_t, alarm_node_t) alarm_list_t;
+typedef dlist(alarm_node_t) alarm_list_t;
 
 void insert( alarm_list_t * this, alarm_node_t * n );

libcfa/src/concurrency/kernel.cfa

@@ -908 +908 @@
         }
 
-        static void crawl_list( cluster * cltr, dlist(processor, processor) & list, unsigned count ) {
+        static void crawl_list( cluster * cltr, dlist(processor) & list, unsigned count ) {
                 /* paranoid */ verify( cltr->stats );
 

libcfa/src/concurrency/kernel.hfa

@@ -107 +107 @@
 
         // Link lists fields
-        DLISTED_MGD_IMPL_IN(processor)
+        inline dlink(processor);
 
         // special init fields
@@ -129 +129 @@
 #endif
 };
+P9_EMBEDDED( processor, dlink(processor) )
 
 void  ?{}(processor & this, const char name[], struct cluster & cltr);
@@ -136 +137 @@
 static inline void  ?{}(processor & this, struct cluster & cltr) { this{ "Anonymous Processor", cltr}; }
 static inline void  ?{}(processor & this, const char name[])     { this{name, *mainCluster}; }
-
-DLISTED_MGD_IMPL_OUT(processor)
 
 //-----------------------------------------------------------------------------
@@ -186 +185 @@
 
         // List of idle processors
-        dlist(processor, processor) idles;
+        dlist(processor) idles;
 
         // List of active processors
-        dlist(processor, processor) actives;
+        dlist(processor) actives;
 };
 

libcfa/src/concurrency/ready_queue.cfa

@@ -554 +554 @@
 }
 
-static void assign_list(unsigned & value, dlist(processor, processor) & list, unsigned count) {
+static void assign_list(unsigned & value, dlist(processor) & list, unsigned count) {
         processor * it = &list`first;
         for(unsigned i = 0; i < count; i++) {