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
PthreadCall(const char * label,int result)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
Mutex()22 Mutex::Mutex() { PthreadCall("init mutex", pthread_mutex_init(&mu_, NULL)); }
23
~Mutex()24 Mutex::~Mutex() { PthreadCall("destroy mutex", pthread_mutex_destroy(&mu_)); }
25
Lock()26 void Mutex::Lock() { PthreadCall("lock", pthread_mutex_lock(&mu_)); }
27
Unlock()28 void Mutex::Unlock() { PthreadCall("unlock", pthread_mutex_unlock(&mu_)); }
29
CondVar(Mutex * mu)30 CondVar::CondVar(Mutex* mu)
31 : mu_(mu) {
32 PthreadCall("init cv", pthread_cond_init(&cv_, NULL));
33 }
34
~CondVar()35 CondVar::~CondVar() { PthreadCall("destroy cv", pthread_cond_destroy(&cv_)); }
36
Wait()37 void CondVar::Wait() {
38 PthreadCall("wait", pthread_cond_wait(&cv_, &mu_->mu_));
39 }
40
Signal()41 void CondVar::Signal() {
42 PthreadCall("signal", pthread_cond_signal(&cv_));
43 }
44
SignalAll()45 void CondVar::SignalAll() {
46 PthreadCall("broadcast", pthread_cond_broadcast(&cv_));
47 }
48
InitOnce(OnceType * once,void (* initializer)())49 void InitOnce(OnceType* once, void (*initializer)()) {
50 PthreadCall("once", pthread_once(once, initializer));
51 }
52
53 } // namespace port
54 } // namespace leveldb
55