1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #include "base/condition_variable.h"
10 #include "base/lock.h"
11 #include "base/lock_impl.h"
12 #include "base/logging.h"
13 #include "base/time.h"
16 using base::TimeDelta
;
18 ConditionVariable::ConditionVariable(Lock
* user_lock
)
19 : user_mutex_(user_lock
->lock_impl()->os_lock()) {
20 int rv
= pthread_cond_init(&condition_
, NULL
);
24 ConditionVariable::~ConditionVariable() {
25 int rv
= pthread_cond_destroy(&condition_
);
29 void ConditionVariable::Wait() {
30 int rv
= pthread_cond_wait(&condition_
, user_mutex_
);
34 void ConditionVariable::TimedWait(const TimeDelta
& max_time
) {
35 int64 usecs
= max_time
.InMicroseconds();
37 // The timeout argument to pthread_cond_timedwait is in absolute time.
39 gettimeofday(&now
, NULL
);
41 struct timespec abstime
;
42 abstime
.tv_sec
= now
.tv_sec
+ (usecs
/ Time::kMicrosecondsPerSecond
);
43 abstime
.tv_nsec
= (now
.tv_usec
+ (usecs
% Time::kMicrosecondsPerSecond
)) *
44 Time::kNanosecondsPerMicrosecond
;
45 abstime
.tv_sec
+= abstime
.tv_nsec
/ Time::kNanosecondsPerSecond
;
46 abstime
.tv_nsec
%= Time::kNanosecondsPerSecond
;
47 DCHECK(abstime
.tv_sec
>= now
.tv_sec
); // Overflow paranoia
49 int rv
= pthread_cond_timedwait(&condition_
, user_mutex_
, &abstime
);
50 DCHECK(rv
== 0 || rv
== ETIMEDOUT
);
53 void ConditionVariable::Broadcast() {
54 int rv
= pthread_cond_broadcast(&condition_
);
58 void ConditionVariable::Signal() {
59 int rv
= pthread_cond_signal(&condition_
);