1640235e2SEnji Cooper /* $NetBSD: t_cond.c,v 1.7 2016/07/03 14:24:59 christos Exp $ */
257718be8SEnji Cooper
357718be8SEnji Cooper /*
457718be8SEnji Cooper * Copyright (c) 2008 The NetBSD Foundation, Inc.
557718be8SEnji Cooper * All rights reserved.
657718be8SEnji Cooper *
757718be8SEnji Cooper * Redistribution and use in source and binary forms, with or without
857718be8SEnji Cooper * modification, are permitted provided that the following conditions
957718be8SEnji Cooper * are met:
1057718be8SEnji Cooper * 1. Redistributions of source code must retain the above copyright
1157718be8SEnji Cooper * notice, this list of conditions and the following disclaimer.
1257718be8SEnji Cooper * 2. Redistributions in binary form must reproduce the above copyright
1357718be8SEnji Cooper * notice, this list of conditions and the following disclaimer in the
1457718be8SEnji Cooper * documentation and/or other materials provided with the distribution.
1557718be8SEnji Cooper *
1657718be8SEnji Cooper * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
1757718be8SEnji Cooper * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
1857718be8SEnji Cooper * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
1957718be8SEnji Cooper * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
2057718be8SEnji Cooper * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
2157718be8SEnji Cooper * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
2257718be8SEnji Cooper * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
2357718be8SEnji Cooper * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
2457718be8SEnji Cooper * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
2557718be8SEnji Cooper * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
2657718be8SEnji Cooper * POSSIBILITY OF SUCH DAMAGE.
2757718be8SEnji Cooper */
2857718be8SEnji Cooper
2957718be8SEnji Cooper #include <sys/cdefs.h>
3057718be8SEnji Cooper __COPYRIGHT("@(#) Copyright (c) 2008\
3157718be8SEnji Cooper The NetBSD Foundation, inc. All rights reserved.");
32640235e2SEnji Cooper __RCSID("$NetBSD: t_cond.c,v 1.7 2016/07/03 14:24:59 christos Exp $");
3357718be8SEnji Cooper
3457718be8SEnji Cooper #include <sys/time.h>
3557718be8SEnji Cooper
3657718be8SEnji Cooper #include <errno.h>
3757718be8SEnji Cooper #include <pthread.h>
3857718be8SEnji Cooper #include <stdio.h>
3957718be8SEnji Cooper #include <unistd.h>
4057718be8SEnji Cooper
4157718be8SEnji Cooper #include <atf-c.h>
4257718be8SEnji Cooper
4357718be8SEnji Cooper #include "h_common.h"
4457718be8SEnji Cooper
4557718be8SEnji Cooper static pthread_mutex_t mutex;
4657718be8SEnji Cooper static pthread_cond_t cond;
4757718be8SEnji Cooper static pthread_mutex_t static_mutex = PTHREAD_MUTEX_INITIALIZER;
4857718be8SEnji Cooper static pthread_cond_t static_cond = PTHREAD_COND_INITIALIZER;
4957718be8SEnji Cooper static int count, share, toggle, total;
5057718be8SEnji Cooper
5157718be8SEnji Cooper static void *
signal_delay_wait_threadfunc(void * arg)5257718be8SEnji Cooper signal_delay_wait_threadfunc(void *arg)
5357718be8SEnji Cooper {
5457718be8SEnji Cooper int *shared = (int *) arg;
5557718be8SEnji Cooper
5657718be8SEnji Cooper printf("2: Second thread.\n");
5757718be8SEnji Cooper
5857718be8SEnji Cooper printf("2: Locking mutex\n");
5957718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
6057718be8SEnji Cooper printf("2: Got mutex.\n");
6157718be8SEnji Cooper printf("Shared value: %d. Changing to 0.\n", *shared);
6257718be8SEnji Cooper *shared = 0;
6357718be8SEnji Cooper
6457718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
6557718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_signal(&cond));
6657718be8SEnji Cooper
6757718be8SEnji Cooper return NULL;
6857718be8SEnji Cooper }
6957718be8SEnji Cooper
7057718be8SEnji Cooper ATF_TC(signal_delay_wait);
ATF_TC_HEAD(signal_delay_wait,tc)7157718be8SEnji Cooper ATF_TC_HEAD(signal_delay_wait, tc)
7257718be8SEnji Cooper {
7357718be8SEnji Cooper atf_tc_set_md_var(tc, "descr", "Checks condition variables");
7457718be8SEnji Cooper }
ATF_TC_BODY(signal_delay_wait,tc)7557718be8SEnji Cooper ATF_TC_BODY(signal_delay_wait, tc)
7657718be8SEnji Cooper {
7757718be8SEnji Cooper pthread_t new;
7857718be8SEnji Cooper void *joinval;
7957718be8SEnji Cooper int sharedval;
8057718be8SEnji Cooper
8157718be8SEnji Cooper printf("1: condition variable test 1\n");
8257718be8SEnji Cooper
8357718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_init(&mutex, NULL));
8457718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_init(&cond, NULL));
8557718be8SEnji Cooper
8657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
8757718be8SEnji Cooper
8857718be8SEnji Cooper sharedval = 1;
8957718be8SEnji Cooper
9057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_create(&new, NULL, signal_delay_wait_threadfunc,
9157718be8SEnji Cooper &sharedval));
9257718be8SEnji Cooper
9357718be8SEnji Cooper printf("1: Before waiting.\n");
9457718be8SEnji Cooper do {
9557718be8SEnji Cooper sleep(2);
9657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_wait(&cond, &mutex));
9757718be8SEnji Cooper printf("1: After waiting, in loop.\n");
9857718be8SEnji Cooper } while (sharedval != 0);
9957718be8SEnji Cooper
10057718be8SEnji Cooper printf("1: After the loop.\n");
10157718be8SEnji Cooper
10257718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
10357718be8SEnji Cooper
10457718be8SEnji Cooper printf("1: After releasing the mutex.\n");
10557718be8SEnji Cooper PTHREAD_REQUIRE(pthread_join(new, &joinval));
10657718be8SEnji Cooper
10757718be8SEnji Cooper printf("1: Thread joined.\n");
10857718be8SEnji Cooper }
10957718be8SEnji Cooper
11057718be8SEnji Cooper static void *
signal_before_unlock_threadfunc(void * arg)11157718be8SEnji Cooper signal_before_unlock_threadfunc(void *arg)
11257718be8SEnji Cooper {
11357718be8SEnji Cooper int *shared = (int *) arg;
11457718be8SEnji Cooper
11557718be8SEnji Cooper printf("2: Second thread.\n");
11657718be8SEnji Cooper
11757718be8SEnji Cooper printf("2: Locking mutex\n");
11857718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
11957718be8SEnji Cooper printf("2: Got mutex.\n");
12057718be8SEnji Cooper printf("Shared value: %d. Changing to 0.\n", *shared);
12157718be8SEnji Cooper *shared = 0;
12257718be8SEnji Cooper
12357718be8SEnji Cooper /* Signal first, then unlock, for a different test than #1. */
12457718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_signal(&cond));
12557718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
12657718be8SEnji Cooper
12757718be8SEnji Cooper return NULL;
12857718be8SEnji Cooper }
12957718be8SEnji Cooper
13057718be8SEnji Cooper ATF_TC(signal_before_unlock);
ATF_TC_HEAD(signal_before_unlock,tc)13157718be8SEnji Cooper ATF_TC_HEAD(signal_before_unlock, tc)
13257718be8SEnji Cooper {
13357718be8SEnji Cooper atf_tc_set_md_var(tc, "descr",
13457718be8SEnji Cooper "Checks condition variables: signal before unlocking mutex");
13557718be8SEnji Cooper }
ATF_TC_BODY(signal_before_unlock,tc)13657718be8SEnji Cooper ATF_TC_BODY(signal_before_unlock, tc)
13757718be8SEnji Cooper {
13857718be8SEnji Cooper pthread_t new;
13957718be8SEnji Cooper void *joinval;
14057718be8SEnji Cooper int sharedval;
14157718be8SEnji Cooper
14257718be8SEnji Cooper printf("1: condition variable test 2\n");
14357718be8SEnji Cooper
14457718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_init(&mutex, NULL));
14557718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_init(&cond, NULL));
14657718be8SEnji Cooper
14757718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
14857718be8SEnji Cooper
14957718be8SEnji Cooper sharedval = 1;
15057718be8SEnji Cooper
15157718be8SEnji Cooper PTHREAD_REQUIRE(pthread_create(&new, NULL,
15257718be8SEnji Cooper signal_before_unlock_threadfunc, &sharedval));
15357718be8SEnji Cooper
15457718be8SEnji Cooper printf("1: Before waiting.\n");
15557718be8SEnji Cooper do {
15657718be8SEnji Cooper sleep(2);
15757718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_wait(&cond, &mutex));
15857718be8SEnji Cooper printf("1: After waiting, in loop.\n");
15957718be8SEnji Cooper } while (sharedval != 0);
16057718be8SEnji Cooper
16157718be8SEnji Cooper printf("1: After the loop.\n");
16257718be8SEnji Cooper
16357718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
16457718be8SEnji Cooper
16557718be8SEnji Cooper printf("1: After releasing the mutex.\n");
16657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_join(new, &joinval));
16757718be8SEnji Cooper
16857718be8SEnji Cooper printf("1: Thread joined.\n");
16957718be8SEnji Cooper }
17057718be8SEnji Cooper
17157718be8SEnji Cooper static void *
signal_before_unlock_static_init_threadfunc(void * arg)17257718be8SEnji Cooper signal_before_unlock_static_init_threadfunc(void *arg)
17357718be8SEnji Cooper {
17457718be8SEnji Cooper int *shared = (int *) arg;
17557718be8SEnji Cooper
17657718be8SEnji Cooper printf("2: Second thread.\n");
17757718be8SEnji Cooper
17857718be8SEnji Cooper printf("2: Locking mutex\n");
17957718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&static_mutex));
18057718be8SEnji Cooper printf("2: Got mutex.\n");
18157718be8SEnji Cooper printf("Shared value: %d. Changing to 0.\n", *shared);
18257718be8SEnji Cooper *shared = 0;
18357718be8SEnji Cooper
18457718be8SEnji Cooper /* Signal first, then unlock, for a different test than #1. */
18557718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_signal(&static_cond));
18657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&static_mutex));
18757718be8SEnji Cooper
18857718be8SEnji Cooper return NULL;
18957718be8SEnji Cooper }
19057718be8SEnji Cooper
19157718be8SEnji Cooper ATF_TC(signal_before_unlock_static_init);
ATF_TC_HEAD(signal_before_unlock_static_init,tc)19257718be8SEnji Cooper ATF_TC_HEAD(signal_before_unlock_static_init, tc)
19357718be8SEnji Cooper {
19457718be8SEnji Cooper atf_tc_set_md_var(tc, "descr",
19557718be8SEnji Cooper "Checks condition variables: signal before unlocking "
19657718be8SEnji Cooper "mutex, use static initializers");
19757718be8SEnji Cooper }
ATF_TC_BODY(signal_before_unlock_static_init,tc)19857718be8SEnji Cooper ATF_TC_BODY(signal_before_unlock_static_init, tc)
19957718be8SEnji Cooper {
20057718be8SEnji Cooper pthread_t new;
20157718be8SEnji Cooper void *joinval;
20257718be8SEnji Cooper int sharedval;
20357718be8SEnji Cooper
20457718be8SEnji Cooper printf("1: condition variable test 3\n");
20557718be8SEnji Cooper
20657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&static_mutex));
20757718be8SEnji Cooper
20857718be8SEnji Cooper sharedval = 1;
20957718be8SEnji Cooper
21057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_create(&new, NULL,
21157718be8SEnji Cooper signal_before_unlock_static_init_threadfunc, &sharedval));
21257718be8SEnji Cooper
21357718be8SEnji Cooper printf("1: Before waiting.\n");
21457718be8SEnji Cooper do {
21557718be8SEnji Cooper sleep(2);
21657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_wait(&static_cond, &static_mutex));
21757718be8SEnji Cooper printf("1: After waiting, in loop.\n");
21857718be8SEnji Cooper } while (sharedval != 0);
21957718be8SEnji Cooper
22057718be8SEnji Cooper printf("1: After the loop.\n");
22157718be8SEnji Cooper
22257718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&static_mutex));
22357718be8SEnji Cooper
22457718be8SEnji Cooper printf("1: After releasing the mutex.\n");
22557718be8SEnji Cooper PTHREAD_REQUIRE(pthread_join(new, &joinval));
22657718be8SEnji Cooper
22757718be8SEnji Cooper printf("1: Thread joined.\n");
22857718be8SEnji Cooper }
22957718be8SEnji Cooper
23057718be8SEnji Cooper static void *
signal_wait_race_threadfunc(void * arg)23157718be8SEnji Cooper signal_wait_race_threadfunc(void *arg)
23257718be8SEnji Cooper {
23357718be8SEnji Cooper printf("2: Second thread.\n");
23457718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&static_mutex));
23557718be8SEnji Cooper printf("2: Before the loop.\n");
23657718be8SEnji Cooper while (count>0) {
23757718be8SEnji Cooper count--;
23857718be8SEnji Cooper total++;
23957718be8SEnji Cooper toggle = 0;
24057718be8SEnji Cooper /* printf("2: Before signal %d.\n", count); */
24157718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_signal(&static_cond));
24257718be8SEnji Cooper do {
24357718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_wait(&static_cond,
24457718be8SEnji Cooper &static_mutex));
24557718be8SEnji Cooper } while (toggle != 1);
24657718be8SEnji Cooper }
24757718be8SEnji Cooper printf("2: After the loop.\n");
24857718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&static_mutex));
24957718be8SEnji Cooper
25057718be8SEnji Cooper return NULL;
25157718be8SEnji Cooper }
25257718be8SEnji Cooper
25357718be8SEnji Cooper ATF_TC(signal_wait_race);
ATF_TC_HEAD(signal_wait_race,tc)25457718be8SEnji Cooper ATF_TC_HEAD(signal_wait_race, tc)
25557718be8SEnji Cooper {
25657718be8SEnji Cooper atf_tc_set_md_var(tc, "descr", "Checks condition variables");
25757718be8SEnji Cooper }
ATF_TC_BODY(signal_wait_race,tc)25857718be8SEnji Cooper ATF_TC_BODY(signal_wait_race, tc)
25957718be8SEnji Cooper {
26057718be8SEnji Cooper pthread_t new;
26157718be8SEnji Cooper void *joinval;
26257718be8SEnji Cooper int sharedval;
26357718be8SEnji Cooper
26457718be8SEnji Cooper printf("1: condition variable test 4\n");
26557718be8SEnji Cooper
26657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&static_mutex));
26757718be8SEnji Cooper
26857718be8SEnji Cooper count = 50000;
26957718be8SEnji Cooper toggle = 0;
27057718be8SEnji Cooper
27157718be8SEnji Cooper PTHREAD_REQUIRE(pthread_create(&new, NULL, signal_wait_race_threadfunc,
27257718be8SEnji Cooper &sharedval));
27357718be8SEnji Cooper
27457718be8SEnji Cooper printf("1: Before waiting.\n");
27557718be8SEnji Cooper while (count>0) {
27657718be8SEnji Cooper count--;
27757718be8SEnji Cooper total++;
27857718be8SEnji Cooper toggle = 1;
27957718be8SEnji Cooper /* printf("1: Before signal %d.\n", count); */
28057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_signal(&static_cond));
28157718be8SEnji Cooper do {
28257718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_wait(&static_cond,
28357718be8SEnji Cooper &static_mutex));
28457718be8SEnji Cooper } while (toggle != 0);
28557718be8SEnji Cooper }
28657718be8SEnji Cooper printf("1: After the loop.\n");
28757718be8SEnji Cooper
28857718be8SEnji Cooper toggle = 1;
28957718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&static_mutex));
29057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_signal(&static_cond));
29157718be8SEnji Cooper
29257718be8SEnji Cooper printf("1: After releasing the mutex.\n");
29357718be8SEnji Cooper PTHREAD_REQUIRE(pthread_join(new, &joinval));
29457718be8SEnji Cooper
29557718be8SEnji Cooper printf("1: Thread joined. Final count = %d, total = %d\n",
29657718be8SEnji Cooper count, total);
29757718be8SEnji Cooper
29857718be8SEnji Cooper ATF_REQUIRE_EQ(count, 0);
29957718be8SEnji Cooper ATF_REQUIRE_EQ(total, 50000);
30057718be8SEnji Cooper }
30157718be8SEnji Cooper
30257718be8SEnji Cooper static void *
pthread_cond_timedwait_func(void * arg)30357718be8SEnji Cooper pthread_cond_timedwait_func(void *arg)
30457718be8SEnji Cooper {
30557718be8SEnji Cooper struct timespec ts;
30657718be8SEnji Cooper size_t i = 0;
30757718be8SEnji Cooper int rv;
30857718be8SEnji Cooper
30957718be8SEnji Cooper for (;;) {
31057718be8SEnji Cooper
31157718be8SEnji Cooper if (i++ >= 10000)
31257718be8SEnji Cooper pthread_exit(NULL);
31357718be8SEnji Cooper
31457718be8SEnji Cooper (void)memset(&ts, 0, sizeof(struct timespec));
31557718be8SEnji Cooper
31657718be8SEnji Cooper ATF_REQUIRE(clock_gettime(CLOCK_REALTIME, &ts) == 0);
31757718be8SEnji Cooper
31857718be8SEnji Cooper /*
31957718be8SEnji Cooper * Set to one second in the past:
32057718be8SEnji Cooper * pthread_cond_timedwait(3) should
32157718be8SEnji Cooper * return ETIMEDOUT immediately.
32257718be8SEnji Cooper */
32357718be8SEnji Cooper ts.tv_sec = ts.tv_sec - 1;
32457718be8SEnji Cooper
32557718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&static_mutex));
32657718be8SEnji Cooper rv = pthread_cond_timedwait(&static_cond, &static_mutex, &ts);
32757718be8SEnji Cooper
32857718be8SEnji Cooper /*
32957718be8SEnji Cooper * Sometimes we catch ESRCH.
33057718be8SEnji Cooper * This should never happen.
33157718be8SEnji Cooper */
33257718be8SEnji Cooper ATF_REQUIRE(rv == ETIMEDOUT);
33357718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&static_mutex));
33457718be8SEnji Cooper }
33557718be8SEnji Cooper }
33657718be8SEnji Cooper
33757718be8SEnji Cooper ATF_TC(cond_timedwait_race);
ATF_TC_HEAD(cond_timedwait_race,tc)33857718be8SEnji Cooper ATF_TC_HEAD(cond_timedwait_race, tc)
33957718be8SEnji Cooper {
34057718be8SEnji Cooper atf_tc_set_md_var(tc, "descr", "Test pthread_cond_timedwait(3)");
34157718be8SEnji Cooper
34257718be8SEnji Cooper }
ATF_TC_BODY(cond_timedwait_race,tc)34357718be8SEnji Cooper ATF_TC_BODY(cond_timedwait_race, tc)
34457718be8SEnji Cooper {
34557718be8SEnji Cooper pthread_t tid[64];
34657718be8SEnji Cooper size_t i;
34757718be8SEnji Cooper
34857718be8SEnji Cooper for (i = 0; i < __arraycount(tid); i++) {
34957718be8SEnji Cooper
35057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_create(&tid[i], NULL,
35157718be8SEnji Cooper pthread_cond_timedwait_func, NULL));
35257718be8SEnji Cooper }
35357718be8SEnji Cooper
35457718be8SEnji Cooper for (i = 0; i < __arraycount(tid); i++) {
35557718be8SEnji Cooper
35657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_join(tid[i], NULL));
35757718be8SEnji Cooper }
35857718be8SEnji Cooper }
35957718be8SEnji Cooper
36057718be8SEnji Cooper static void *
broadcast_threadfunc(void * arg)36157718be8SEnji Cooper broadcast_threadfunc(void *arg)
36257718be8SEnji Cooper {
36357718be8SEnji Cooper printf("2: Second thread.\n");
36457718be8SEnji Cooper
36557718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&static_mutex));
36657718be8SEnji Cooper while (count>0) {
36757718be8SEnji Cooper count--;
36857718be8SEnji Cooper total++;
36957718be8SEnji Cooper toggle = 0;
37057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_signal(&static_cond));
37157718be8SEnji Cooper do {
37257718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_wait(&static_cond,
37357718be8SEnji Cooper &static_mutex));
37457718be8SEnji Cooper } while (toggle != 1);
37557718be8SEnji Cooper }
37657718be8SEnji Cooper printf("2: After the loop.\n");
37757718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&static_mutex));
37857718be8SEnji Cooper
37957718be8SEnji Cooper return NULL;
38057718be8SEnji Cooper }
38157718be8SEnji Cooper
38257718be8SEnji Cooper
38357718be8SEnji Cooper ATF_TC(broadcast);
ATF_TC_HEAD(broadcast,tc)38457718be8SEnji Cooper ATF_TC_HEAD(broadcast, tc)
38557718be8SEnji Cooper {
38657718be8SEnji Cooper atf_tc_set_md_var(tc, "descr",
38757718be8SEnji Cooper "Checks condition variables: use pthread_cond_broadcast()");
38857718be8SEnji Cooper }
ATF_TC_BODY(broadcast,tc)38957718be8SEnji Cooper ATF_TC_BODY(broadcast, tc)
39057718be8SEnji Cooper {
39157718be8SEnji Cooper pthread_t new;
39257718be8SEnji Cooper void *joinval;
39357718be8SEnji Cooper int sharedval;
39457718be8SEnji Cooper
39557718be8SEnji Cooper printf("1: condition variable test 5\n");
39657718be8SEnji Cooper
39757718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&static_mutex));
39857718be8SEnji Cooper
39957718be8SEnji Cooper count = 50000;
40057718be8SEnji Cooper toggle = 0;
40157718be8SEnji Cooper
40257718be8SEnji Cooper PTHREAD_REQUIRE(pthread_create(&new, NULL, broadcast_threadfunc,
40357718be8SEnji Cooper &sharedval));
40457718be8SEnji Cooper
40557718be8SEnji Cooper printf("1: Before waiting.\n");
40657718be8SEnji Cooper while (count>0) {
40757718be8SEnji Cooper count--;
40857718be8SEnji Cooper total++;
40957718be8SEnji Cooper toggle = 1;
41057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_broadcast(&static_cond));
41157718be8SEnji Cooper do {
41257718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_wait(&static_cond,
41357718be8SEnji Cooper &static_mutex));
41457718be8SEnji Cooper } while (toggle != 0);
41557718be8SEnji Cooper }
41657718be8SEnji Cooper printf("1: After the loop.\n");
41757718be8SEnji Cooper
41857718be8SEnji Cooper toggle = 1;
41957718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&static_mutex));
42057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_signal(&static_cond));
42157718be8SEnji Cooper
42257718be8SEnji Cooper printf("1: After releasing the mutex.\n");
42357718be8SEnji Cooper PTHREAD_REQUIRE(pthread_join(new, &joinval));
42457718be8SEnji Cooper
42557718be8SEnji Cooper printf("1: Thread joined. Final count = %d, total = %d\n", count,
42657718be8SEnji Cooper total);
42757718be8SEnji Cooper
42857718be8SEnji Cooper ATF_REQUIRE_EQ(count, 0);
42957718be8SEnji Cooper ATF_REQUIRE_EQ(total, 50000);
43057718be8SEnji Cooper }
43157718be8SEnji Cooper
43257718be8SEnji Cooper static void *
bogus_timedwaits_threadfunc(void * arg)43357718be8SEnji Cooper bogus_timedwaits_threadfunc(void *arg)
43457718be8SEnji Cooper {
43557718be8SEnji Cooper return NULL;
43657718be8SEnji Cooper }
43757718be8SEnji Cooper
43857718be8SEnji Cooper ATF_TC(bogus_timedwaits);
ATF_TC_HEAD(bogus_timedwaits,tc)43957718be8SEnji Cooper ATF_TC_HEAD(bogus_timedwaits, tc)
44057718be8SEnji Cooper {
44157718be8SEnji Cooper atf_tc_set_md_var(tc, "descr",
44257718be8SEnji Cooper "Checks condition variables: bogus timedwaits");
44357718be8SEnji Cooper }
ATF_TC_BODY(bogus_timedwaits,tc)44457718be8SEnji Cooper ATF_TC_BODY(bogus_timedwaits, tc)
44557718be8SEnji Cooper {
44657718be8SEnji Cooper pthread_t new;
44757718be8SEnji Cooper struct timespec ts;
44857718be8SEnji Cooper struct timeval tv;
44957718be8SEnji Cooper
45057718be8SEnji Cooper printf("condition variable test 6: bogus timedwaits\n");
45157718be8SEnji Cooper
45257718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&static_mutex));
45357718be8SEnji Cooper
45457718be8SEnji Cooper printf("unthreaded test (past)\n");
45557718be8SEnji Cooper gettimeofday(&tv, NULL);
45657718be8SEnji Cooper tv.tv_sec -= 2; /* Place the time in the past */
45757718be8SEnji Cooper TIMEVAL_TO_TIMESPEC(&tv, &ts);
45857718be8SEnji Cooper
45957718be8SEnji Cooper ATF_REQUIRE_EQ_MSG(pthread_cond_timedwait(&static_cond, &static_mutex,
46057718be8SEnji Cooper &ts), ETIMEDOUT, "pthread_cond_timedwait() (unthreaded) in the "
46157718be8SEnji Cooper "past");
46257718be8SEnji Cooper
46357718be8SEnji Cooper printf("unthreaded test (zero time)\n");
46457718be8SEnji Cooper tv.tv_sec = 0;
46557718be8SEnji Cooper tv.tv_usec = 0;
46657718be8SEnji Cooper TIMEVAL_TO_TIMESPEC(&tv, &ts);
46757718be8SEnji Cooper
46857718be8SEnji Cooper ATF_REQUIRE_EQ_MSG(pthread_cond_timedwait(&static_cond, &static_mutex,
46957718be8SEnji Cooper &ts), ETIMEDOUT, "pthread_cond_timedwait() (unthreaded) with zero "
47057718be8SEnji Cooper "time");
47157718be8SEnji Cooper
47257718be8SEnji Cooper PTHREAD_REQUIRE(pthread_create(&new, NULL, bogus_timedwaits_threadfunc,
47357718be8SEnji Cooper NULL));
47457718be8SEnji Cooper PTHREAD_REQUIRE(pthread_join(new, NULL));
47557718be8SEnji Cooper
47657718be8SEnji Cooper printf("threaded test\n");
47757718be8SEnji Cooper gettimeofday(&tv, NULL);
47857718be8SEnji Cooper tv.tv_sec -= 2; /* Place the time in the past */
47957718be8SEnji Cooper TIMEVAL_TO_TIMESPEC(&tv, &ts);
48057718be8SEnji Cooper
48157718be8SEnji Cooper ATF_REQUIRE_EQ_MSG(pthread_cond_timedwait(&static_cond, &static_mutex,
48257718be8SEnji Cooper &ts), ETIMEDOUT, "pthread_cond_timedwait() (threaded) in the past");
48357718be8SEnji Cooper
48457718be8SEnji Cooper printf("threaded test (zero time)\n");
48557718be8SEnji Cooper tv.tv_sec = 0;
48657718be8SEnji Cooper tv.tv_usec = 0;
48757718be8SEnji Cooper TIMEVAL_TO_TIMESPEC(&tv, &ts);
48857718be8SEnji Cooper
48957718be8SEnji Cooper ATF_REQUIRE_EQ_MSG(pthread_cond_timedwait(&static_cond, &static_mutex,
49057718be8SEnji Cooper &ts), ETIMEDOUT, "pthread_cond_timedwait() (threaded) with zero "
49157718be8SEnji Cooper "time");
49257718be8SEnji Cooper
49357718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&static_mutex));
49457718be8SEnji Cooper }
49557718be8SEnji Cooper
496b16150eaSMark Johnston #ifdef __FreeBSD__
497b16150eaSMark Johnston static void *
destroy_busy_threadfunc(void * arg)498b16150eaSMark Johnston destroy_busy_threadfunc(void *arg)
499b16150eaSMark Johnston {
500b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
501b16150eaSMark Johnston
502b16150eaSMark Johnston share = 1;
503b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_broadcast(&cond));
504b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_wait(&cond, &mutex));
505b16150eaSMark Johnston
506b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
507b16150eaSMark Johnston
508b16150eaSMark Johnston return NULL;
509b16150eaSMark Johnston }
510b16150eaSMark Johnston
511b16150eaSMark Johnston ATF_TC(destroy_busy);
ATF_TC_HEAD(destroy_busy,tc)512b16150eaSMark Johnston ATF_TC_HEAD(destroy_busy, tc)
513b16150eaSMark Johnston {
514b16150eaSMark Johnston atf_tc_set_md_var(tc, "descr", "Checks non-standard behaviour of "
515b16150eaSMark Johnston "returning EBUSY when attempting to destroy an active condvar");
516b16150eaSMark Johnston }
ATF_TC_BODY(destroy_busy,tc)517b16150eaSMark Johnston ATF_TC_BODY(destroy_busy, tc)
518b16150eaSMark Johnston {
519b16150eaSMark Johnston pthread_t thread;
520b16150eaSMark Johnston
521b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_init(&mutex, NULL));
522b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_init(&cond, NULL));
523b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
524b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_create(&thread, NULL, destroy_busy_threadfunc,
525b16150eaSMark Johnston NULL));
526b16150eaSMark Johnston
527b16150eaSMark Johnston while (share == 0) {
528b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_wait(&cond, &mutex));
529b16150eaSMark Johnston }
530b16150eaSMark Johnston
531b16150eaSMark Johnston PTHREAD_REQUIRE_STATUS(pthread_cond_destroy(&cond), EBUSY);
532b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_signal(&cond));
533b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_destroy(&cond));
534b16150eaSMark Johnston
535b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
536b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_join(thread, NULL));
537b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_destroy(&mutex));
538b16150eaSMark Johnston }
539b16150eaSMark Johnston #endif
540b16150eaSMark Johnston
54157718be8SEnji Cooper static void
unlock(void * arg)54257718be8SEnji Cooper unlock(void *arg)
54357718be8SEnji Cooper {
54457718be8SEnji Cooper pthread_mutex_unlock((pthread_mutex_t *)arg);
54557718be8SEnji Cooper }
54657718be8SEnji Cooper
54757718be8SEnji Cooper static void *
destroy_after_cancel_threadfunc(void * arg)54857718be8SEnji Cooper destroy_after_cancel_threadfunc(void *arg)
54957718be8SEnji Cooper {
55057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
55157718be8SEnji Cooper
55257718be8SEnji Cooper pthread_cleanup_push(unlock, &mutex);
55357718be8SEnji Cooper
55457718be8SEnji Cooper while (1) {
55557718be8SEnji Cooper share = 1;
55657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_broadcast(&cond));
55757718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_wait(&cond, &mutex));
55857718be8SEnji Cooper }
55957718be8SEnji Cooper
56057718be8SEnji Cooper pthread_cleanup_pop(0);
56157718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
56257718be8SEnji Cooper
56357718be8SEnji Cooper return NULL;
56457718be8SEnji Cooper }
56557718be8SEnji Cooper
56657718be8SEnji Cooper ATF_TC(destroy_after_cancel);
ATF_TC_HEAD(destroy_after_cancel,tc)56757718be8SEnji Cooper ATF_TC_HEAD(destroy_after_cancel, tc)
56857718be8SEnji Cooper {
56957718be8SEnji Cooper atf_tc_set_md_var(tc, "descr", "Checks destroying a condition variable "
57057718be8SEnji Cooper "after cancelling a wait");
57157718be8SEnji Cooper }
ATF_TC_BODY(destroy_after_cancel,tc)57257718be8SEnji Cooper ATF_TC_BODY(destroy_after_cancel, tc)
57357718be8SEnji Cooper {
57457718be8SEnji Cooper pthread_t thread;
57557718be8SEnji Cooper
57657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_init(&mutex, NULL));
57757718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_init(&cond, NULL));
57857718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
57957718be8SEnji Cooper PTHREAD_REQUIRE(pthread_create(&thread, NULL,
58057718be8SEnji Cooper destroy_after_cancel_threadfunc, NULL));
58157718be8SEnji Cooper
58257718be8SEnji Cooper while (share == 0) {
58357718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_wait(&cond, &mutex));
58457718be8SEnji Cooper }
58557718be8SEnji Cooper
58657718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
58757718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cancel(thread));
58857718be8SEnji Cooper
58957718be8SEnji Cooper PTHREAD_REQUIRE(pthread_join(thread, NULL));
59057718be8SEnji Cooper PTHREAD_REQUIRE(pthread_cond_destroy(&cond));
59157718be8SEnji Cooper
59257718be8SEnji Cooper PTHREAD_REQUIRE(pthread_mutex_destroy(&mutex));
59357718be8SEnji Cooper }
59457718be8SEnji Cooper
595b16150eaSMark Johnston static void *
destroy_after_signal_threadfunc(void * arg)596b16150eaSMark Johnston destroy_after_signal_threadfunc(void *arg)
597b16150eaSMark Johnston {
598b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
599b16150eaSMark Johnston
600b16150eaSMark Johnston share = 1;
601b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_broadcast(&cond));
602b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_wait(&cond, &mutex));
603b16150eaSMark Johnston
604b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
605b16150eaSMark Johnston
606b16150eaSMark Johnston return NULL;
607b16150eaSMark Johnston }
608b16150eaSMark Johnston
609b16150eaSMark Johnston ATF_TC(destroy_after_signal);
ATF_TC_HEAD(destroy_after_signal,tc)610b16150eaSMark Johnston ATF_TC_HEAD(destroy_after_signal, tc)
611b16150eaSMark Johnston {
612b16150eaSMark Johnston atf_tc_set_md_var(tc, "descr", "Checks destroying a condition variable "
613b16150eaSMark Johnston "immediately after signaling waiters");
614b16150eaSMark Johnston }
ATF_TC_BODY(destroy_after_signal,tc)615b16150eaSMark Johnston ATF_TC_BODY(destroy_after_signal, tc)
616b16150eaSMark Johnston {
617b16150eaSMark Johnston pthread_t thread;
618b16150eaSMark Johnston
619b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_init(&mutex, NULL));
620b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_init(&cond, NULL));
621b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_lock(&mutex));
622b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_create(&thread, NULL,
623b16150eaSMark Johnston destroy_after_signal_threadfunc, NULL));
624b16150eaSMark Johnston
625b16150eaSMark Johnston while (share == 0) {
626b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_wait(&cond, &mutex));
627b16150eaSMark Johnston }
628b16150eaSMark Johnston
629b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_signal(&cond));
630b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_cond_destroy(&cond));
631b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex));
632b16150eaSMark Johnston
633b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_join(thread, NULL));
634b16150eaSMark Johnston
635b16150eaSMark Johnston PTHREAD_REQUIRE(pthread_mutex_destroy(&mutex));
636b16150eaSMark Johnston }
637b16150eaSMark Johnston
638640235e2SEnji Cooper ATF_TC(condattr);
ATF_TC_HEAD(condattr,tc)639640235e2SEnji Cooper ATF_TC_HEAD(condattr, tc)
640640235e2SEnji Cooper {
641640235e2SEnji Cooper atf_tc_set_md_var(tc, "descr", "Checks Condattr");
642640235e2SEnji Cooper }
ATF_TC_BODY(condattr,tc)643640235e2SEnji Cooper ATF_TC_BODY(condattr, tc)
644640235e2SEnji Cooper {
645640235e2SEnji Cooper pthread_condattr_t condattr;
646640235e2SEnji Cooper clockid_t clockid;
647640235e2SEnji Cooper
648640235e2SEnji Cooper PTHREAD_REQUIRE(pthread_condattr_init(&condattr));
649640235e2SEnji Cooper PTHREAD_REQUIRE(pthread_condattr_setclock(&condattr, CLOCK_REALTIME));
650640235e2SEnji Cooper PTHREAD_REQUIRE(pthread_condattr_getclock(&condattr, &clockid));
651640235e2SEnji Cooper ATF_REQUIRE_EQ(clockid, CLOCK_REALTIME);
652640235e2SEnji Cooper
653640235e2SEnji Cooper PTHREAD_REQUIRE(pthread_condattr_setclock(&condattr, CLOCK_MONOTONIC));
654640235e2SEnji Cooper PTHREAD_REQUIRE(pthread_condattr_getclock(&condattr, &clockid));
655640235e2SEnji Cooper ATF_REQUIRE_EQ(clockid, CLOCK_MONOTONIC);
656640235e2SEnji Cooper }
657640235e2SEnji Cooper
ATF_TP_ADD_TCS(tp)65857718be8SEnji Cooper ATF_TP_ADD_TCS(tp)
65957718be8SEnji Cooper {
66057718be8SEnji Cooper
66157718be8SEnji Cooper ATF_TP_ADD_TC(tp, signal_delay_wait);
66257718be8SEnji Cooper ATF_TP_ADD_TC(tp, signal_before_unlock);
66357718be8SEnji Cooper ATF_TP_ADD_TC(tp, signal_before_unlock_static_init);
66457718be8SEnji Cooper ATF_TP_ADD_TC(tp, signal_wait_race);
66557718be8SEnji Cooper ATF_TP_ADD_TC(tp, cond_timedwait_race);
66657718be8SEnji Cooper ATF_TP_ADD_TC(tp, broadcast);
66757718be8SEnji Cooper ATF_TP_ADD_TC(tp, bogus_timedwaits);
668b16150eaSMark Johnston #ifdef __FreeBSD__
669b16150eaSMark Johnston ATF_TP_ADD_TC(tp, destroy_busy);
670b16150eaSMark Johnston #endif
67157718be8SEnji Cooper ATF_TP_ADD_TC(tp, destroy_after_cancel);
672b16150eaSMark Johnston ATF_TP_ADD_TC(tp, destroy_after_signal);
673640235e2SEnji Cooper ATF_TP_ADD_TC(tp, condattr);
67457718be8SEnji Cooper
67557718be8SEnji Cooper return atf_no_error();
67657718be8SEnji Cooper }
677