src/leveldb/port/port_posix.cc

   1 // Copyright (c) 2011 The LevelDB 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. See the AUTHORS file for names of contributors.
   4
   5 #include "port/port_posix.h"
   6
   7 #include <cstdlib>
   8 #include <stdio.h>
   9 #include <string.h>
  10 #include "util/logging.h"
  11
  12 namespace leveldb {
  13 namespace port {
  14
  15 static void PthreadCall(const char* label, int result) {
  16   if (result != 0) {
  17     fprintf(stderr, "pthread %s: %s\n", label, strerror(result));
  18     abort();
  19   }
  20 }
  21
  22 Mutex::Mutex() { PthreadCall("init mutex", pthread_mutex_init(&mu_, NULL)); }
  23
  24 Mutex::~Mutex() { PthreadCall("destroy mutex", pthread_mutex_destroy(&mu_)); }
  25
  26 void Mutex::Lock() { PthreadCall("lock", pthread_mutex_lock(&mu_)); }
  27
  28 void Mutex::Unlock() { PthreadCall("unlock", pthread_mutex_unlock(&mu_)); }
  29
  30 CondVar::CondVar(Mutex* mu)
  31     : mu_(mu) {
  32     PthreadCall("init cv", pthread_cond_init(&cv_, NULL));
  33 }
  34
  35 CondVar::~CondVar() { PthreadCall("destroy cv", pthread_cond_destroy(&cv_)); }
  36
  37 void CondVar::Wait() {
  38   PthreadCall("wait", pthread_cond_wait(&cv_, &mu_->mu_));
  39 }
  40
  41 void CondVar::Signal() {
  42   PthreadCall("signal", pthread_cond_signal(&cv_));
  43 }
  44
  45 void CondVar::SignalAll() {
  46   PthreadCall("broadcast", pthread_cond_broadcast(&cv_));
  47 }
  48
  49 void InitOnce(OnceType* once, void (*initializer)()) {
  50   PthreadCall("once", pthread_once(once, initializer));
  51 }
  52
  53 }  // namespace port
  54 }  // namespace leveldb