Changes in src/libcfa/concurrency/kernel [bdeba0b:c81ebf9]

File:

• src/libcfa/concurrency/kernel (modified) (4 diffs)

src/libcfa/concurrency/kernel

@@ -28 +28 @@
 //-----------------------------------------------------------------------------
 // Locks
-bool try_lock  ( spinlock * DEBUG_CTX_PARAM2 );
-void lock      ( spinlock * DEBUG_CTX_PARAM2 );
-void lock_yield( spinlock * DEBUG_CTX_PARAM2 );
-void unlock    ( spinlock * );
+bool try_lock( spinlock * );
+void lock( spinlock * );
+void unlock( spinlock * );
 
-struct semaphore {
-        spinlock lock;
-        int count;
-        __thread_queue_t waiting;
+struct signal_once {
+        volatile bool cond;
+        struct spinlock lock;
+        struct __thread_queue_t blocked;
 };
 
-void  ?{}(semaphore * this, int count = 1);
-void ^?{}(semaphore * this);
-void P(semaphore * this);
-void V(semaphore * this);
+void ?{}(signal_once * this);
+void ^?{}(signal_once * this);
 
+void wait( signal_once * );
+void signal( signal_once * );
 
 //-----------------------------------------------------------------------------
@@ -69 +68 @@
         unsigned short thrd_count;
 };
-static inline void ?{}(FinishAction * this) {
+static inline void ?{}(FinishAction * this) { 
         this->action_code = No_Action;
         this->thrd = NULL;
@@ -79 +78 @@
         struct processorCtx_t * runner;
         cluster * cltr;
+        coroutine_desc * current_coroutine;
+        thread_desc * current_thread;
         pthread_t kernel_thread;
-
-        semaphore terminated;
+        
+        signal_once terminated;
         volatile bool is_terminated;
 
@@ -89 +90 @@
         unsigned int preemption;
 
+        unsigned short disable_preempt_count;
+
         bool pending_preemption;
-
-        char * last_enable;
 };