test/synchronized.m

   1 // TEST_CONFIG
   2
   3 #include "test.h"
   4
   5 #include <Foundation/NSObject.h>
   6 #include <mach/mach.h>
   7 #include <pthread.h>
   8 #include <sys/time.h>
   9 #include <objc/runtime.h>
  10 #include <objc/objc-sync.h>
  11
  12 // Basic @synchronized tests.
  13
  14
  15 #define WAIT_SEC 3
  16
  17 static id obj;
  18 static semaphore_t go;
  19 static semaphore_t stop;
  20
  21 void *thread(void *arg __unused)
  22 {
  23     int err;
  24
  25     // non-blocking sync_enter
  26     err = objc_sync_enter(obj);
  27     testassert(err == OBJC_SYNC_SUCCESS);
  28
  29     semaphore_signal(go);
  30     // main thread: sync_exit of object locked on some other thread
  31     semaphore_wait(stop);
  32
  33     err = objc_sync_exit(obj);
  34     testassert(err == OBJC_SYNC_SUCCESS);
  35     err = objc_sync_enter(obj);
  36     testassert(err == OBJC_SYNC_SUCCESS);
  37
  38     semaphore_signal(go);
  39     // main thread: blocking sync_enter
  40     testassert(WAIT_SEC/3*3 == WAIT_SEC);
  41     sleep(WAIT_SEC/3);
  42     // recursive enter while someone waits
  43     err = objc_sync_enter(obj);
  44     testassert(err == OBJC_SYNC_SUCCESS);
  45     sleep(WAIT_SEC/3);
  46     // recursive exit while someone waits
  47     err = objc_sync_exit(obj);
  48     testassert(err == OBJC_SYNC_SUCCESS);
  49     sleep(WAIT_SEC/3);
  50     // sync_exit while someone waits
  51     err = objc_sync_exit(obj);
  52     testassert(err == OBJC_SYNC_SUCCESS);
  53
  54     return NULL;
  55 }
  56
  57 int main()
  58 {
  59     pthread_t th;
  60     int err;
  61     struct timeval start, end;
  62
  63     obj = [[NSObject alloc] init];
  64
  65     // sync_exit of never-locked object
  66     err = objc_sync_exit(obj);
  67     testassert(err == OBJC_SYNC_NOT_OWNING_THREAD_ERROR);
  68
  69     semaphore_create(mach_task_self(), &go, 0, 0);
  70     semaphore_create(mach_task_self(), &stop, 0, 0);
  71     pthread_create(&th, NULL, &thread, NULL);
  72     semaphore_wait(go);
  73
  74     // sync_exit of object locked on some other thread
  75     err = objc_sync_exit(obj);
  76     testassert(err == OBJC_SYNC_NOT_OWNING_THREAD_ERROR);
  77
  78     semaphore_signal(stop);
  79     semaphore_wait(go);
  80
  81     // blocking sync_enter
  82     gettimeofday(&start, NULL);
  83     err = objc_sync_enter(obj);
  84     gettimeofday(&end, NULL);
  85     testassert(err == OBJC_SYNC_SUCCESS);
  86     // should have waited more than WAIT_SEC but less than WAIT_SEC+1
  87     // fixme hack: sleep(1) is ending 500 usec too early on x86_64 buildbot
  88     // (rdar://6456975)
  89     testassert(end.tv_sec*1000000LL+end.tv_usec >=
  90                start.tv_sec*1000000LL+start.tv_usec + WAIT_SEC*1000000LL
  91                - 3*500 /*hack*/);
  92     testassert(end.tv_sec*1000000LL+end.tv_usec <
  93                start.tv_sec*1000000LL+start.tv_usec + (1+WAIT_SEC)*1000000LL);
  94
  95     err = objc_sync_exit(obj);
  96     testassert(err == OBJC_SYNC_SUCCESS);
  97
  98     err = objc_sync_exit(obj);
  99     testassert(err == OBJC_SYNC_NOT_OWNING_THREAD_ERROR);
 100
 101     succeed(__FILE__);
 102 }