Changes in libcfa/src/concurrency/kernel_private.hfa [3e2b9c9:320ec6fc]

File:

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

libcfa/src/concurrency/kernel_private.hfa

@@ -22 +22 @@
 #include "stats.hfa"
 
+#include "bits/random.hfa"
+
+
 //-----------------------------------------------------------------------------
 // Scheduler
@@ -50 +53 @@
 
 
+struct event_kernel_t {
+        alarm_list_t alarms;
+        __spinlock_t lock;
+};
+
+extern event_kernel_t * event_kernel;
+
+struct __cfa_kernel_preemption_state_t {
+        bool enabled;
+        bool in_progress;
+        unsigned short disable_count;
+};
+
+extern volatile thread_local __cfa_kernel_preemption_state_t preemption_state __attribute__ ((tls_model ( "initial-exec" )));
+
 extern cluster * mainCluster;
 
@@ -66 +84 @@
 void __unpark( struct __processor_id_t *, $thread * thrd __cfaabi_dbg_ctx_param2 );
 
-static inline bool __post(single_sem & this, struct __processor_id_t * id) {
-        for() {
-                struct $thread * expected = this.ptr;
-                if(expected == 1p) return false;
-                if(expected == 0p) {
-                        if(__atomic_compare_exchange_n(&this.ptr, &expected, 1p, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
-                                return false;
-                        }
-                }
-                else {
-                        if(__atomic_compare_exchange_n(&this.ptr, &expected, 0p, false, __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)) {
-                                __unpark( id, expected __cfaabi_dbg_ctx2 );
-                                return true;
-                        }
-                }
-        }
-}
+//-----------------------------------------------------------------------------
+// I/O
+void __kernel_io_startup     ( cluster &, unsigned, bool );
+void __kernel_io_finish_start( cluster & );
+void __kernel_io_prepare_stop( cluster & );
+void __kernel_io_shutdown    ( cluster &, bool );
 
 //-----------------------------------------------------------------------------
 // Utils
+#define KERNEL_STORAGE(T,X) __attribute((aligned(__alignof__(T)))) static char storage_##X[sizeof(T)]
+
+static inline uint64_t __tls_rand() {
+        #if defined(__SIZEOF_INT128__)
+                return __lehmer64( kernelTLS.rand_seed );
+        #else
+                return __xorshift64( kernelTLS.rand_seed );
+        #endif
+}
+
+
+void doregister( struct cluster & cltr );
+void unregister( struct cluster & cltr );
+
 void doregister( struct cluster * cltr, struct $thread & thrd );
 void unregister( struct cluster * cltr, struct $thread & thrd );
-
-//-----------------------------------------------------------------------------
-// I/O
-void ^?{}(io_context & this, bool );
 
 //=======================================================================
@@ -263 +280 @@
 void ready_queue_shrink(struct cluster * cltr, int target);
 
+//-----------------------------------------------------------------------
+// IO user data
+struct __io_user_data_t {
+        int32_t result;
+        $thread * thrd;
+};
+
+//-----------------------------------------------------------------------
+// Statics call at the end of each thread to register statistics
+#if !defined(__CFA_NO_STATISTICS__)
+        static inline struct __stats_t * __tls_stats() {
+                /* paranoid */ verify( ! kernelTLS.preemption_state.enabled );
+                /* paranoid */ verify( kernelTLS.this_stats );
+                return kernelTLS.this_stats;
+        }
+
+        #define __STATS__(in_kernel, ...) { \
+                if( !(in_kernel) ) disable_interrupts(); \
+                with( *__tls_stats() ) { \
+                        __VA_ARGS__ \
+                } \
+                if( !(in_kernel) ) enable_interrupts( __cfaabi_dbg_ctx ); \
+        }
+#else
+        #define __STATS__(in_kernel, ...)
+#endif
 
 // Local Variables: //