Changeset 90152a4 for tests/concurrent/signal/block.c

Timestamp:

Aug 27, 2018, 4:40:34 PM (7 years ago)

Author:

Rob Schluntz <rschlunt@…>

Branches:

ADT, arm-eh, ast-experimental, cleanup-dtors, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum, stuck-waitfor-destruct

Children:

b7c89aa

Parents:

f9feab8 (diff), 305581d (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' into cleanup-dtors

File:

• tests/concurrent/signal/block.c (moved) (moved from src/tests/concurrent/signal/block.c ) (8 diffs)

tests/concurrent/signal/block.c

@@ -7 +7 @@
 
 
-#include <fstream>
-#include <kernel>
-#include <monitor>
-#include <stdlib>
-#include <thread>
+#include <fstream.hfa>
+#include <kernel.hfa>hfa>
+#include <monitor.hfa>
+#include <stdlib.hfa>
+#include <thread.hfa>
+#include <time.hfa>
 
-#include <time.h>
-
-static const unsigned long N = 5_000ul;
+#include "long_tests.h"
 
 #ifndef PREEMPTION_RATE
-#define PREEMPTION_RATE 10_000ul
+#define PREEMPTION_RATE 10`ms
 #endif
 
-unsigned int default_preemption() {
+Duration default_preemption() {
         return PREEMPTION_RATE;
 }
+
+#ifdef TEST_LONG
+static const unsigned long N = 150_000ul;
+#else
+static const unsigned long N = 5_000ul;
+#endif
 
 enum state_t { WAITED, SIGNAL, BARGE };
@@ -37 +42 @@
 }
 
-void ^?{} ( global_data_t & this ) {}
+void ^?{} ( global_data_t & mutex this ) {}
 
 global_data_t globalA, globalB;
@@ -47 +52 @@
 //------------------------------------------------------------------------------
 void wait_op( global_data_t & mutex a, global_data_t & mutex b, unsigned i ) {
-        wait( cond, (uintptr_t)this_thread );
+    wait( cond, (uintptr_t)active_thread() );
 
         yield( random( 10 ) );
@@ -56 +61 @@
         }
 
-        a.last_thread = b.last_thread = this_thread;
+        a.last_thread = b.last_thread = active_thread();
 
         yield( random( 10 ) );
@@ -63 +68 @@
 thread Waiter {};
 void main( Waiter & this ) {
-        for( int i = 0; i < N; i++ ) {
+        for( int i = 0; TEST(i < N); i++ ) {
                 wait_op( globalA, globalB, i );
+                KICK_WATCHDOG;
         }
 }
@@ -72 +78 @@
         yield( random( 10 ) );
 
-        [a.last_thread, b.last_thread, a.last_signaller, b.last_signaller] = this_thread;
+        [a.last_thread, b.last_thread, a.last_signaller, b.last_signaller] = active_thread();
 
         if( !is_empty( cond ) ) {
@@ -102 +108 @@
 //------------------------------------------------------------------------------
 void barge_op( global_data_t & mutex a ) {
-        a.last_thread = this_thread;
+        a.last_thread = active_thread();
 }
 
@@ -118 +124 @@
 
 int main(int argc, char* argv[]) {
-        random_seed( time( NULL ) );
+        srandom( time( NULL ) );
         done = false;
         processor p;