Index: tests/threads/rwlock_test.c |
diff --git a/tests/threads/rwlock_test.c b/tests/threads/rwlock_test.c |
deleted file mode 100644 |
index fe763abc4a4a4da111f8576727c64b339f0ef467..0000000000000000000000000000000000000000 |
--- a/tests/threads/rwlock_test.c |
+++ /dev/null |
@@ -1,279 +0,0 @@ |
-/* |
- * Copyright 2015 The Native Client Authors. All rights reserved. |
- * Use of this source code is governed by a BSD-style license that can be |
- * found in the LICENSE file. |
- */ |
- |
-#include <errno.h> |
-#include <pthread.h> |
-#include <stdio.h> |
-#include <time.h> |
- |
-#include "native_client/src/include/nacl_assert.h" |
- |
-pthread_rwlock_t g_rwlock; |
-volatile int g_thread_has_lock = 0; |
-volatile int g_thread_should_acquire_lock = 0; |
-volatile int g_thread_should_release_lock = 0; |
- |
-typedef enum { |
- READ_LOCK = 1, |
- WRITE_LOCK = 2, |
-} lock_type; |
- |
-void *locking_thread(void *unused) { |
- int rc; |
- for (;;) { |
- while (!g_thread_should_acquire_lock) { /* Spin. */ } |
- |
- ASSERT_EQ(g_thread_has_lock, 0); |
- if (g_thread_should_acquire_lock == WRITE_LOCK) |
- rc = pthread_rwlock_wrlock(&g_rwlock); |
- else |
- rc = pthread_rwlock_rdlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- __sync_fetch_and_add(&g_thread_has_lock, 1); |
- |
- while (!g_thread_should_release_lock) { /* Spin. */ } |
- |
- ASSERT_EQ(g_thread_has_lock, 1); |
- rc = pthread_rwlock_unlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- __sync_fetch_and_sub(&g_thread_has_lock, 1); |
- } |
- |
- return NULL; |
-} |
- |
- |
-void tell_thread_to_acquire_lock(lock_type lock_type) { |
- fprintf(stderr, "Thread acquiring lock: %s\n", |
- lock_type == WRITE_LOCK ? "WRITE" : "READ"); |
- |
- ASSERT_EQ(g_thread_has_lock, 0); |
- ASSERT_EQ(g_thread_should_acquire_lock, 0); |
- __sync_fetch_and_add(&g_thread_should_acquire_lock, lock_type); |
- |
- while (!g_thread_has_lock) { /* Spin. */ } |
- |
- __sync_fetch_and_sub(&g_thread_should_acquire_lock, lock_type); |
- ASSERT_EQ(g_thread_should_acquire_lock, 0); |
- |
- fprintf(stderr, "Thread acquired lock.\n"); |
-} |
- |
-void tell_thread_to_release_lock(void) { |
- fprintf(stderr, "Thread releasing lock.\n"); |
- |
- ASSERT_EQ(g_thread_has_lock, 1); |
- ASSERT_EQ(g_thread_should_release_lock, 0); |
- __sync_fetch_and_add(&g_thread_should_release_lock, 1); |
- |
- while (g_thread_has_lock) { /* Spin. */ } |
- |
- __sync_fetch_and_sub(&g_thread_should_release_lock, 1); |
- ASSERT_EQ(g_thread_should_release_lock, 0); |
- |
- fprintf(stderr, "Thread released lock.\n"); |
-} |
- |
-void test_reader_timedwait(void) { |
- fprintf(stderr, "test_reader_timedwait\n"); |
- tell_thread_to_acquire_lock(WRITE_LOCK); |
- |
- struct timespec t = { 0, 0 }; |
- int rc = pthread_rwlock_timedrdlock(&g_rwlock, &t); |
- ASSERT_EQ(rc, ETIMEDOUT); |
- |
- tell_thread_to_release_lock(); |
-} |
- |
-void test_writer_timedwait(void) { |
- fprintf(stderr, "test_writer_timedwait\n"); |
- tell_thread_to_acquire_lock(READ_LOCK); |
- |
- struct timespec t = { 0, 0 }; |
- int rc = pthread_rwlock_timedwrlock(&g_rwlock, &t); |
- ASSERT_EQ(rc, ETIMEDOUT); |
- |
- tell_thread_to_release_lock(); |
-} |
- |
-void test_multiple_writers(void) { |
- fprintf(stderr, "test_multiple_writers\n"); |
- tell_thread_to_acquire_lock(WRITE_LOCK); |
- |
- /* |
- * Attempt to acquire second write lock should fail. |
- */ |
- int rc = pthread_rwlock_trywrlock(&g_rwlock); |
- ASSERT_EQ(rc, EBUSY); |
- |
- tell_thread_to_release_lock(); |
-} |
- |
-void test_recursive_reader(void) { |
- /* |
- * Test that an rdlock can be recursively acquired even when there |
- * is a waiting writer. |
- */ |
- int rc = pthread_rwlock_rdlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- |
- /* |
- * Tell the locking thread to attempt to acquire the write lock. |
- * This should fail and block until all readers are unlocked. |
- */ |
- ASSERT_EQ(g_thread_has_lock, 0); |
- ASSERT_EQ(g_thread_should_acquire_lock, 0); |
- __sync_fetch_and_add(&g_thread_should_acquire_lock, WRITE_LOCK); |
- |
- /* |
- * Sleep for 10ms |
- */ |
- rc = usleep(10 * 1000); |
- ASSERT_EQ(rc, 0); |
- ASSERT_EQ(g_thread_has_lock, 0); |
- |
- /* |
- * Now make sure the waiting writer doesn't block the recursive acquisition |
- * of the rdlock (using both tryrdlock and rdlock). |
- */ |
- rc = pthread_rwlock_tryrdlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- rc = pthread_rwlock_unlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- ASSERT_EQ(g_thread_has_lock, 0); |
- rc = pthread_rwlock_rdlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- rc = pthread_rwlock_unlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- ASSERT_EQ(g_thread_has_lock, 0); |
- |
- /* |
- * Finally unlock the rdlock which should allow the secondary thread |
- * to acquire the wrlock |
- */ |
- rc = pthread_rwlock_unlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- while (!g_thread_has_lock) { /* Spin. */ } |
- __sync_fetch_and_sub(&g_thread_should_acquire_lock, WRITE_LOCK); |
- ASSERT_EQ(g_thread_should_acquire_lock, 0); |
- |
- tell_thread_to_release_lock(); |
-} |
- |
-void test_multiple_readers(void) { |
- fprintf(stderr, "test_multiple_readers\n"); |
- tell_thread_to_acquire_lock(READ_LOCK); |
- |
- /* |
- * Now attempt to acquire the lock on the main thread. |
- * Since they are both readers this should succeed. |
- * Try with tryrdlock, rdlock and timedrdlock. |
- */ |
- int rc = pthread_rwlock_tryrdlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- rc = pthread_rwlock_unlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- |
- struct timespec t = { 0, 0 }; |
- rc = pthread_rwlock_timedrdlock(&g_rwlock, &t); |
- ASSERT_EQ(rc, 0); |
- rc = pthread_rwlock_unlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- |
- rc = pthread_rwlock_rdlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- rc = pthread_rwlock_unlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- |
- tell_thread_to_release_lock(); |
-} |
- |
-void test_reader_plus_writer(void) { |
- fprintf(stderr, "test_reader_plus_writer\n"); |
- tell_thread_to_acquire_lock(READ_LOCK); |
- |
- /* |
- * Now attempt to acquire the write lock on the main thread. |
- * This should fail. |
- */ |
- int rc = pthread_rwlock_trywrlock(&g_rwlock); |
- ASSERT_EQ(rc, EBUSY); |
- |
- tell_thread_to_release_lock(); |
-} |
- |
-void test_writer_plus_reader(void) { |
- fprintf(stderr, "test_writer_plus_reader\n"); |
- |
- /* |
- * First get the write lock. |
- */ |
- int rc = pthread_rwlock_wrlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- |
- /* |
- * Attempt to acquire read lock should now fail |
- */ |
- rc = pthread_rwlock_tryrdlock(&g_rwlock); |
- ASSERT_EQ(rc, EBUSY); |
- |
- rc = pthread_rwlock_unlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
-} |
- |
-void test_unlocked_with_zero_timestamp(void) { |
- fprintf(stderr, "test_unlocked_with_zero_timestamp\n"); |
- int rc; |
- struct timespec abstime = { 0, 0 }; |
- ASSERT_EQ(g_thread_has_lock, 0); |
- fprintf(stderr, "Trying to lock the unlocked rwlock with a valid " |
- "zero absolute timestamp. " |
- "Expected to succeed instantly since the lock is free.\n"); |
- rc = pthread_rwlock_timedrdlock(&g_rwlock, &abstime); |
- ASSERT_EQ(rc, 0); |
- rc = pthread_rwlock_unlock(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
-} |
- |
-int main(int argc, char **argv) { |
- int rc; |
- fprintf(stderr, "Running...\n"); |
- |
- pthread_rwlockattr_t attrs; |
- rc = pthread_rwlockattr_init(&attrs); |
- ASSERT_EQ(rc, 0); |
- int shared = -1; |
- rc = pthread_rwlockattr_getpshared(&attrs, &shared); |
- ASSERT_EQ(rc, 0); |
- ASSERT_EQ(shared, PTHREAD_PROCESS_PRIVATE); |
- rc = pthread_rwlockattr_setpshared(&attrs, PTHREAD_PROCESS_SHARED); |
- ASSERT_EQ(rc, 0); |
- rc = pthread_rwlockattr_setpshared(&attrs, PTHREAD_PROCESS_PRIVATE); |
- ASSERT_EQ(rc, 0); |
- rc = pthread_rwlock_init(&g_rwlock, &attrs); |
- ASSERT_EQ(rc, 0); |
- rc = pthread_rwlockattr_destroy(&attrs); |
- ASSERT_EQ(rc, 0); |
- |
- pthread_t thread; |
- rc = pthread_create(&thread, NULL, locking_thread, NULL); |
- ASSERT_EQ(rc, 0); |
- fprintf(stderr, "Thread started.\n"); |
- |
- test_unlocked_with_zero_timestamp(); |
- test_multiple_readers(); |
- test_multiple_writers(); |
- test_reader_plus_writer(); |
- test_writer_plus_reader(); |
- test_reader_timedwait(); |
- test_writer_timedwait(); |
- test_recursive_reader(); |
- |
- rc = pthread_rwlock_destroy(&g_rwlock); |
- ASSERT_EQ(rc, 0); |
- fprintf(stderr, "Done.\n"); |
- return 0; |
-} |