Index: tests/concurrent/.expect/semaphore.txt =================================================================== --- tests/concurrent/.expect/semaphore.txt (revision c90db2db871a3e57c7c5f98cc53831bb1ca50d84) +++ (revision ) @@ -1,3 +1,0 @@ -Starting -Done! -Match! Index: tests/concurrent/.expect/spinaphore.txt =================================================================== --- tests/concurrent/.expect/spinaphore.txt (revision c90db2db871a3e57c7c5f98cc53831bb1ca50d84) +++ (revision ) @@ -1,3 +1,0 @@ -Starting -Done! -Match! Index: tests/concurrent/semaphore.cfa =================================================================== --- tests/concurrent/semaphore.cfa (revision c90db2db871a3e57c7c5f98cc53831bb1ca50d84) +++ (revision ) @@ -1,78 +1,0 @@ -#include -#include -#include -#include - -enum { num_blockers = 17, num_unblockers = 13 }; - -void thrash() { - unsigned t[100]; - for(i; 100) { - t[i] = 0xDEADBEEF; - } -} - -ThreadBenaphore ben; - -// const unsigned int num_blocks = 25000; -const unsigned int num_blocks = 5; - -thread Blocker { - size_t sum; -}; - -void main(Blocker & this) { - thread$ * me = active_thread(); - this.sum = 0; - for(num_blocks) { - this.sum += (unsigned)me; - thrash(); - P(ben); - if(((thread&)this).seqable.next != 0p) mutex(sout) sout | "Link not invalidated"; - thrash(); - } -} - -thread Unblocker { - size_t sum; -}; - -void main(Unblocker & this) { - this.sum = 0; - LOOP: for() { - waitfor( ^?{} : this) { - break LOOP; - } - or else {} - - thread$ * t = V(ben, false); - if(t) { - this.sum += (unsigned)t; - unpark(t); - } - yield(random(10)); - } -} - -int main() { - size_t usum = 0; - size_t bsum = 0; - - sout | "Starting"; - { - Blocker blockers [num_blockers ]; - Unblocker unblockers[num_unblockers]; - - for(i;num_blockers) { - bsum += join(blockers[i]).sum; - } - - sout | "Done!"; - - for(i;num_unblockers) { - usum += join(unblockers[i]).sum; - } - } - if(bsum == usum) sout | "Match!"; - else sout | "No Match!" | usum | "!=" | bsum; -} Index: tests/concurrent/spinaphore.cfa =================================================================== --- tests/concurrent/spinaphore.cfa (revision c90db2db871a3e57c7c5f98cc53831bb1ca50d84) +++ (revision ) @@ -1,94 +1,0 @@ -#include -#include -#include - -enum { num_blockers = 17, num_unblockers = 13 }; - -void thrash() { - unsigned t[100]; - for(i; 100) { - t[i] = 0xDEADBEEF; - } -} - -Semaphore0nary sem; - -const unsigned int num_blocks = 1625; - -thread Blocker { - size_t sum; -}; -void main(Blocker & this); - -Blocker * from_thread(thread$ * t) { - Blocker & nullb = *(Blocker*)0p; - thread$ & nullt = (thread&)nullb; - uintptr_t offset = (uintptr_t)&nullt; - uintptr_t address = ((uintptr_t)t) - offset; - return (Blocker*)address; -} - -void main(Blocker & this) { - thread$ * me = active_thread(); - Blocker * me1 = &this; - Blocker * me2 = from_thread(me); - if( me1 != me2 ) sout | "Bad casting!" | me1 | "vs" | me2; - this.sum = 0; - for(num_blocks) { - P(sem); - if(((thread&)this).seqable.next != 0p) sout | "Link not invalidated"; - } -} - -const unsigned int num_unblocks = 2125; - -thread Unblocker { - size_t sum; -}; - -void main(Unblocker & this) { - this.sum = 0; - unsigned me = (unsigned)(uintptr_t)&this; - for(num_unblocks) { - thread$ * t = V(sem, false); - Blocker * b = from_thread(t); - b->sum += me; - this.sum += (unsigned)(uintptr_t)b; - unpark(t); - yield(random(10)); - } -} - -int main() { - size_t usum = 0; - size_t bsum = 0; - - if((num_unblocks * num_unblockers) != (num_blocks * num_blockers)) sout | "Mismatched Operations: " | (num_unblocks * num_unblockers) | "vs" | (num_blocks * num_blockers); - - sout | "Starting"; - { - Blocker blockers [num_blockers ]; - Unblocker unblockers[num_unblockers]; - - for(i;num_blockers) { - for(num_blocks) - usum += (unsigned)(uintptr_t)&blockers[i]; - } - - for(i;num_unblockers) { - for(num_unblocks) - bsum += (unsigned)(uintptr_t)&unblockers[i]; - } - - for(i;num_blockers) { - bsum -= join(blockers[i]).sum; - } - - for(i;num_unblockers) { - usum -= join(unblockers[i]).sum; - } - } - sout | "Done!"; - if(bsum == 0 && usum == 0) sout | "Match!"; - else sout | "No Match!" | usum | "/" | bsum; -} Index: tests/unified_locking/.expect/locks.txt =================================================================== --- tests/unified_locking/.expect/locks.txt (revision c90db2db871a3e57c7c5f98cc53831bb1ca50d84) +++ tests/unified_locking/.expect/locks.txt (revision 25337e082faf7ec7364ea6d7d9c16c8e76e0bf5e) @@ -11,18 +11,14 @@ Start Test 6: owner lock and condition variable 3 wait/notify all Done Test 6 -Start Test 7: fast lock and condition variable single wait/notify +Start Test 7: linear backoff lock and condition variable single wait/notify Done Test 7 -Start Test 8: fast lock and condition variable 3 wait/notify all +Start Test 8: linear backoff lock and condition variable 3 wait/notify all Done Test 8 -Start Test 9: linear backoff lock and condition variable single wait/notify +Start Test 9: multi acquisiton lock and condition variable multiple acquire and wait/notify Done Test 9 -Start Test 10: linear backoff lock and condition variable 3 wait/notify all +Start Test 10: owner lock and condition variable multiple acquire and wait/notify Done Test 10 -Start Test 11: multi acquisiton lock and condition variable multiple acquire and wait/notify +Start Test 11: no lock condition variable wait/notify Done Test 11 -Start Test 12: owner lock and condition variable multiple acquire and wait/notify +Start Test 12: locked condition variable wait/notify with front() Done Test 12 -Start Test 13: no lock condition variable wait/notify -Done Test 13 -Start Test 14: locked condition variable wait/notify with front() -Done Test 14 Index: tests/unified_locking/locks.cfa =================================================================== --- tests/unified_locking/locks.cfa (revision c90db2db871a3e57c7c5f98cc53831bb1ca50d84) +++ tests/unified_locking/locks.cfa (revision 25337e082faf7ec7364ea6d7d9c16c8e76e0bf5e) @@ -15,7 +15,4 @@ condition_variable( owner_lock ) c_o; -fast_lock f; -condition_variable( fast_lock ) c_f; - linear_backoff_then_block_lock l; condition_variable( linear_backoff_then_block_lock ) c_l; @@ -74,32 +71,4 @@ } unlock(s); - } -} - -thread T_C_F_WS1 {}; - -void main( T_C_F_WS1 & this ) { - for (unsigned int i = 0; i < num_times; i++) { - lock(f); - if(empty(c_f) && i != num_times - 1) { - wait(c_f,f); - }else{ - notify_one(c_f); - } - unlock(f); - } -} - -thread T_C_F_WB1 {}; - -void main( T_C_F_WB1 & this ) { - for (unsigned int i = 0; i < num_times; i++) { - lock(f); - if(counter(c_f) == 3 || i == num_times - 1) { - notify_all(c_f); - }else{ - wait(c_f,f); - } - unlock(f); } } @@ -317,51 +286,39 @@ printf("Done Test 6\n"); - printf("Start Test 7: fast lock and condition variable single wait/notify\n"); - { - T_C_F_WS1 t1[2]; + printf("Start Test 7: linear backoff lock and condition variable single wait/notify\n"); + { + T_C_L_WS1 t1[2]; } printf("Done Test 7\n"); - printf("Start Test 8: fast lock and condition variable 3 wait/notify all\n"); - { - T_C_F_WB1 t1[4]; + printf("Start Test 8: linear backoff lock and condition variable 3 wait/notify all\n"); + { + T_C_L_WB1 t1[4]; } printf("Done Test 8\n"); - printf("Start Test 9: linear backoff lock and condition variable single wait/notify\n"); - { - T_C_L_WS1 t1[2]; + printf("Start Test 9: multi acquisiton lock and condition variable multiple acquire and wait/notify\n"); + { + T_C_M_WS2 t1[2]; } printf("Done Test 9\n"); - printf("Start Test 10: linear backoff lock and condition variable 3 wait/notify all\n"); - { - T_C_L_WB1 t1[4]; + printf("Start Test 10: owner lock and condition variable multiple acquire and wait/notify\n"); + { + T_C_O_WS2 t1[2]; } printf("Done Test 10\n"); - printf("Start Test 11: multi acquisiton lock and condition variable multiple acquire and wait/notify\n"); - { - T_C_M_WS2 t1[2]; - } - printf("Done Test 11\n"); - - printf("Start Test 12: owner lock and condition variable multiple acquire and wait/notify\n"); - { - T_C_O_WS2 t1[2]; - } - printf("Done Test 12\n"); - - printf("Start Test 13: no lock condition variable wait/notify\n"); + printf("Start Test 11: no lock condition variable wait/notify\n"); { T_C_NLW t1; T_C_NLS t2; } - printf("Done Test 13\n"); - - printf("Start Test 14: locked condition variable wait/notify with front()\n"); + printf("Done Test 11\n"); + + printf("Start Test 12: locked condition variable wait/notify with front()\n"); { T_C_S_WNF t1[2]; } - printf("Done Test 14\n"); -} + printf("Done Test 12\n"); +} Index: tests/zombies/fastlock.cfa =================================================================== --- tests/zombies/fastlock.cfa (revision c90db2db871a3e57c7c5f98cc53831bb1ca50d84) +++ (revision ) @@ -1,8 +1,0 @@ -#include - -#define LOCK fast_lock -#include "mutex_test.hfa" - -int main() { - test(); -}