consolidate semaphore implementation (part one)

3 files changed, 5 insertions, 207 deletions

diff --git a/libs/ardour/ardour/worker.h b/libs/ardour/ardour/worker.h
index c9ff2f2d7f..529d59a4a6 100644
--- a/libs/ardour/ardour/worker.h
+++ b/libs/ardour/ardour/worker.h
@@ -25,7 +25,7 @@
 #include <glibmm/threads.h>
 
 #include "pbd/ringbuffer.h"
-#include "pbd/semaphore.h"
+#include "pbd/semutils.h"
 
 #include "ardour/libardour_visibility.h"
 
@@ -92,7 +92,7 @@ private:
 	RingBuffer<uint8_t>*   _requests;
 	RingBuffer<uint8_t>*   _responses;
 	uint8_t*               _response;
-	PBD::Semaphore         _sem;
+	PBD::ProcessSemaphore  _sem;
 	bool                   _exit;
 	Glib::Threads::Thread* _thread;
 
diff --git a/libs/ardour/worker.cc b/libs/ardour/worker.cc
index aea1c6f8e3..ce71c92a15 100644
--- a/libs/ardour/worker.cc
+++ b/libs/ardour/worker.cc
@@ -32,7 +32,7 @@ Worker::Worker(Workee* workee, uint32_t ring_size)
 	, _requests(new RingBuffer<uint8_t>(ring_size))
 	, _responses(new RingBuffer<uint8_t>(ring_size))
 	, _response((uint8_t*)malloc(ring_size))
-	, _sem(0)
+	, _sem ("worker_semaphore", 0)
 	, _exit(false)
 	, _thread (Glib::Threads::Thread::create(sigc::mem_fun(*this, &Worker::run)))
 {}
@@ -40,7 +40,7 @@ Worker::Worker(Workee* workee, uint32_t ring_size)
 Worker::~Worker()
 {
 	_exit = true;
-	_sem.post();
+	_sem.signal();
 	_thread->join();
 }
 
@@ -56,7 +56,7 @@ Worker::schedule(uint32_t size, const void* data)
 	if (_requests->write((const uint8_t*)data, size) != size) {
 		return false;
 	}
-	_sem.post();
+	_sem.signal();
 	return true;
 }
 
