123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293 |
- #include "rsSignal.h"
- #include <errno.h>
- namespace android {
- namespace renderscript {
- Signal::Signal() {
- mSet = true;
- }
- Signal::~Signal() {
- pthread_mutex_destroy(&mMutex);
- pthread_cond_destroy(&mCondition);
- }
- bool Signal::init() {
- int status = pthread_mutex_init(&mMutex, nullptr);
- if (status) {
- ALOGE("Signal::init: mutex init failure: %s", strerror(status));
- return false;
- }
- status = pthread_cond_init(&mCondition, nullptr);
- if (status) {
- ALOGE("Signal::init: condition init failure: %s", strerror(status));
- pthread_mutex_destroy(&mMutex);
- return false;
- }
- return true;
- }
- void Signal::set() {
- int status = pthread_mutex_lock(&mMutex);
- if (status) {
- ALOGE("Signal::set: error locking for set condition: %s", strerror(status));
- return;
- }
- mSet = true;
- status = pthread_cond_signal(&mCondition);
- if (status) {
- ALOGE("Signal::set: error on set condition: %s", strerror(status));
- }
- status = pthread_mutex_unlock(&mMutex);
- if (status) {
- ALOGE("Signal::set: error unlocking for set condition: %s", strerror(status));
- }
- }
- void Signal::wait() {
- int status = pthread_mutex_lock(&mMutex);
- if (status) {
- ALOGE("Signal::wait: error locking for condition: %s", strerror(status));
- return;
- }
- if (!mSet) {
- status = pthread_cond_wait(&mCondition, &mMutex);
- }
- if (!status) {
- mSet = false;
- } else {
- ALOGE("Signal::wait: error waiting for condition: %s", strerror(status));
- }
- status = pthread_mutex_unlock(&mMutex);
- if (status) {
- ALOGE("Signal::wait: error unlocking for condition: %s", strerror(status));
- }
- }
- }
- }
|