Changeset b9f383f for src/tests/concurrent/examples/boundedBufferEXT.c

Timestamp:

Apr 27, 2018, 2:35:00 PM (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:

5527759

Parents:

de6319f

Message:

named threads in thread tests
fixed bounded buffer expect
added error check for waitfor with no parameters
added missing parameters to bounded buffer EXT

File:

• src/tests/concurrent/examples/boundedBufferEXT.c (modified) (4 diffs)

src/tests/concurrent/examples/boundedBufferEXT.c

@@ -1 @@
-// 
+//
 // The contents of this file are covered under the licence agreement in the
 // file "LICENCE" distributed with Cforall.
-// 
-// boundedBufferEXT.c -- 
-// 
+//
+// boundedBufferEXT.c --
+//
 // Author           : Peter A. Buhr
 // Created On       : Wed Apr 18 22:52:12 2018
@@ -10 +10 @@
 // Last Modified On : Fri Apr 20 22:25:14 2018
 // Update Count     : 6
-// 
+//
 
 #include <stdlib>                                                                               // random
@@ -39 +39 @@
 forall( otype T )
 void insert( Buffer(T) & mutex buffer, T elem ) with( buffer ) {
-        if ( count == BufferSize ) waitfor( remove );
+        if ( count == BufferSize ) waitfor( remove, buffer );
         elements[back] = elem;
         back = ( back + 1 ) % BufferSize;
@@ -47 +47 @@
 forall( otype T )
 T remove( Buffer(T) & mutex buffer ) with( buffer ) {
-        if ( count == 0 ) waitfor( insert );
+        if ( count == 0 ) waitfor( insert, buffer );
         T elem = elements[front];
         front = ( front + 1 ) % BufferSize;