Changes in libcfa/src/concurrency/kernel_private.hfa [d3605f8:24e321c]

File:

• libcfa/src/concurrency/kernel_private.hfa (modified) (4 diffs)

libcfa/src/concurrency/kernel_private.hfa

@@ -39 +39 @@
 }
 
-// Defines whether or not we *want* to use io_uring_enter as the idle_sleep blocking call
-#define CFA_WANT_IO_URING_IDLE
-
-// Defines whether or not we *can* use io_uring_enter as the idle_sleep blocking call
-#if defined(CFA_WANT_IO_URING_IDLE) && defined(CFA_HAVE_LINUX_IO_URING_H)
-        #if defined(CFA_HAVE_IORING_OP_READ) || (defined(CFA_HAVE_READV) && defined(CFA_HAVE_IORING_OP_READV))
-                #define CFA_WITH_IO_URING_IDLE
-        #endif
-#endif
-
 //-----------------------------------------------------------------------------
 // Scheduler
@@ -159 +149 @@
         __atomic_store_n(ll, (bool)false, __ATOMIC_RELEASE);
 }
+
+
+
+
 
 //-----------------------------------------------------------------------
@@ -274 +268 @@
         ready_schedule_lock();
 
-        lock( this.lock __cfaabi_dbg_ctx2 );
-
-        /* paranoid */ verify( ! __preemption_enabled() );
-}
-
-static inline bool try_lock(__cluster_proc_list & this) {
-        /* paranoid */ verify( ! __preemption_enabled() );
-
-        // Start by locking the global RWlock so that we know no-one is
-        // adding/removing processors while we mess with the idle lock
-        ready_schedule_lock();
-
-        if(try_lock( this.lock __cfaabi_dbg_ctx2 )) {
-                // success
-                /* paranoid */ verify( ! __preemption_enabled() );
-                return true;
-        }
-
-        // failed to lock
-        ready_schedule_unlock();
-
-        /* paranoid */ verify( ! __preemption_enabled() );
-        return false;
+        // Simple counting lock, acquired, acquired by incrementing the counter
+        // to an odd number
+        for() {
+                uint64_t l = this.lock;
+                if(
+                        (0 == (l % 2))
+                        && __atomic_compare_exchange_n(&this.lock, &l, l + 1, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)
+                ) return;
+                Pause();
+        }
+
+        /* paranoid */ verify( ! __preemption_enabled() );
 }
 
@@ -302 +285 @@
         /* paranoid */ verify( ! __preemption_enabled() );
 
-        unlock(this.lock);
+        /* paranoid */ verify( 1 == (this.lock % 2) );
+        // Simple couting lock, release by incrementing to an even number
+        __atomic_fetch_add( &this.lock, 1, __ATOMIC_SEQ_CST );
 
         // Release the global lock, which we acquired when locking