Chromium Code Reviews| Index: tests/threads/rwlock_test.c |
| diff --git a/tests/threads/rwlock_test.c b/tests/threads/rwlock_test.c |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..f5c45d1a26a1d96dc30ee341de3ad4b7ba525dc4 |
| --- /dev/null |
| +++ b/tests/threads/rwlock_test.c |
| @@ -0,0 +1,73 @@ |
| +/* |
| + * Copyright (c) 2014 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" |
| + |
| +static pthread_rwlock_t rwlock; |
| +volatile int thread_has_lock = 0; |
| +volatile int thread_should_acquire_lock = 0; |
| +volatile int thread_should_release_lock = 0; |
| + |
| +void *locking_thread(void *unused) { |
| + for (;;) { |
| + while (!thread_should_acquire_lock) { /* Spin. */ } |
| + |
| + ASSERT_EQ(thread_has_lock, 0); |
| + int rc = pthread_rwlock_rdlock(&rwlock); |
| + ASSERT_EQ(rc, 0); |
| + __sync_fetch_and_add(&thread_has_lock, 1); |
| + |
| + while (!thread_should_release_lock) { /* Spin. */ } |
| + |
| + ASSERT_EQ(thread_has_lock, 1); |
| + rc = pthread_rwlock_unlock(&rwlock); |
| + ASSERT_EQ(rc, 0); |
| + __sync_fetch_and_sub(&thread_has_lock, 1); |
| + } |
| + |
| + return NULL; |
| +} |
| + |
| +void test_unlocked_with_zero_timestamp(void) { |
| + int rc; |
| + struct timespec abstime = { 0, 0 }; |
| + ASSERT_EQ(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(&rwlock, &abstime); |
| + ASSERT_EQ(rc, 0); |
| + rc = pthread_rwlock_unlock(&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); |
| + rc = pthread_rwlock_init(&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); |
|
Mark Seaborn
2014/10/02 19:58:51
AFAICT you don't synchronise with this thread, so
|
| + ASSERT_EQ(rc, 0); |
| + fprintf(stderr, "Thread started.\n"); |
| + |
| + test_unlocked_with_zero_timestamp(); |
| + |
| + fprintf(stderr, "Done.\n"); |
| + return 0; |
| +} |