tools/regression/pthread/cv_cancel1/cv_cancel1.c

   1 /*-
   2  * Copyright (c) 2006, David Xu <davidxu@freebsd.org>
   3  * All rights reserved.
   4  *
   5  * Redistribution and use in source and binary forms, with or without
   6  * modification, are permitted provided that the following conditions
   7  * are met:
   8  * 1. Redistributions of source code must retain the above copyright
   9  *    notice unmodified, this list of conditions, and the following
  10  *    disclaimer.
  11  * 2. Redistributions in binary form must reproduce the above copyright
  12  *    notice, this list of conditions and the following disclaimer in the
  13  *    documentation and/or other materials provided with the distribution.
  14  *
  15  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
  16  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  17  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
  18  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
  19  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
  20  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  21  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  22  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  23  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
  24  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  25  *
  26  * $FreeBSD$
  27  *
  28  */
  29 #include <pthread.h>
  30 #include <stdio.h>
  31 #include <unistd.h>
  32
  33 #define NLOOPS  10
  34
  35 pthread_mutex_t m = PTHREAD_MUTEX_INITIALIZER;
  36 pthread_cond_t cv = PTHREAD_COND_INITIALIZER;
  37
  38 int wake;
  39 int stop;
  40
  41 void *
  42 thr_routine(void *arg)
  43 {
  44         pthread_mutex_lock(&m);
  45         while (wake == 0)
  46                 pthread_cond_wait(&cv, &m);
  47         pthread_mutex_unlock(&m);
  48
  49         while (stop == 0)
  50                 pthread_yield();
  51         return (NULL);
  52 }
  53
  54 int main(int argc, char **argv)
  55 {
  56         pthread_t td;
  57         int i;
  58         void *result;
  59
  60         pthread_setconcurrency(1);
  61         for (i = 0; i < NLOOPS; ++i) {
  62                 stop = 0;
  63                 wake = 0;
  64
  65                 pthread_create(&td, NULL, thr_routine, NULL);
  66                 sleep(1);
  67                 printf("trying: %d\n", i);
  68                 pthread_mutex_lock(&m);
  69                 wake = 1;
  70                 pthread_cond_signal(&cv);
  71                 pthread_cancel(td);
  72                 pthread_mutex_unlock(&m);
  73                 stop = 1;
  74                 result = NULL;
  75                 pthread_join(td, &result);
  76                 if (result == PTHREAD_CANCELED) {
  77                         printf("the condition variable implementation does not\n"
  78                                "conform to SUSv3, a thread unblocked from\n"
  79                                "condition variable still can be canceled.\n");
  80                         return (1);
  81                 }
  82         }
  83
  84         printf("OK\n");
  85         return (0);
  86 }