Changeset 90c4df0 for src/tests/sched-ext.c

Timestamp:

Aug 22, 2017, 1:44:12 PM (6 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

aaron-thesis, arm-eh, 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, resolv-new, with_gc

Children:

80c72a7

Parents:

e50e9ff

Message:

Implemented search for external scheduling

File:

• src/tests/sched-ext.c (modified) (5 diffs)

src/tests/sched-ext.c

@@ -7 +7 @@
 #include <time.h>
 
-static const unsigned long N = 2_500ul;
+static const unsigned long N = 500ul;
 
 #ifndef PREEMPTION_RATE
@@ -24 +24 @@
 thread Acceptee {};
 
+volatile bool done;
+
+unsigned rand10() {
+        return (unsigned)rand48() % 10;
+}
+
 //----------------------------------------------------------------------------------------------------
 // Acceptor
@@ -29 +35 @@
 
 void do_wait( global_t * mutex a ) {
-        sout | "Preparing to wait" | endl;
+        sout | "Waiting to accept" | endl;
+        yield( rand10() );
+
+        sout | "Accepting" | endl;
 
         __acceptable_t acceptable;
-        acceptable.func          = (void_fptr_t)do_notify;
+        acceptable.func          = (fptr_t)do_notify;
         acceptable.count         = 1;
         acceptable.monitors      = &a;
         acceptable.run_preaccept = false;
 
-        sout | "Waiting for notify" | endl;
+        __accept_internal( 1, &acceptable );
 
-        int ret = __accept_internal( 1, &acceptable );
-        sout | "Back from wating, accepted" | ret | endl;
+        sout | "Accepted" | endl;
+        yield( rand10() );
 }
 
 void main( Acceptor* this ) {
-        do_wait( &globalA );
+        for( int i = 0; i < N; i++ ) {
+                do_wait( &globalA );
+                sout | i | endl;
+        }
+
+        done = true;
 }
 
@@ -50 +64 @@
 // Acceptee
 void do_notify( global_t * mutex a ) {
-        sout | "Notifying" | endl;
+
 }
 
 void main( Acceptee* this ) {
-        for( volatile int i = 0; i < N; i++ );
-
-        sout | "Call Notify" | endl;
-        do_notify( &globalA );
+        while( !done ) {
+                yield( rand10() );
+                do_notify( &globalA );
+                yield( rand10() );
+        }
 }
 
@@ -63 +78 @@
 // Main
 int main(int argc, char* argv[]) {
-        processor p;
+        done = false;
+        rand48seed( time( NULL ) );
+        printf("%p\n", &globalA);
         sout | "Starting" | endl;
         {
                 Acceptor r;
-                Acceptee e;
+                Acceptee e[13];
+
         }
         sout | "Done" | endl;