mirror of
https://git.savannah.gnu.org/git/guile.git
synced 2025-04-30 20:00:19 +02:00
c957ec7ab0
* libguile/__scm.h (SCM_TICK): Always define as scm_async_tick(). * libguile/error.c (scm_syserror, scm_syserror_msg): * libguile/fports.c (fport_read, fport_write): * libguile/_scm.h (SCM_SYSCALL): Replace SCM_ASYNC_TICK with scm_async_tick (). (SCM_ASYNC_TICK, SCM_ASYNC_TICK_WITH_CODE) (SCM_ASYNC_TICK_WITH_GUARD_CODE): Remove internal definitions. We inline into vm-engine.c, the only place where it matters. * libguile/async.h: * libguile/async.c (scm_async_tick, scm_i_setup_sleep): (scm_i_reset_sleep, scm_system_async_mark_for_thread): * libguile/threads.h (struct scm_thread_wake_data): * libguile/threads.h (scm_i_thread): * libguile/threads.c (block_self, guilify_self_1, scm_std_select): Rewrite to use sequentially-consistent atomic references. * libguile/atomics-internal.h (scm_atomic_set_pointer): (scm_atomic_ref_pointer): New definitions. * libguile/finalizers.c (queue_finalizer_async): We can allocate, so just use scm_system_async_mark_for_thread instead of the set-cdr! shenanigans. * libguile/scmsigs.c (take_signal): * libguile/gc.c (queue_after_gc_hook): Adapt to new asyncs mechanism. Can't allocate but we're just manipulating the current thread when no other threads are running so we should be good. * libguile/vm-engine.c (VM_HANDLE_INTERRUPTS): Inline the async_tick business.
176 lines
4 KiB
C
176 lines
4 KiB
C
#ifndef SCM_ATOMICS_INTERNAL_H
|
||
#define SCM_ATOMICS_INTERNAL_H
|
||
|
||
/* Copyright (C) 2016
|
||
* Free Software Foundation, Inc.
|
||
*
|
||
* This library is free software; you can redistribute it and/or
|
||
* modify it under the terms of the GNU Lesser General Public License
|
||
* as published by the Free Software Foundation; either version 3 of
|
||
* the License, or (at your option) any later version.
|
||
*
|
||
* This library 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
|
||
* Lesser General Public License for more details.
|
||
*
|
||
* You should have received a copy of the GNU Lesser General Public
|
||
* License along with this library; if not, write to the Free Software
|
||
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
|
||
* 02110-1301 USA
|
||
*/
|
||
|
||
|
||
|
||
|
||
#include <stdint.h>
|
||
|
||
|
||
|
||
|
||
#define HAVE_C11_ATOMICS (__STDC_VERSION__ >= 201112L && !defined(__STDC_NO_ATOMICS__))
|
||
|
||
#if HAVE_C11_ATOMICS
|
||
|
||
#include <stdatomic.h>
|
||
static inline uint32_t
|
||
scm_atomic_subtract_uint32 (uint32_t *loc, uint32_t arg)
|
||
{
|
||
return atomic_fetch_sub (loc, arg);
|
||
}
|
||
static inline _Bool
|
||
scm_atomic_compare_and_swap_uint32 (uint32_t *loc, uint32_t *expected,
|
||
uint32_t desired)
|
||
{
|
||
return atomic_compare_exchange_weak (loc, expected, desired);
|
||
}
|
||
static inline void
|
||
scm_atomic_set_pointer (void **loc, void *val)
|
||
{
|
||
atomic_store (loc, val);
|
||
}
|
||
static inline void *
|
||
scm_atomic_ref_pointer (void **loc)
|
||
{
|
||
return atomic_load (loc);
|
||
}
|
||
static inline void
|
||
scm_atomic_set_scm (SCM *loc, SCM val)
|
||
{
|
||
atomic_store (loc, val);
|
||
}
|
||
static inline SCM
|
||
scm_atomic_ref_scm (SCM *loc)
|
||
{
|
||
return atomic_load (loc);
|
||
}
|
||
static inline SCM
|
||
scm_atomic_swap_scm (SCM *loc, SCM val)
|
||
{
|
||
return atomic_exchange (loc, val);
|
||
}
|
||
static inline _Bool
|
||
scm_atomic_compare_and_swap_scm (SCM *loc, SCM *expected, SCM desired)
|
||
{
|
||
return atomic_compare_exchange_weak (loc, expected, desired);
|
||
}
|
||
#else /* HAVE_C11_ATOMICS */
|
||
|
||
/* Fallback implementation using locks. */
|
||
#include "libguile/threads.h"
|
||
static scm_i_pthread_mutex_t atomics_lock = SCM_I_PTHREAD_MUTEX_INITIALIZER;
|
||
static inline uint32_t
|
||
scm_atomic_subtract_uint32 (uint32_t *loc, uint32_t arg)
|
||
{
|
||
uint32_t ret;
|
||
scm_i_pthread_mutex_lock (&atomics_lock);
|
||
ret = *loc;
|
||
*loc -= arg;
|
||
scm_i_pthread_mutex_unlock (&atomics_lock);
|
||
return ret;
|
||
}
|
||
static inline int
|
||
scm_atomic_compare_and_swap_uint32 (uint32_t *loc, uint32_t *expected,
|
||
uint32_t desired)
|
||
{
|
||
int ret;
|
||
scm_i_pthread_mutex_lock (&atomics_lock);
|
||
if (*loc == *expected)
|
||
{
|
||
*loc = desired;
|
||
ret = 1;
|
||
}
|
||
else
|
||
{
|
||
*expected = *loc;
|
||
ret = 0;
|
||
}
|
||
scm_i_pthread_mutex_unlock (&atomics_lock);
|
||
return ret;
|
||
}
|
||
|
||
static inline void
|
||
scm_atomic_set_pointer (void **loc, void *val)
|
||
{
|
||
scm_i_pthread_mutex_lock (&atomics_lock);
|
||
*loc = val;
|
||
scm_i_pthread_mutex_unlock (&atomics_lock);
|
||
}
|
||
static inline void *
|
||
scm_atomic_ref_pointer (void **loc)
|
||
{
|
||
void *ret;
|
||
scm_i_pthread_mutex_lock (&atomics_lock);
|
||
ret = *loc;
|
||
scm_i_pthread_mutex_unlock (&atomics_lock);
|
||
return ret;
|
||
}
|
||
|
||
static inline void
|
||
scm_atomic_set_scm (SCM *loc, SCM val)
|
||
{
|
||
scm_i_pthread_mutex_lock (&atomics_lock);
|
||
*loc = val;
|
||
scm_i_pthread_mutex_unlock (&atomics_lock);
|
||
}
|
||
static inline SCM
|
||
scm_atomic_ref_scm (SCM *loc)
|
||
{
|
||
SCM ret;
|
||
scm_i_pthread_mutex_lock (&atomics_lock);
|
||
ret = *loc;
|
||
scm_i_pthread_mutex_unlock (&atomics_lock);
|
||
return ret;
|
||
}
|
||
static inline SCM
|
||
scm_atomic_swap_scm (SCM *loc, SCM val)
|
||
{
|
||
SCM ret;
|
||
scm_i_pthread_mutex_lock (&atomics_lock);
|
||
ret = *loc;
|
||
*loc = val;
|
||
scm_i_pthread_mutex_unlock (&atomics_lock);
|
||
return ret;
|
||
}
|
||
static inline int
|
||
scm_atomic_compare_and_swap_scm (SCM *loc, SCM *expected, SCM desired)
|
||
{
|
||
int ret;
|
||
scm_i_pthread_mutex_lock (&atomics_lock);
|
||
if (*loc == *expected)
|
||
{
|
||
*loc = desired;
|
||
ret = 1;
|
||
}
|
||
else
|
||
{
|
||
*expected = *loc;
|
||
ret = 0;
|
||
}
|
||
scm_i_pthread_mutex_unlock (&atomics_lock);
|
||
return ret;
|
||
}
|
||
|
||
#endif /* HAVE_C11_ATOMICS */
|
||
|
||
#endif /* SCM_ATOMICS_INTERNAL_H */
|