Changeset 5c931e0 for libcfa/src

Timestamp:

Jan 9, 2023, 4:07:45 PM (3 years ago)

Author:

caparsons <caparson@…>

Branches:

ADT, ast-experimental, master

Children:

cca034e

Parents:

72abfddd

Message:

made changes to support zero-size channels

File:

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

libcfa/src/concurrency/channel.hfa

@@ -16 +16 @@
 
 forall( T ) {
-struct __attribute__ ((aligned (64))) channel {
+struct channel {
     size_t size;
     size_t front, back, count;
@@ -49 +49 @@
     lock( mutex_lock );
 
+    // have to check for the zero size channel case
+    if ( size == 0 && !empty( cons ) ) {
+        memcpy((void *)front( cons ), (void *)&elem, sizeof(T));
+        notify_one( cons );
+        unlock( mutex_lock );
+        return;
+    }
+
     // wait if buffer is full, work will be completed by someone else
     if ( count == size ) { 
@@ -55 +63 @@
     } // if
 
-    if ( count == 0 && !empty( prods ) )
+    if ( count == 0 && !empty( cons ) )
         // do waiting consumer work
-        memcpy((void *)front( prods ), (void *)&elem, sizeof(T)); 
+        memcpy((void *)front( cons ), (void *)&elem, sizeof(T)); 
     else insert_( chan, elem );
     
-    notify_one( prods );
+    notify_one( cons );
     unlock( mutex_lock );
 }
@@ -68 +76 @@
     T retval;
 
+    // have to check for the zero size channel case
+    if ( size == 0 && !empty( prods ) ) {
+        memcpy((void *)&retval, (void *)front( prods ), sizeof(T));
+        notify_one( prods );
+        unlock( mutex_lock );
+        return retval;
+    }
+
     // wait if buffer is empty, work will be completed by someone else
     if (count == 0) { 
-        wait( prods, mutex_lock, (uintptr_t)&retval );
+        wait( cons, mutex_lock, (uintptr_t)&retval );
         return retval;
     }