Changes in libcfa/src/concurrency/kernel.hfa [639e4fc:31c967b]

File:

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

libcfa/src/concurrency/kernel.hfa

@@ -64 +64 @@
         // 1 - means the proc should wake-up immediately
         // FD - means the proc is going asleep and should be woken by writing to the FD.
-        //      The FD value should always be the evfd field just below.
         volatile int sem;
 
@@ -70 +69 @@
         int evfd;
 
-        // Used for debugging, should be removed eventually.
+        // buffer into which the proc will read from evfd
+        // unused if not using io_uring for idle sleep
+        void * rdbuf;
+
+        // future use to track the read of the eventfd
+        // unused if not using io_uring for idle sleep
+        io_future_t * ftr;
+
         volatile unsigned long long wake__time;
         volatile unsigned long long sleep_time;
@@ -154 +160 @@
 // P9_EMBEDDED( processor, dlink(processor) )
 static inline tytagref( dlink(processor), dlink(processor) ) ?`inner( processor & this ) {
-        dlink(processor) & b = this.link;
-        tytagref( dlink(processor), dlink(processor) ) result = { b };
-        return result;
+    dlink(processor) & b = this.link;
+    tytagref( dlink(processor), dlink(processor) ) result = { b };
+    return result;
 }
 
@@ -250 +256 @@
         // List of threads
         __spinlock_t thread_list_lock;
-        dlist(struct thread$, struct __thread_user_link) threads;
+        __dllist_t(struct thread$) threads;
         unsigned int nthreads;
 
@@ -263 +269 @@
                 io_context_params params;
         } io;
-
-        struct {
-                struct processor ** procs;
-                unsigned cnt;
-        } managed;
 
         #if !defined(__CFA_NO_STATISTICS__)
@@ -297 +298 @@
 static inline struct cluster   * active_cluster  () { return publicTLS_get( this_processor )->cltr; }
 
-// set the number of internal processors
-// these processors are in addition to any explicitly declared processors
-unsigned set_concurrency( cluster & this, unsigned new_count );
-
 #if !defined(__CFA_NO_STATISTICS__)
         void print_stats_now( cluster & this, int flags );