diff options
author | hongbotian <hongbo.tianhongbo@huawei.com> | 2015-11-30 03:10:21 -0500 |
---|---|---|
committer | hongbotian <hongbo.tianhongbo@huawei.com> | 2015-11-30 03:10:21 -0500 |
commit | c0b7206652b2852bc574694e7ba07ba1c2acdc00 (patch) | |
tree | 5cb95cb0e19e03610525903df46279df2c3b7eb1 /rubbos/app/httpd-2.0.64/srclib/apr/test/testlock.c | |
parent | b6d3d6e668b793220f2d3af1bc3e828553dc3fe6 (diff) |
delete app
Change-Id: Id4c572809969ebe89e946e88063eaed262cff3f2
Signed-off-by: hongbotian <hongbo.tianhongbo@huawei.com>
Diffstat (limited to 'rubbos/app/httpd-2.0.64/srclib/apr/test/testlock.c')
-rw-r--r-- | rubbos/app/httpd-2.0.64/srclib/apr/test/testlock.c | 322 |
1 files changed, 0 insertions, 322 deletions
diff --git a/rubbos/app/httpd-2.0.64/srclib/apr/test/testlock.c b/rubbos/app/httpd-2.0.64/srclib/apr/test/testlock.c deleted file mode 100644 index 134426c4..00000000 --- a/rubbos/app/httpd-2.0.64/srclib/apr/test/testlock.c +++ /dev/null @@ -1,322 +0,0 @@ -/* Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include "apr_thread_proc.h" -#include "apr_file_io.h" -#include "apr_thread_mutex.h" -#include "apr_thread_rwlock.h" -#include "apr_thread_cond.h" -#include "apr_errno.h" -#include "apr_general.h" -#include "apr_getopt.h" -#include "test_apr.h" - -#if APR_HAS_THREADS - -#define MAX_ITER 40000 -#define MAX_COUNTER 100000 -#define MAX_RETRY 5 - -static void *APR_THREAD_FUNC thread_rwlock_func(apr_thread_t *thd, void *data); -static void *APR_THREAD_FUNC thread_mutex_function(apr_thread_t *thd, void *data); -static void *APR_THREAD_FUNC thread_cond_producer(apr_thread_t *thd, void *data); -static void *APR_THREAD_FUNC thread_cond_consumer(apr_thread_t *thd, void *data); - -static apr_thread_mutex_t *thread_mutex; -static apr_thread_rwlock_t *rwlock; -static int i = 0, x = 0; - -static int buff[MAX_COUNTER]; - -struct { - apr_thread_mutex_t *mutex; - int nput; - int nval; -} put; - -struct { - apr_thread_mutex_t *mutex; - apr_thread_cond_t *cond; - int nready; -} nready; - -static apr_thread_mutex_t *timeout_mutex; -static apr_thread_cond_t *timeout_cond; - -static void *APR_THREAD_FUNC thread_rwlock_func(apr_thread_t *thd, void *data) -{ - int exitLoop = 1; - - while (1) - { - apr_thread_rwlock_rdlock(rwlock); - if (i == MAX_ITER) - exitLoop = 0; - apr_thread_rwlock_unlock(rwlock); - - if (!exitLoop) - break; - - apr_thread_rwlock_wrlock(rwlock); - if (i != MAX_ITER) - { - i++; - x++; - } - apr_thread_rwlock_unlock(rwlock); - } - return NULL; -} - -static void *APR_THREAD_FUNC thread_mutex_function(apr_thread_t *thd, void *data) -{ - int exitLoop = 1; - - /* slight delay to allow things to settle */ - apr_sleep (1); - - while (1) - { - apr_thread_mutex_lock(thread_mutex); - if (i == MAX_ITER) - exitLoop = 0; - else - { - i++; - x++; - } - apr_thread_mutex_unlock(thread_mutex); - - if (!exitLoop) - break; - } - return NULL; -} - -static void *APR_THREAD_FUNC thread_cond_producer(apr_thread_t *thd, void *data) -{ - for (;;) { - apr_thread_mutex_lock(put.mutex); - if (put.nput >= MAX_COUNTER) { - apr_thread_mutex_unlock(put.mutex); - return NULL; - } - buff[put.nput] = put.nval; - put.nput++; - put.nval++; - apr_thread_mutex_unlock(put.mutex); - - apr_thread_mutex_lock(nready.mutex); - if (nready.nready == 0) - apr_thread_cond_signal(nready.cond); - nready.nready++; - apr_thread_mutex_unlock(nready.mutex); - - *((int *) data) += 1; - } - - return NULL; -} - -static void *APR_THREAD_FUNC thread_cond_consumer(apr_thread_t *thd, void *data) -{ - int i; - - for (i = 0; i < MAX_COUNTER; i++) { - apr_thread_mutex_lock(nready.mutex); - while (nready.nready == 0) - apr_thread_cond_wait(nready.cond, nready.mutex); - nready.nready--; - apr_thread_mutex_unlock(nready.mutex); - - if (buff[i] != i) - printf("buff[%d] = %d\n", i, buff[i]); - } - - return NULL; -} - -static void test_thread_mutex(CuTest *tc) -{ - apr_thread_t *t1, *t2, *t3, *t4; - apr_status_t s1, s2, s3, s4; - - s1 = apr_thread_mutex_create(&thread_mutex, APR_THREAD_MUTEX_DEFAULT, p); - CuAssertIntEquals(tc, APR_SUCCESS, s1); - CuAssertPtrNotNull(tc, thread_mutex); - - i = 0; - x = 0; - - s1 = apr_thread_create(&t1, NULL, thread_mutex_function, NULL, p); - CuAssertIntEquals(tc, APR_SUCCESS, s1); - s2 = apr_thread_create(&t2, NULL, thread_mutex_function, NULL, p); - CuAssertIntEquals(tc, APR_SUCCESS, s2); - s3 = apr_thread_create(&t3, NULL, thread_mutex_function, NULL, p); - CuAssertIntEquals(tc, APR_SUCCESS, s3); - s4 = apr_thread_create(&t4, NULL, thread_mutex_function, NULL, p); - CuAssertIntEquals(tc, APR_SUCCESS, s4); - - apr_thread_join(&s1, t1); - apr_thread_join(&s2, t2); - apr_thread_join(&s3, t3); - apr_thread_join(&s4, t4); - - CuAssertIntEquals(tc, MAX_ITER, x); -} - -static void test_thread_rwlock(CuTest *tc) -{ - apr_thread_t *t1, *t2, *t3, *t4; - apr_status_t s1, s2, s3, s4; - - s1 = apr_thread_rwlock_create(&rwlock, p); - apr_assert_success(tc, "rwlock_create", s1); - CuAssertPtrNotNull(tc, rwlock); - - i = 0; - x = 0; - - s1 = apr_thread_create(&t1, NULL, thread_rwlock_func, NULL, p); - apr_assert_success(tc, "create thread 1", s1); - s2 = apr_thread_create(&t2, NULL, thread_rwlock_func, NULL, p); - apr_assert_success(tc, "create thread 2", s2); - s3 = apr_thread_create(&t3, NULL, thread_rwlock_func, NULL, p); - apr_assert_success(tc, "create thread 3", s3); - s4 = apr_thread_create(&t4, NULL, thread_rwlock_func, NULL, p); - apr_assert_success(tc, "create thread 4", s4); - - apr_thread_join(&s1, t1); - apr_thread_join(&s2, t2); - apr_thread_join(&s3, t3); - apr_thread_join(&s4, t4); - - CuAssertIntEquals(tc, MAX_ITER, x); - - apr_thread_rwlock_destroy(rwlock); -} - -static void test_cond(CuTest *tc) -{ - apr_thread_t *p1, *p2, *p3, *p4, *c1; - apr_status_t s0, s1, s2, s3, s4; - int count1, count2, count3, count4; - int sum; - - s1 = apr_thread_mutex_create(&put.mutex, APR_THREAD_MUTEX_DEFAULT, p); - CuAssertIntEquals(tc, APR_SUCCESS, s1); - CuAssertPtrNotNull(tc, put.mutex); - - s1 = apr_thread_mutex_create(&nready.mutex, APR_THREAD_MUTEX_DEFAULT, p); - CuAssertIntEquals(tc, APR_SUCCESS, s1); - CuAssertPtrNotNull(tc, nready.mutex); - - s1 = apr_thread_cond_create(&nready.cond, p); - CuAssertIntEquals(tc, APR_SUCCESS, s1); - CuAssertPtrNotNull(tc, nready.cond); - - count1 = count2 = count3 = count4 = 0; - put.nput = put.nval = 0; - nready.nready = 0; - i = 0; - x = 0; - - s0 = apr_thread_create(&p1, NULL, thread_cond_producer, &count1, p); - CuAssertIntEquals(tc, APR_SUCCESS, s0); - s1 = apr_thread_create(&p2, NULL, thread_cond_producer, &count2, p); - CuAssertIntEquals(tc, APR_SUCCESS, s1); - s2 = apr_thread_create(&p3, NULL, thread_cond_producer, &count3, p); - CuAssertIntEquals(tc, APR_SUCCESS, s2); - s3 = apr_thread_create(&p4, NULL, thread_cond_producer, &count4, p); - CuAssertIntEquals(tc, APR_SUCCESS, s3); - s4 = apr_thread_create(&c1, NULL, thread_cond_consumer, NULL, p); - CuAssertIntEquals(tc, APR_SUCCESS, s4); - - apr_thread_join(&s0, p1); - apr_thread_join(&s1, p2); - apr_thread_join(&s2, p3); - apr_thread_join(&s3, p4); - apr_thread_join(&s4, c1); - - sum = count1 + count2 + count3 + count4; - /* - printf("count1 = %d count2 = %d count3 = %d count4 = %d\n", - count1, count2, count3, count4); - */ - CuAssertIntEquals(tc, MAX_COUNTER, sum); -} - -static void test_timeoutcond(CuTest *tc) -{ - apr_status_t s; - apr_interval_time_t timeout; - apr_time_t begin, end; - int i; - - s = apr_thread_mutex_create(&timeout_mutex, APR_THREAD_MUTEX_DEFAULT, p); - CuAssertIntEquals(tc, APR_SUCCESS, s); - CuAssertPtrNotNull(tc, timeout_mutex); - - s = apr_thread_cond_create(&timeout_cond, p); - CuAssertIntEquals(tc, APR_SUCCESS, s); - CuAssertPtrNotNull(tc, timeout_cond); - - timeout = apr_time_from_sec(5); - - for (i = 0; i < MAX_RETRY; i++) { - apr_thread_mutex_lock(timeout_mutex); - - begin = apr_time_now(); - s = apr_thread_cond_timedwait(timeout_cond, timeout_mutex, timeout); - end = apr_time_now(); - apr_thread_mutex_unlock(timeout_mutex); - - if (s != APR_SUCCESS && !APR_STATUS_IS_TIMEUP(s)) { - continue; - } - CuAssertIntEquals(tc, 1, APR_STATUS_IS_TIMEUP(s)); - CuAssert(tc, "Timer returned too late", end - begin - timeout < 100000); - break; - } - CuAssert(tc, "Too many retries", i < MAX_RETRY); -} - -#endif /* !APR_HAS_THREADS */ - -#if !APR_HAS_THREADS -static void threads_not_impl(CuTest *tc) -{ - CuNotImpl(tc, "Threads not implemented on this platform"); -} -#endif - - -CuSuite *testlock(void) -{ - CuSuite *suite = CuSuiteNew("Thread Locks"); - -#if !APR_HAS_THREADS - SUITE_ADD_TEST(suite, threads_not_impl); -#else - SUITE_ADD_TEST(suite, test_thread_mutex); - SUITE_ADD_TEST(suite, test_thread_rwlock); - SUITE_ADD_TEST(suite, test_cond); - SUITE_ADD_TEST(suite, test_timeoutcond); -#endif - - return suite; -} - |