Initial revision

1 files changed, 104 insertions, 0 deletions

diff --git a/lib/base/elock.cpp b/lib/base/elock.cpp
new file mode 100644
index 00000000..afddcc6f
--- /dev/null
+++ b/lib/base/elock.cpp
@@ -0,0 +1,104 @@
+#include <lib/base/elock.h>
+#include <unistd.h>
+
+void eLock::lock(int res)
+{
+	if (res>max)
+		res=max;
+	pthread_mutex_lock(&mutex);
+	while ((counter+res)>max)
+		pthread_cond_wait(&cond, &mutex);
+	counter+=res;
+	pthread_mutex_unlock(&mutex);
+}
+
+void eLock::unlock(int res)
+{
+	if (res>max)
+		res=max;
+	pthread_mutex_lock(&mutex);
+	counter-=res;
+	pthread_mutex_unlock(&mutex);
+	pthread_cond_signal(&cond);
+}
+
+eLock::eLock(int max): max(max)
+{
+	pthread_mutex_init(&mutex, 0);
+	pthread_cond_init(&cond, 0);
+	counter=0;
+	pid=-1;
+}
+
+eLock::~eLock()
+{
+	pthread_mutex_destroy(&mutex);
+	pthread_cond_destroy(&cond);
+}
+
+eLocker::eLocker(eLock &lock, int res): lock(lock), res(res)
+{
+	lock.lock(res);
+}
+
+eLocker::~eLocker()
+{
+	lock.unlock(res);
+}
+
+eSemaphore::eSemaphore()
+{
+	v=1;
+	pthread_mutex_init(&mutex, 0);
+	pthread_cond_init(&cond, 0);
+}
+
+eSemaphore::~eSemaphore()
+{
+	pthread_mutex_destroy(&mutex);
+	pthread_cond_destroy(&cond);
+}
+
+int eSemaphore::down()
+{
+	int value_after_op;
+	pthread_mutex_lock(&mutex);
+	while (v<=0)
+		pthread_cond_wait(&cond, &mutex);
+	v--;
+	value_after_op=v;
+	pthread_mutex_unlock(&mutex);
+	return value_after_op;
+}
+
+int eSemaphore::decrement()
+{
+	int value_after_op;
+	pthread_mutex_lock(&mutex);
+	v--;
+	value_after_op=v;
+	pthread_mutex_unlock(&mutex);
+	pthread_cond_signal(&cond);
+	return value_after_op;
+}
+
+int eSemaphore::up()
+{
+	int value_after_op;
+	pthread_mutex_lock(&mutex);
+	v++;
+	value_after_op=v;
+	pthread_mutex_unlock(&mutex);
+	pthread_cond_signal(&cond);
+	return value_after_op;
+}
+
+int eSemaphore::value()
+{
+	int value_after_op;
+	pthread_mutex_lock(&mutex);
+	value_after_op=v;
+	pthread_mutex_unlock(&mutex);
+	return value_after_op;
+}
+