diff --git a/libs/pbd/pbd/semaphore.h b/libs/pbd/pbd/semaphore.h
deleted file mode 100644
index 265a219e07..0000000000
--- a/libs/pbd/pbd/semaphore.h
+++ /dev/null
@@ -1,202 +0,0 @@
-/*
-  Copyright (C) 2012 Paul Davis
-  Author: David Robillard
-
-  This program is free software; you can redistribute it and/or modify
-  it under the terms of the GNU General Public License as published by
-  the Free Software Foundation; either version 2 of the License, or
-  (at your option) any later version.
-
-  This program is distributed in the hope that it will be useful,
-  but WITHOUT ANY WARRANTY; without even the implied warranty of
-  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-  GNU General Public License for more details.
-
-  You should have received a copy of the GNU General Public License
-  along with this program; if not, write to the Free Software
-  Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
-*/
-
-#ifndef __pbd_semaphore_h__
-#define __pbd_semaphore_h__
-
-#ifdef __APPLE__
-#    include <mach/mach.h>
-#elif defined(PLATFORM_WINDOWS)
-#    include <windows.h>
-#ifndef INFINITE
-#define INFINITE 0xffffffffL
-#endif
-#else
-#    include <semaphore.h>
-#    include <errno.h>
-#endif
-
-#include "pbd/libpbd_visibility.h"
-#include "pbd/failed_constructor.h"
-
-namespace PBD {
-
-/**
-   Unnamed (process local) counting semaphore.
-
-   The civilized person's synchronisation primitive.  A counting semaphore is
-   an integer which is always non-negative, so, an attempted decrement (or
-   "wait") will block if the value is 0, until another thread does an increment
-   (or "post").
-
-   At least on Lignux, the main advantage of this is that it is fast and the
-   only safe way to reliably signal from a real-time audio thread.  The
-   counting semantics also complement ringbuffers of events nicely.
-*/
-class /*LIBPBD_API*/ Semaphore
-{
-public:
-	/**
-	   Create a new semaphore.
-
-	   Chances are you want 1 wait() per 1 post(), an initial value of 0.
-	*/
-	inline Semaphore(unsigned initial);
-
-	inline ~Semaphore();
-
-	/** Post/Increment/Signal */
-	inline void post();
-
-	/** Wait/Decrement.  Returns false on error. */
-	inline bool wait();
-
-	/** Attempt Wait/Decrement.  Returns true iff a decrement occurred. */
-	inline bool try_wait();
-
-private:
-#if defined(__APPLE__)
-	semaphore_t _sem;  // sem_t is a worthless broken mess on OSX
-#elif defined(PLATFORM_WINDOWS)
-	HANDLE _sem;  // types are overrated anyway
-#else
-	sem_t _sem;
-#endif
-};
-
-#ifdef __APPLE__
-
-inline
-Semaphore::Semaphore(unsigned initial)
-{
-	if (semaphore_create(mach_task_self(), &_sem, SYNC_POLICY_FIFO, initial)) {
-		throw failed_constructor();
-	}
-}
-
-inline
-Semaphore::~Semaphore()
-{
-	semaphore_destroy(mach_task_self(), _sem);
-}
-
-inline void
-Semaphore::post()
-{
-	semaphore_signal(_sem);
-}
-
-inline bool
-Semaphore::wait()
-{
-	if (semaphore_wait(_sem) != KERN_SUCCESS) {
-		return false;
-	}
-	return true;
-}
-
-inline bool
-Semaphore::try_wait()
-{
-	const mach_timespec_t zero = { 0, 0 };
-	return semaphore_timedwait(_sem, zero) == KERN_SUCCESS;
-}
-
-#elif defined(PLATFORM_WINDOWS)
-
-inline
-Semaphore::Semaphore(unsigned initial)
-{
-	if (!(_sem = CreateSemaphore(NULL, initial, LONG_MAX, NULL))) {
-		throw failed_constructor();
-	}
-}
-
-inline
-Semaphore::~Semaphore()
-{
-	CloseHandle(_sem);
-}
-
-inline void
-Semaphore::post()
-{
-	ReleaseSemaphore(_sem, 1, NULL);
-}
-
-inline bool
-Semaphore::wait()
-{
-	if (WaitForSingleObject(_sem, INFINITE) != WAIT_OBJECT_0) {
-		return false;
-	}
-	return true;
-}
-
-inline bool
-Semaphore::try_wait()
-{
-	return WaitForSingleObject(_sem, 0) == WAIT_OBJECT_0;
-}
-
-#else  /* !defined(__APPLE__) && !defined(PLATFORM_WINDOWS) */
-
-Semaphore::Semaphore(unsigned initial)
-{
-	if (sem_init(&_sem, 0, initial)) {
-		throw failed_constructor();
-	}
-}
-
-inline
-Semaphore::~Semaphore()
-{
-	sem_destroy(&_sem);
-}
-
-inline void
-Semaphore::post()
-{
-	sem_post(&_sem);
-}
-
-inline bool
-Semaphore::wait()
-{
-	while (sem_wait(&_sem)) {
-		if (errno != EINTR) {
-			return false;  // We are all doomed
-		}
-		/* Otherwise, interrupted (rare/weird), so try again. */
-	}
-
-	return true;
-}
-
-inline bool
-Semaphore::try_wait()
-{
-	return (sem_trywait(&_sem) == 0);
-}
-
-#endif
-
-}  // namespace PBD
-
-#endif  /* __pbd_semaphore_h__ */