aboutsummaryrefslogtreecommitdiffstats
path: root/Alc/backends/solaris.cpp
diff options
context:
space:
mode:
authorChris Robinson <[email protected]>2018-11-26 21:19:20 -0800
committerChris Robinson <[email protected]>2018-11-26 21:39:31 -0800
commitb108d0acfd062756da69074242e24ea7b2856b8a (patch)
tree40a573fbefeb77310f375ace284bc847b4014973 /Alc/backends/solaris.cpp
parent7860a11ae2723d744eb35eae9bbbc6f9a55e9caa (diff)
Remove the last remaining uses of althrd_t
Diffstat (limited to 'Alc/backends/solaris.cpp')
-rw-r--r--Alc/backends/solaris.cpp30
1 files changed, 18 insertions, 12 deletions
diff --git a/Alc/backends/solaris.cpp b/Alc/backends/solaris.cpp
index 0ca7a4ec..941ca015 100644
--- a/Alc/backends/solaris.cpp
+++ b/Alc/backends/solaris.cpp
@@ -34,6 +34,8 @@
#include <errno.h>
#include <math.h>
+#include <thread>
+
#include "alMain.h"
#include "alu.h"
#include "alconfig.h"
@@ -50,10 +52,10 @@ struct ALCsolarisBackend final : public ALCbackend {
int data_size{0};
std::atomic<ALenum> mKillNow{AL_TRUE};
- althrd_t thread;
+ std::thread mThread;
};
-static int ALCsolarisBackend_mixerProc(void *ptr);
+static int ALCsolarisBackend_mixerProc(ALCsolarisBackend *self);
static void ALCsolarisBackend_Construct(ALCsolarisBackend *self, ALCdevice *device);
static void ALCsolarisBackend_Destruct(ALCsolarisBackend *self);
@@ -98,9 +100,8 @@ static void ALCsolarisBackend_Destruct(ALCsolarisBackend *self)
}
-static int ALCsolarisBackend_mixerProc(void *ptr)
+static int ALCsolarisBackend_mixerProc(ALCsolarisBackend *self)
{
- ALCsolarisBackend *self = static_cast<ALCsolarisBackend*>(ptr);
ALCdevice *device = STATIC_CAST(ALCbackend, self)->mDevice;
struct timeval timeout;
ALubyte *write_ptr;
@@ -268,20 +269,25 @@ static ALCboolean ALCsolarisBackend_reset(ALCsolarisBackend *self)
static ALCboolean ALCsolarisBackend_start(ALCsolarisBackend *self)
{
- self->mKillNow.store(AL_FALSE);
- if(althrd_create(&self->thread, ALCsolarisBackend_mixerProc, self) != althrd_success)
- return ALC_FALSE;
- return ALC_TRUE;
+ try {
+ self->mKillNow.store(AL_FALSE);
+ self->mThread = std::thread(ALCsolarisBackend_mixerProc, self);
+ return ALC_TRUE;
+ }
+ catch(std::exception& e) {
+ ERR("Could not create playback thread: %s\n", e.what());
+ }
+ catch(...) {
+ }
+ return ALC_FALSE;
}
static void ALCsolarisBackend_stop(ALCsolarisBackend *self)
{
- int res;
-
- if(self->mKillNow.exchange(AL_TRUE))
+ if(self->mKillNow.exchange(AL_TRUE) || !self->mThread.joinable())
return;
- althrd_join(self->thread, &res);
+ self->mThread.join();
if(ioctl(self->fd, AUDIO_DRAIN) < 0)
ERR("Error draining device: %s\n", strerror(errno));