Add Semaphore::TimedWait()

util/synchronization/semaphore_posix.cc

 // Copyright 2014 The Crashpad Authors. 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 "util/misc/clock.h"

[Robert Sesek, 2015/02/10 21:57:07]

The find-copies here sucks.

[Mark Mentovai, 2015/02/10 22:01:45]

Robert Sesek wrote:
Yeah, I left it on because it got the other two files right, but it totally
missed it on this one.

+#include "util/synchronization/semaphore.h"
 
-#include <time.h>
+#include <errno.h>
+
+#include <cmath>
 
 #include "base/logging.h"
 #include "base/posix/eintr_wrapper.h"
-#include "build/build_config.h"
-
-namespace {
-
-const uint64_t kNanosecondsPerSecond = 1E9;
-
-}  // namespace
 
 namespace crashpad {
 
 #if !defined(OS_MACOSX)
 
-uint64_t ClockMonotonicNanoseconds() {
-  timespec now;
-  int rv = clock_gettime(CLOCK_MONOTONIC, &now);
-  DPCHECK(rv == 0) << "clock_gettime";
+Semaphore::Semaphore(int value) {
+  PCHECK(sem_init(&semaphore_, 0, value) == 0) << "sem_init";
+}
 
-  return now.tv_sec * kNanosecondsPerSecond + now.tv_nsec;
+Semaphore::~Semaphore() {
+  PCHECK(sem_destroy(&semaphore_) == 0) << "sem_destroy";
+}
+
+void Semaphore::Wait() {
+  PCHECK(HANDLE_EINTR(sem_wait(&semaphore_)) == 0) << "sem_wait";
+}
+
+bool Semaphore::TimedWait(double seconds) {
+  DCHECK_GE(seconds, 0.0);
+  timespec timeout;
+  timeout.tv_sec = seconds;
+  timeout.tv_nsec = (seconds - trunc(seconds)) * 1E9;
+
+  int rv = HANDLE_EINTR(sem_timedwait(&semaphore_, &timeout));
+  PCHECK(rv == 0 || errno == ETIMEDOUT) << "sem_timedwait";
+  return rv == 0;
+}
+
+void Semaphore::Signal() {
+  PCHECK(sem_post(&semaphore_) == 0) << "sem_post";
 }
 
 #endif
 
-void SleepNanoseconds(uint64_t nanoseconds) {
-  timespec sleep_time;
-  sleep_time.tv_sec = nanoseconds / kNanosecondsPerSecond;
-  sleep_time.tv_nsec = nanoseconds % kNanosecondsPerSecond;
-  int rv = HANDLE_EINTR(nanosleep(&sleep_time, &sleep_time));
-  DPCHECK(rv == 0) << "nanosleep";
-}
-
 }  // namespace crashpad