Changes in libcfa/src/concurrency/kernel/startup.cfa [22226e4:c655650]

File:

• libcfa/src/concurrency/kernel/startup.cfa (modified) (13 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 * );
 
 //-----------------------------------------------------------------------------
@@ -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) );
-
         register_tls( mainProcessor );
-        __cfa_io_start( mainProcessor );
 
         // Start by initializing the main thread
@@ -314 +304 @@
         mainProcessor->local_data = 0p;
 
-        __cfa_io_stop( mainProcessor );
         unregister_tls( mainProcessor );
 
@@ -366 +355 @@
         register_tls( proc );
 
-        __cfa_io_start( 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
         // which is needed for the 2-step context switch. However, there is no reason
@@ -401 +381 @@
         // Main routine of the core returned, the core is now fully terminated
         __cfadbg_print_safe(runtime_core, "Kernel : core %p main ended (%p)\n", proc, &proc->runner);
-
-        __cfa_io_stop( proc );
 
         #if !defined(__CFA_NO_STATISTICS__)
@@ -537 +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;
@@ -554 +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;
+        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__)
@@ -576 +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);
 }
 
@@ -627 +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.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;