Changeset 34d194c

Timestamp:

Jul 5, 2026, 11:13:26 PM (4 days ago)

Author:

Peter A. Buhr <pabuhr@…>

Branches:

master

Children:

97c75bf

Parents:

3859adb

git-author:

Peter A. Buhr <pabuhr@…> (07/05/26 23:05:57)

git-committer:

Peter A. Buhr <pabuhr@…> (07/05/26 23:13:26)

Message:

move libcfa/src/concurrency/atomic.hfa to libcfa/src/bits/atomic.hfa, and update all the atomic operations

Location:

libcfa/src

Files:

• Makefile.am (modified) (2 diffs)
• bits/atomic.hfa (added)
• bits/defs.hfa (modified) (2 diffs)
• bits/locks.hfa (modified) (2 diffs)
• concurrency/atomic.hfa (deleted)
• concurrency/kernel/fwd.hfa (modified) (1 diff)
• concurrency/locks.hfa (modified) (2 diffs)
• heap.cfa (modified) (7 diffs)

libcfa/src/Makefile.am

@@ -11 +11 @@
 ## Created On       : Sun May 31 08:54:01 2015
 ## Last Modified By : Peter A. Buhr
-## Last Modified On : Wed Nov  1 19:03:42 2023
-## Update Count     : 266
+## Last Modified On : Sat Jul  4 07:27:10 2026
+## Update Count     : 267
 ###############################################################################
 
@@ -60 +60 @@
         bits/queue.hfa \
         bits/sequence.hfa \
-        concurrency/atomic.hfa \
+        bits/atomic.hfa \
         concurrency/iofwd.hfa \
         concurrency/barrier.hfa \

libcfa/src/bits/defs.hfa

@@ -13 +13 @@
 // Created On       : Thu Nov  9 13:24:10 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Mon Oct 27 22:40:05 2025
-// Update Count     : 23
+// Last Modified On : Sat Jul  4 15:04:20 2026
+// Update Count     : 26
 //
 
@@ -68 +68 @@
 #endif
 
-static inline long long int rdtscl(void) {
-        #if defined( __i386 ) || defined( __x86_64 )
-        unsigned int lo, hi;
-        __asm__ __volatile__ ("rdtsc" : "=a"(lo), "=d"(hi));
-        return ( (unsigned long long)lo)|( ((unsigned long long)hi)<<32 );
-        #elif defined( __aarch64__ ) || defined( __arm__ )
-        // https://github.com/google/benchmark/blob/v1.1.0/src/cycleclock.h#L116
-        long long int virtual_timer_value;
-        asm volatile("mrs %0, cntvct_el0" : "=r"(virtual_timer_value));
-        return virtual_timer_value;
-        #else
-                #error unsupported hardware architecture
-        #endif
-}
-
-// pause to prevent excess processor bus usage
-#if defined( __i386 ) || defined( __x86_64 )
-        #define Pause() __asm__ __volatile__ ( "pause" : : : )
-#elif defined( __ARM_ARCH )
-        #define Pause() __asm__ __volatile__ ( "YIELD" : : : )
-#else
-        #error unsupported architecture
-#endif
-
 #define CFA_IO_LAZY (1_l64u << 32_l64u)

libcfa/src/bits/locks.hfa

@@ -13 +13 @@
 // Created On       : Tue Oct 31 15:14:38 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Tue Sep 20 22:09:50 2022
-// Update Count     : 18
+// Last Modified On : Sat Jul  4 06:50:46 2026
+// Update Count     : 21
 //
 
@@ -21 +21 @@
 #include "bits/debug.hfa"
 #include "bits/defs.hfa"
+#include "bits/atomic.hfa"
 #include <assert.h>
 

libcfa/src/concurrency/kernel/fwd.hfa

@@ -19 +19 @@
 #include "bits/defs.hfa"
 #include "bits/debug.hfa"
+#include "bits/atomic.hfa"                                                              // Pause
 
 #ifdef __cforall

libcfa/src/concurrency/locks.hfa

@@ -11 +11 @@
 // Created On       : Thu Jan 21 19:46:50 2021
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Sun Mar 29 22:46:39 2026
-// Update Count     : 68
+// Last Modified On : Sat Jul  4 06:52:06 2026
+// Update Count     : 70
 //
 
@@ -21 +21 @@
 
 #include "bits/weakso_locks.hfa"
+#include "bits/atomic.hfa"
 #include "collections/lockfree.hfa"
 #include "collections/list.hfa"

libcfa/src/heap.cfa

@@ -10 +10 @@
 // Created On       : Tue Dec 19 21:58:35 2017
 // Last Modified By : Peter A. Buhr
-// Last Modified On : Thu May 15 16:47:35 2025
-// Update Count     : 1647
+// Last Modified On : Sat Jul  4 16:17:06 2026
+// Update Count     : 1658
 //
 
@@ -25 +25 @@
 
 #include "heap.hfa"
-#include "bits/align.hfa"                                                               // libAlign
-#include "bits/defs.hfa"                                                                // likely, unlikely
+#include "bits/align.hfa"                                                               // libAlign, Pause, likely, unlikely
 #include "concurrency/kernel/fwd.hfa"                                   // disable_interrupts, enable_interrupts
 #include "startup.hfa"                                                                  // STARTUP_PRIORITY_MEMORY
@@ -129 +128 @@
 } // Bsearchl
 
-
-// pause to prevent excess processor bus usage
-#if defined( __i386 ) || defined( __x86_64 )
-        #define Pause() __asm__ __volatile__ ( "pause" : : : )
-#elif defined(__ARM_ARCH)
-        #define Pause() __asm__ __volatile__ ( "YIELD" : : : )
-#else
-        #error unsupported architecture
-#endif
-
 typedef volatile uintptr_t SpinLock_t;
 
@@ -146 +135 @@
 
         for ( unsigned int i = 1;; i += 1 ) {
-          if ( slock == 0 && __atomic_test_and_set( &slock, __ATOMIC_ACQUIRE ) == 0 ) break; // Fence
+          if ( slock == 0 && AtomicTas( slock ) == 0 ) break; // Fence
                 for ( volatile unsigned int s = 0; s < spin; s += 1 ) Pause(); // exponential spin
                 spin += spin;                                                                   // powers of 2
@@ -155 +144 @@
 
 static inline __attribute__((always_inline)) void unlock( volatile SpinLock_t & slock ) {
-        __atomic_clear( &slock, __ATOMIC_RELEASE );                     // Fence
+        AtomicClr( slock );                                                                     // Fence
 } // spin_unlock
 
@@ -1003 +992 @@
                                 unlock( freeHead->returnLock );
                                 #else
-                                block = __atomic_exchange_n( &freeHead->returnList, 0p, __ATOMIC_SEQ_CST );
+                                block = AtomicFas( freeHead->returnList, 0p );
                                 #endif // RETURNSPIN
 
@@ -1168 +1157 @@
                         header->kind.real.next = freeHead->returnList; // link new node to top node
                         // CAS resets header->kind.real.next = freeHead->returnList on failure
-                        while ( ! __atomic_compare_exchange_n( &freeHead->returnList, &header->kind.real.next, (Heap.Storage *)header,
-                                                                                                   false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST ) );
+                        while ( ! AtomicCasv( freeHead->returnList, header->kind.real.next, (Heap.Storage *)header );
 
                         #ifdef __STATISTICS__