| // Copyright 2015 Google Inc. All Rights Reserved. |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| #include "starboard/condition_variable.h" |
| |
| #include <errno.h> |
| #include <pthread.h> |
| #include <time.h> |
| |
| #include "starboard/shared/posix/time_internal.h" |
| #include "starboard/shared/pthread/is_success.h" |
| #include "starboard/shared/starboard/lazy_initialization_internal.h" |
| #include "starboard/time.h" |
| |
| using starboard::shared::starboard::EnsureInitialized; |
| |
| SbConditionVariableResult SbConditionVariableWaitTimed( |
| SbConditionVariable* condition, |
| SbMutex* mutex, |
| SbTime timeout) { |
| if (!condition || !mutex) { |
| return kSbConditionVariableFailed; |
| } |
| |
| if (timeout < 0) { |
| timeout = 0; |
| } |
| |
| #if !SB_HAS_QUIRK(NO_CONDATTR_SETCLOCK_SUPPORT) |
| SbTime timeout_time = SbTimeGetMonotonicNow() + timeout; |
| #else // !SB_HAS_QUIRK(NO_CONDATTR_SETCLOCK_SUPPORT) |
| int64_t timeout_time = SbTimeToPosix(SbTimeGetNow()) + timeout; |
| #endif // !SB_HAS_QUIRK(NO_CONDATTR_SETCLOCK_SUPPORT) |
| |
| // Detect overflow if timeout is near kSbTimeMax. Since timeout can't be |
| // negative at this point, if it goes negative after adding now, we know we've |
| // gone over. Especially posix now, which has a 400 year advantage over |
| // Chromium (Windows) now. |
| if (timeout_time < 0) { |
| timeout_time = kSbInt64Max; |
| } |
| |
| struct timespec timeout_ts; |
| ToTimespec(&timeout_ts, timeout_time); |
| |
| if (!EnsureInitialized(&condition->initialized_state)) { |
| // The condition variable is set to SB_CONDITION_VARIABLE_INITIALIZER and |
| // is uninitialized, so call SbConditionVariableCreate() to initialize the |
| // condition variable. SbConditionVariableCreate() is responsible for |
| // marking the variable as initialized. |
| SbConditionVariableCreate(condition, mutex); |
| } |
| |
| int result = |
| pthread_cond_timedwait(&condition->condition, mutex, &timeout_ts); |
| if (IsSuccess(result)) { |
| return kSbConditionVariableSignaled; |
| } |
| |
| if (result == ETIMEDOUT) { |
| return kSbConditionVariableTimedOut; |
| } |
| |
| return kSbConditionVariableFailed; |
| } |