Changeset ea8b2f7 for src/libcfa/bits/locks.h

Timestamp:

Jun 7, 2018, 11:14:07 AM (6 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, with_gc

Children:

ae3bb3d

Parents:

214e8da

Message:

Immetidate fix for halting processors, drifting still an issue

File:

• src/libcfa/bits/locks.h (modified) (2 diffs)

src/libcfa/bits/locks.h

@@ -18 +18 @@
 #include "bits/debug.h"
 #include "bits/defs.h"
+#include <assert.h>
+
+#ifdef __cforall
+        extern "C" {
+                #include <pthread.h>
+        }
+#endif
 
 // pause to prevent excess processor bus usage
@@ -112 +119 @@
                 __atomic_clear( &this.lock, __ATOMIC_RELEASE );
         }
+
+
+        #ifdef __CFA_WITH_VERIFY__
+                extern bool __cfaabi_dbg_in_kernel();
+        #endif
+
+        struct __bin_sem_t {
+                int_fast8_t     counter;
+                pthread_mutex_t lock;
+                pthread_cond_t  cond;
+        };
+
+        static inline void ?{}(__bin_sem_t & this) with( this ) {
+                counter = 0;
+                pthread_mutex_init(&lock, NULL);
+                pthread_cond_init (&cond, NULL);
+        }
+
+        static inline void ^?{}(__bin_sem_t & this) with( this ) {
+                pthread_mutex_destroy(&lock);
+                pthread_cond_destroy (&cond);
+        }
+
+        static inline void wait(__bin_sem_t & this) with( this ) {
+                verify(__cfaabi_dbg_in_kernel());
+                pthread_mutex_lock(&lock);
+                if(counter != 0) {   // this must be a loop, not if!
+                        pthread_cond_wait(&cond, &lock);
+                }
+                counter = 1;
+                pthread_mutex_unlock(&lock);
+        }
+
+        static inline void post(__bin_sem_t & this) with( this ) {
+                verify(__cfaabi_dbg_in_kernel());
+                pthread_mutex_lock(&lock);
+                bool needs_signal = counter == 0;
+                counter = 1;
+                pthread_mutex_unlock(&lock);
+                if (!needs_signal)
+                        pthread_cond_signal(&cond);
+                }
 #endif