| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright 2012 Google Inc. | 2 * Copyright 2012 Google Inc. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license that can be | 4 * Use of this source code is governed by a BSD-style license that can be |
| 5 * found in the LICENSE file. | 5 * found in the LICENSE file. |
| 6 */ | 6 */ |
| 7 | 7 |
| 8 #include "SkCondVar.h" | 8 #include "CondVar.h" |
| 9 | 9 |
| 10 SkCondVar::SkCondVar() { | 10 CondVar::CondVar() { |
| 11 #ifdef SK_USE_POSIX_THREADS | 11 #ifdef SK_USE_POSIX_THREADS |
| 12 pthread_mutex_init(&fMutex, NULL /* default mutex attr */); | 12 pthread_mutex_init(&fMutex, NULL /* default mutex attr */); |
| 13 pthread_cond_init(&fCond, NULL /* default cond attr */); | 13 pthread_cond_init(&fCond, NULL /* default cond attr */); |
| 14 #elif defined(SK_BUILD_FOR_WIN32) | 14 #elif defined(SK_BUILD_FOR_WIN32) |
| 15 InitializeCriticalSection(&fCriticalSection); | 15 InitializeCriticalSection(&fCriticalSection); |
| 16 InitializeConditionVariable(&fCondition); | 16 InitializeConditionVariable(&fCondition); |
| 17 #endif | 17 #endif |
| 18 } | 18 } |
| 19 | 19 |
| 20 SkCondVar::~SkCondVar() { | 20 CondVar::~CondVar() { |
| 21 #ifdef SK_USE_POSIX_THREADS | 21 #ifdef SK_USE_POSIX_THREADS |
| 22 pthread_mutex_destroy(&fMutex); | 22 pthread_mutex_destroy(&fMutex); |
| 23 pthread_cond_destroy(&fCond); | 23 pthread_cond_destroy(&fCond); |
| 24 #elif defined(SK_BUILD_FOR_WIN32) | 24 #elif defined(SK_BUILD_FOR_WIN32) |
| 25 DeleteCriticalSection(&fCriticalSection); | 25 DeleteCriticalSection(&fCriticalSection); |
| 26 // No need to clean up fCondition. | 26 // No need to clean up fCondition. |
| 27 #endif | 27 #endif |
| 28 } | 28 } |
| 29 | 29 |
| 30 void SkCondVar::lock() { | 30 void CondVar::lock() { |
| 31 #ifdef SK_USE_POSIX_THREADS | 31 #ifdef SK_USE_POSIX_THREADS |
| 32 pthread_mutex_lock(&fMutex); | 32 pthread_mutex_lock(&fMutex); |
| 33 #elif defined(SK_BUILD_FOR_WIN32) | 33 #elif defined(SK_BUILD_FOR_WIN32) |
| 34 EnterCriticalSection(&fCriticalSection); | 34 EnterCriticalSection(&fCriticalSection); |
| 35 #endif | 35 #endif |
| 36 } | 36 } |
| 37 | 37 |
| 38 void SkCondVar::unlock() { | 38 void CondVar::unlock() { |
| 39 #ifdef SK_USE_POSIX_THREADS | 39 #ifdef SK_USE_POSIX_THREADS |
| 40 pthread_mutex_unlock(&fMutex); | 40 pthread_mutex_unlock(&fMutex); |
| 41 #elif defined(SK_BUILD_FOR_WIN32) | 41 #elif defined(SK_BUILD_FOR_WIN32) |
| 42 LeaveCriticalSection(&fCriticalSection); | 42 LeaveCriticalSection(&fCriticalSection); |
| 43 #endif | 43 #endif |
| 44 } | 44 } |
| 45 | 45 |
| 46 void SkCondVar::wait() { | 46 void CondVar::wait() { |
| 47 #ifdef SK_USE_POSIX_THREADS | 47 #ifdef SK_USE_POSIX_THREADS |
| 48 pthread_cond_wait(&fCond, &fMutex); | 48 pthread_cond_wait(&fCond, &fMutex); |
| 49 #elif defined(SK_BUILD_FOR_WIN32) | 49 #elif defined(SK_BUILD_FOR_WIN32) |
| 50 SleepConditionVariableCS(&fCondition, &fCriticalSection, INFINITE); | 50 SleepConditionVariableCS(&fCondition, &fCriticalSection, INFINITE); |
| 51 #endif | 51 #endif |
| 52 } | 52 } |
| 53 | 53 |
| 54 void SkCondVar::signal() { | 54 void CondVar::signal() { |
| 55 #ifdef SK_USE_POSIX_THREADS | 55 #ifdef SK_USE_POSIX_THREADS |
| 56 pthread_cond_signal(&fCond); | 56 pthread_cond_signal(&fCond); |
| 57 #elif defined(SK_BUILD_FOR_WIN32) | 57 #elif defined(SK_BUILD_FOR_WIN32) |
| 58 WakeConditionVariable(&fCondition); | 58 WakeConditionVariable(&fCondition); |
| 59 #endif | 59 #endif |
| 60 } | 60 } |
| 61 | 61 |
| 62 void SkCondVar::broadcast() { | 62 void CondVar::broadcast() { |
| 63 #ifdef SK_USE_POSIX_THREADS | 63 #ifdef SK_USE_POSIX_THREADS |
| 64 pthread_cond_broadcast(&fCond); | 64 pthread_cond_broadcast(&fCond); |
| 65 #elif defined(SK_BUILD_FOR_WIN32) | 65 #elif defined(SK_BUILD_FOR_WIN32) |
| 66 WakeAllConditionVariable(&fCondition); | 66 WakeAllConditionVariable(&fCondition); |
| 67 #endif | 67 #endif |
| 68 } | 68 } |
| OLD | NEW |