summaryrefslogtreecommitdiff
path: root/src/cache
diff options
context:
space:
mode:
Diffstat (limited to 'src/cache')
-rw-r--r--src/cache/handlers/cdio.c14
-rw-r--r--src/cache/handlers/cdio.h2
2 files changed, 8 insertions, 8 deletions
diff --git a/src/cache/handlers/cdio.c b/src/cache/handlers/cdio.c
index a9e3747..8326868 100644
--- a/src/cache/handlers/cdio.c
+++ b/src/cache/handlers/cdio.c
@@ -42,7 +42,7 @@ static nn_thread_result NNWT_THREADCALL cd_read_thread(void *userdata)
nn_thread_set_name("cdio_read");
for (;;) {
- if (!al_atomic_load(s32)(&cdio->running, AL_ATOMIC_RELAXED)) {
+ if (!atomic_load(bool)(&cdio->running, AL_ATOMIC_RELAXED)) {
// We don't care about how complete the read was.
return 0;
}
@@ -88,13 +88,13 @@ static void handler_cdio_maybe_spawn_worker(struct cch_handler *handler, size_t
{
struct cch_handler_cdio *cdio = (struct cch_handler_cdio *)handler;
if (cdio->start == (lsn_t)index) return;
- if (al_atomic_load(s32)(&cdio->running, AL_ATOMIC_ACQUIRE)) {
- al_atomic_store(s32)(&cdio->running, 0, AL_ATOMIC_RELEASE);
+ if (atomic_load(bool)(&cdio->running, AL_ATOMIC_ACQUIRE)) {
+ atomic_store(bool)(&cdio->running, false, AL_ATOMIC_RELEASE);
nn_thread_join(&cdio->thread);
}
cdio->start = index;
cdio->sector = cdio->start;
- al_atomic_store(s32)(&cdio->running, 1, AL_ATOMIC_RELEASE);
+ atomic_store(bool)(&cdio->running, true, AL_ATOMIC_RELEASE);
nn_thread_create(&cdio->thread, cd_read_thread, cdio);
}
@@ -114,8 +114,8 @@ static void handler_cdio_free(struct cch_handler **handler)
{
struct cch_handler_cdio *cdio = (struct cch_handler_cdio *)*handler;
cch_threaded_waits_disable_all(&cdio->waits);
- if (al_atomic_load(s32)(&cdio->running, AL_ATOMIC_RELAXED)) {
- al_atomic_store(s32)(&cdio->running, 0, AL_ATOMIC_RELAXED);
+ if (atomic_load(bool)(&cdio->running, AL_ATOMIC_RELAXED)) {
+ atomic_store(bool)(&cdio->running, false, AL_ATOMIC_RELAXED);
nn_thread_join(&cdio->thread);
}
if (cdio->drive) {
@@ -209,7 +209,7 @@ struct cch_entry *cch_handler_cdio_create(void)
if (!open_cd_drive(cdio)) {
return NULL;
}
- al_atomic_store(s32)(&cdio->running, 0, AL_ATOMIC_RELAXED);
+ atomic_store(bool)(&cdio->running, false, AL_ATOMIC_RELAXED);
nn_buffer_init(&cdio->buffer);
nn_buffer_ensure_space(&cdio->buffer, BYTES_PER_STEP);
cdio->buffer.size = BYTES_PER_STEP;
diff --git a/src/cache/handlers/cdio.h b/src/cache/handlers/cdio.h
index a2734ca..6ef37b9 100644
--- a/src/cache/handlers/cdio.h
+++ b/src/cache/handlers/cdio.h
@@ -15,7 +15,7 @@ struct cch_handler_cdio {
lsn_t end;
lsn_t sector;
struct nn_buffer buffer;
- atomic(s32) running;
+ atomic(bool) running;
struct nn_thread thread;
struct cch_threaded_waits waits;
};