blocxx
AtomicOps.cpp
Go to the documentation of this file.
1 /*******************************************************************************
2 * Copyright (C) 2005, Vintela, Inc. All rights reserved.
3 * Copyright (C) 2006, Novell, Inc. All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 *
8 * * Redistributions of source code must retain the above copyright notice,
9 * this list of conditions and the following disclaimer.
10 * * Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
13 * * Neither the name of
14 * Vintela, Inc.,
15 * nor Novell, Inc.,
16 * nor the names of its contributors or employees may be used to
17 * endorse or promote products derived from this software without
18 * specific prior written permission.
19 *
20 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
21 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
24 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
25 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
26 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
27 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
28 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
29 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
30 * POSSIBILITY OF SUCH DAMAGE.
31 *******************************************************************************/
32 
33 
38 #include "blocxx/BLOCXX_config.h"
39 #include "blocxx/AtomicOps.hpp"
40 
41 #if defined(BLOCXX_USE_PTHREAD_SPIN_LOCK_ATOMIC_OPS)
42 
43 namespace BLOCXX_NAMESPACE
44 {
45 
46 Atomic_t::Atomic_t()
47  : val(0)
48 {
49  pthread_spin_init(&spinlock, 0);
50 }
51 Atomic_t::Atomic_t(int i)
52  : val(i)
53 {
54  pthread_spin_init(&spinlock, 0);
55 }
56 void AtomicInc(Atomic_t &v)
57 {
58  pthread_spin_lock(&v.spinlock);
59  ++v.val;
60  pthread_spin_unlock(&v.spinlock);
61 }
62 bool AtomicDecAndTest(Atomic_t &v)
63 {
64  pthread_spin_lock(&v.spinlock);
65  --v.val;
66  bool b = ((v.val == 0) ? true : false) ;
67  pthread_spin_unlock(&v.spinlock);
68  return b;
69 }
70 int AtomicGet(Atomic_t const &v)
71 {
72  return v.val;
73 }
74 void AtomicDec(Atomic_t &v)
75 {
76  pthread_spin_lock(&v.spinlock);
77  --v.val;
78  pthread_spin_unlock(&v.spinlock);
79 }
80 
81 } // end namespace BLOCXX_NAMESPACE
82 
83 #elif defined(BLOCXX_USE_BLOCXX_DEFAULT_ATOMIC_OPS)
84 #include "blocxx/Mutex.hpp"
85 #include "blocxx/MutexLock.hpp"
86 #include "blocxx/ThreadOnce.hpp"
87 
88 namespace BLOCXX_NAMESPACE
89 {
90 
91 // this needs to be a pointer because of static initialization order conflicts.
92 // It shouldn't ever be deleted b/c it may be referenced by a destructor of a
93 // static variable that is being deleted.
94 static Mutex* guard = 0;
95 static OnceFlag g_once = BLOCXX_ONCE_INIT;
96 static void initGuard()
97 {
98  guard = new Mutex();
99 }
100 void AtomicInc(Atomic_t &v)
101 {
102  callOnce(g_once, initGuard);
103  MutexLock lock(*guard);
104  ++v.val;
105 }
106 bool AtomicDecAndTest(Atomic_t &v)
107 {
108  callOnce(g_once, initGuard);
109  MutexLock lock(*guard);
110  return --v.val == 0;
111 }
112 int AtomicGet(Atomic_t const &v)
113 {
114  callOnce(g_once, initGuard);
115  MutexLock lock(*guard);
116  return v.val;
117 }
118 void AtomicDec(Atomic_t &v)
119 {
120  callOnce(g_once, initGuard);
121  MutexLock lock(*guard);
122  --v.val;
123 }
124 
125 } // end namespace BLOCXX_NAMESPACE
126 
127 #endif
128 
129 
BLOCXX_NAMESPACE
Taken from RFC 1321.
Definition: AppenderLogger.cpp:47
BLOCXX_NAMESPACE::AtomicGet
int AtomicGet(Atomic_t const &v)
Definition: AtomicOps.cpp:70
i
size_t i
Definition: LogMessagePatternFormatter.cpp:912
MutexLock.hpp
BLOCXX_NAMESPACE::Atomic_t
Definition: AtomicOps.hpp:331
AtomicOps.hpp
Mutex.hpp
BLOCXX_NAMESPACE::AtomicDecAndTest
bool AtomicDecAndTest(Atomic_t &v)
Definition: AtomicOps.cpp:62
BLOCXX_NAMESPACE::Atomic_t::Atomic_t
Atomic_t()
Definition: AtomicOps.hpp:333
BLOCXX_NAMESPACE::callOnce
void BLOCXX_COMMON_API callOnce(OnceFlag &flag, FuncT F)
The first time callOnce is called with a given onceFlag argument, it calls func with no argument and ...
BLOCXX_NAMESPACE::Atomic_t::val
volatile int val
Definition: AtomicOps.hpp:335
BLOCXX_NAMESPACE::AtomicDec
void AtomicDec(Atomic_t &v)
Definition: AtomicOps.cpp:74
ThreadOnce.hpp
BLOCXX_NAMESPACE::AtomicInc
void AtomicInc(Atomic_t &v)
Definition: AtomicOps.cpp:56
Generated by   doxygen 1.8.15