added fake connection list
[anytun.git] / threadUtils.hpp
blobad45f687d04e0badfce1279260b69e19f118eb11
1 /*
2 * anytun
4 * The secure anycast tunneling protocol (satp) defines a protocol used
5 * for communication between any combination of unicast and anycast
6 * tunnel endpoints. It has less protocol overhead than IPSec in Tunnel
7 * mode and allows tunneling of every ETHER TYPE protocol (e.g.
8 * ethernet, ip, arp ...). satp directly includes cryptography and
9 * message authentication based on the methodes used by SRTP. It is
10 * intended to deliver a generic, scaleable and secure solution for
11 * tunneling and relaying of packets of any protocol.
14 * Copyright (C) 2007 anytun.org <satp@wirdorange.org>
16 * This program is free software; you can redistribute it and/or modify
17 * it under the terms of the GNU General Public License version 2
18 * as published by the Free Software Foundation.
20 * This program is distributed in the hope that it will be useful,
21 * but WITHOUT ANY WARRANTY; without even the implied warranty of
22 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
23 * GNU General Public License for more details.
25 * You should have received a copy of the GNU General Public License
26 * along with this program (see the file COPYING included with this
27 * distribution); if not, write to the Free Software Foundation, Inc.,
28 * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
31 #ifndef _THREADUTILS_HPP_
32 #define _THREADUTILS_HPP_
34 #include <stdexcept>
35 #include <semaphore.h>
37 class Mutex
39 public:
40 Mutex()
42 if(pthread_mutex_init(&mutex,NULL))
43 throw std::runtime_error("can't create mutex");
46 ~Mutex()
48 pthread_mutex_destroy(&mutex);
51 private:
52 Mutex(const Mutex& src);
53 void operator=(const Mutex& src);
55 void lock()
57 if(pthread_mutex_lock(&mutex))
58 throw std::runtime_error("can't lock mutex");
61 void unlock()
63 if(pthread_mutex_unlock(&mutex))
64 throw std::runtime_error("can't unlock mutex");
66 friend class Lock;
67 friend class Condition;
68 pthread_mutex_t mutex;
72 class Lock
74 public:
75 Lock(Mutex &m) : mutex(m)
77 mutex.lock();
80 ~Lock()
82 mutex.unlock();
85 private:
86 Lock(const Lock& src);
87 void operator=(const Lock& src);
89 Mutex &mutex;
92 class Condition
94 public:
95 Condition()
97 if(pthread_cond_init(&cond, NULL))
98 throw std::runtime_error("can't create condition");
101 ~Condition()
103 pthread_cond_destroy(&cond);
106 void wait()
108 mutex.lock();
109 if(pthread_cond_wait(&cond, &mutex.mutex))
111 mutex.unlock();
112 throw std::runtime_error("error on waiting for condition");
114 mutex.unlock();
117 void signal()
119 mutex.lock();
120 if(pthread_cond_signal(&cond))
122 mutex.unlock();
123 throw std::runtime_error("can't signal condition");
125 mutex.unlock();
128 void broadcast()
130 mutex.lock();
131 if(pthread_cond_broadcast(&cond))
133 mutex.unlock();
134 throw std::runtime_error("can't broadcast condition");
136 mutex.unlock();
139 private:
140 pthread_cond_t cond;
141 Mutex mutex;
144 class Semaphore
146 public:
147 Semaphore(unsigned int initVal=0)
149 if(sem_init(&sem, 0, initVal))
150 throw std::runtime_error("can't create semaphore");
153 ~Semaphore()
155 sem_destroy(&sem);
158 void down()
160 if(sem_wait(&sem))
161 throw std::runtime_error("error on semaphore down");
164 void up()
166 if(sem_post(&sem))
167 throw std::runtime_error("error on semaphore up");
170 private:
171 sem_t sem;
174 #endif