Changes in libcfa/src/concurrency/kernel/startup.cfa [0c3aa67:7cf3b1d]

File:

• libcfa/src/concurrency/kernel/startup.cfa (modified) (15 diffs)

libcfa/src/concurrency/kernel/startup.cfa

@@ -18 +18 @@
 
 // C Includes
-#include <errno.h>                                      // errno
+#include <errno.h>              // errno
 #include <signal.h>
-#include <string.h>                                     // strerror
-#include <unistd.h>                                     // sysconf
+#include <string.h>             // strerror
+#include <unistd.h>             // sysconf
 
 extern "C" {
-        #include <limits.h>                             // PTHREAD_STACK_MIN
-        #include <unistd.h>                             // syscall
-        #include <sys/eventfd.h>                        // eventfd
-        #include <sys/mman.h>                           // mprotect
-        #include <sys/resource.h>                       // getrlimit
+      #include <limits.h>       // PTHREAD_STACK_MIN
+        #include <unistd.h>       // syscall
+        #include <sys/eventfd.h>  // eventfd
+      #include <sys/mman.h>     // mprotect
+      #include <sys/resource.h> // getrlimit
 }
 
 // CFA Includes
-#include "kernel/private.hfa"
-#include "iofwd.hfa"
-#include "startup.hfa"                                  // STARTUP_PRIORITY_XXX
+#include "kernel_private.hfa"
+#include "startup.hfa"          // STARTUP_PRIORITY_XXX
 #include "limits.hfa"
 #include "math.hfa"
@@ -98 +97 @@
 extern void __kernel_alarm_startup(void);
 extern void __kernel_alarm_shutdown(void);
-extern void __cfa_io_start( processor * );
-extern void __cfa_io_stop ( processor * );
 
 //-----------------------------------------------------------------------------
@@ -105 +102 @@
 extern void __wake_proc(processor *);
 extern int cfa_main_returned;                                                   // from interpose.cfa
-uint32_t __global_random_prime = 4_294_967_291u, __global_random_mask = false;
+extern uint32_t __global_random_seed;
 
 //-----------------------------------------------------------------------------
@@ -114 +111 @@
 KERNEL_STORAGE(__stack_t,            mainThreadCtx);
 KERNEL_STORAGE(__scheduler_RWLock_t, __scheduler_lock);
-KERNEL_STORAGE(eventfd_t,            mainIdleEventFd);
-KERNEL_STORAGE(io_future_t,          mainIdleFuture);
 #if !defined(__CFA_NO_STATISTICS__)
 KERNEL_STORAGE(__stats_t, mainProcStats);
@@ -229 +224 @@
         (*mainProcessor){};
 
-        mainProcessor->idle_wctx.rdbuf = &storage_mainIdleEventFd;
-        mainProcessor->idle_wctx.ftr   = (io_future_t*)&storage_mainIdleFuture;
-        /* paranoid */ verify( sizeof(storage_mainIdleEventFd) == sizeof(eventfd_t) );
-
-        __cfa_io_start( mainProcessor );
         register_tls( mainProcessor );
 
@@ -315 +305 @@
 
         unregister_tls( mainProcessor );
-        __cfa_io_stop( mainProcessor );
 
         // Destroy the main processor and its context in reverse order of construction
@@ -364 +353 @@
         proc->local_data = &__cfaabi_tls;
 
-        __cfa_io_start( proc );
         register_tls( proc );
-
-        // used for idle sleep when io_uring is present
-        io_future_t future;
-        eventfd_t idle_buf;
-        proc->idle_wctx.ftr = &future;
-        proc->idle_wctx.rdbuf = &idle_buf;
-
 
         // SKULLDUGGERY: We want to create a context for the processor coroutine
@@ -414 +395 @@
 
         unregister_tls( proc );
-        __cfa_io_stop( proc );
 
         return 0p;
@@ -510 +490 @@
         preferred = ready_queue_new_preferred();
         last_proc = 0p;
-        random_state = __global_random_mask ? __global_random_prime : __global_random_prime ^ rdtscl();
+        random_state = __global_random_seed;
         #if defined( __CFA_WITH_VERIFY__ )
                 canary = 0x0D15EA5E0D15EA5Ep;
@@ -535 +515 @@
         this.rdq.its = 0;
         this.rdq.itr = 0;
-        this.rdq.id  = 0;
+        this.rdq.id  = MAX;
         this.rdq.target = MAX;
         this.rdq.last = MAX;
@@ -552 +532 @@
         this.local_data = 0p;
 
-        idle_wctx.evfd = eventfd(0, 0);
-        if (idle_wctx.evfd < 0) {
+        this.idle_fd = eventfd(0, 0);
+        if (idle_fd < 0) {
                 abort("KERNEL ERROR: PROCESSOR EVENTFD - %s\n", strerror(errno));
         }
 
-        idle_wctx.sem = 0;
-        idle_wctx.wake__time = 0;
+        this.idle_wctx.fd = 0;
 
         // I'm assuming these two are reserved for standard input and output
         // so I'm using them as sentinels with idle_wctx.
-        /* paranoid */ verify( idle_wctx.evfd != 0 );
-        /* paranoid */ verify( idle_wctx.evfd != 1 );
+        /* paranoid */ verify( this.idle_fd != 0 );
+        /* paranoid */ verify( this.idle_fd != 1 );
 
         #if !defined(__CFA_NO_STATISTICS__)
@@ -575 +554 @@
 // Not a ctor, it just preps the destruction but should not destroy members
 static void deinit(processor & this) {
-        close(this.idle_wctx.evfd);
+        close(this.idle_fd);
 }
 
@@ -626 +605 @@
         this.name = name;
         this.preemption_rate = preemption_rate;
-        this.sched.readyQ.data = 0p;
-        this.sched.readyQ.tscs = 0p;
-        this.sched.readyQ.count = 0;
-        this.sched.io.tscs = 0p;
-        this.sched.io.data = 0p;
-        this.sched.caches = 0p;
+        ready_queue{};
 
         #if !defined(__CFA_NO_STATISTICS__)
@@ -670 +644 @@
         // Unlock the RWlock
         ready_mutate_unlock( last_size );
-
-        ready_queue_close( &this );
-        /* paranoid */ verify( this.sched.readyQ.data == 0p );
-        /* paranoid */ verify( this.sched.readyQ.tscs == 0p );
-        /* paranoid */ verify( this.sched.readyQ.count == 0 );
-        /* paranoid */ verify( this.sched.io.tscs == 0p );
-        /* paranoid */ verify( this.sched.caches == 0p );
-
         enable_interrupts( false ); // Don't poll, could be in main cluster
-
 
         #if !defined(__CFA_NO_STATISTICS__)
@@ -771 +736 @@
         check( pthread_attr_init( &attr ), "pthread_attr_init" ); // initialize attribute
 
-        size_t stacksize = max( PTHREAD_STACK_MIN, DEFAULT_STACK_SIZE );
+        size_t stacksize = DEFAULT_STACK_SIZE;
 
         void * stack;