atomic.c File Reference

Implementation of atomic operations abstraction. More...

Go to the source code of this file.

Functions
bool	atomic_load_bool_impl (const atomic_t *a)
void	atomic_store_bool_impl (atomic_t *a, uint64_t value)
bool	atomic_cas_bool_impl (atomic_t *a, bool *expected, bool new_value)
int	atomic_load_int_impl (const atomic_t *a)
void	atomic_store_int_impl (atomic_t *a, uint64_t value)
int	atomic_fetch_add_int_impl (atomic_t *a, int64_t delta)
int	atomic_fetch_sub_int_impl (atomic_t *a, int64_t delta)
uint64_t	atomic_load_u64_impl (const atomic_t *a)
void	atomic_store_u64_impl (atomic_t *a, uint64_t value)
uint64_t	atomic_fetch_add_u64_impl (atomic_t *a, uint64_t delta)
uint64_t	atomic_fetch_sub_u64_impl (atomic_t *a, uint64_t delta)
bool	atomic_cas_u64_impl (atomic_t *a, uint64_t *expected, uint64_t new_value)
bool	atomic_cas_int_impl (atomic_t *a, int *expected, int new_value)
void *	atomic_ptr_load_impl (const atomic_ptr_t *a)
void	atomic_ptr_store_impl (atomic_ptr_t *a, void *value)
bool	atomic_ptr_cas_impl (atomic_ptr_t *a, void **expected, void *new_value)
void *	atomic_ptr_exchange_impl (atomic_ptr_t *a, void *new_value)
bool	atomic_exchange_bool_impl (atomic_t *a, bool new_value)
int	atomic_exchange_int_impl (atomic_t *a, int new_value)
uint64_t	atomic_exchange_u64_impl (atomic_t *a, uint64_t new_value)
bool	atomic_load_bool (atomic_t *a)
	Atomically load a boolean value.
void	atomic_store_bool (atomic_t *a, bool value)
	Atomically store a boolean value.
bool	atomic_cas_bool (atomic_t *a, bool *expected, bool new_value)
	Atomically compare-and-swap a boolean.
int	atomic_load_int (atomic_t *a)
	Atomically load an int value.
void	atomic_store_int (atomic_t *a, int value)
	Atomically store an int value.
int	atomic_fetch_add_int (atomic_t *a, int delta)
	Atomically add to an int and return the previous value.
int	atomic_fetch_sub_int (atomic_t *a, int delta)
	Atomically subtract from an int and return the previous value.
bool	atomic_cas_int (atomic_t *a, int *expected, int new_value)
	Atomically compare-and-swap an int.
uint64_t	atomic_load_u64 (atomic_t *a)
	Atomically load a uint64_t value.
void	atomic_store_u64 (atomic_t *a, uint64_t value)
	Atomically store a uint64_t value.
uint64_t	atomic_fetch_add_u64 (atomic_t *a, uint64_t delta)
	Atomically add to a uint64_t and return the previous value.
uint64_t	atomic_fetch_sub_u64 (atomic_t *a, uint64_t delta)
	Atomically subtract from a uint64_t and return the previous value.
bool	atomic_cas_u64 (atomic_t *a, uint64_t *expected, uint64_t new_value)
	Atomically compare-and-swap a uint64_t.
void *	atomic_ptr_load (atomic_ptr_t *a)
	Atomically load a pointer.
void	atomic_ptr_store (atomic_ptr_t *a, void *value)
	Atomically store a pointer.
bool	atomic_ptr_cas (atomic_ptr_t *a, void **expected, void *new_value)
	Atomically compare-and-swap a pointer.
void *	atomic_ptr_exchange (atomic_ptr_t *a, void *new_value)
	Atomically exchange a pointer and return the old value.
bool	atomic_exchange_bool (atomic_t *a, bool new_value)
	Atomically exchange a boolean and return the old value.
int	atomic_exchange_int (atomic_t *a, int new_value)
	Atomically exchange an int and return the old value.
uint64_t	atomic_exchange_u64 (atomic_t *a, uint64_t new_value)
	Atomically exchange a uint64_t and return the old value.
bool	debug_atomic_is_initialized (void)
void	atomic_on_load (atomic_t *a)
void	atomic_on_store (atomic_t *a)
void	atomic_on_cas (atomic_t *a, bool success)
void	atomic_on_fetch (atomic_t *a)
void	atomic_ptr_on_load (atomic_ptr_t *a)
void	atomic_ptr_on_store (atomic_ptr_t *a)
void	atomic_ptr_on_cas (atomic_ptr_t *a, bool success)
void	atomic_ptr_on_exchange (atomic_ptr_t *a)

Detailed Description

Implementation of atomic operations abstraction.

Date

March 2026

Provides _impl functions for atomic operations. In debug builds, these functions are wrapped by the typed macros to include debug hooks. In release builds, the macros call these directly for zero overhead.

Design: Uses raw C11 atomic operations internally, never calls back into the atomic_t system (no recursion). Debug hooks are called after the atomic operation completes.

Definition in file atomic.c.

Function Documentation

atomic_cas_bool()

bool atomic_cas_bool	(	atomic_t *	a,
		bool *	expected,
		bool	new_value
	)

Atomically compare-and-swap a boolean.

Parameters

a	Pointer to atomic_t
expected	Expected current value (passed by reference)
new_value	Value to store if comparison succeeds

Returns

true if swap succeeded, false otherwise

Definition at line 184 of file atomic.c.

                                                                  {
  if (!a || !expected)
    return false;
  uint64_t exp = (uint64_t)*expected;
  bool success = atomic_compare_exchange_strong((_Atomic(uint64_t) *)&a->impl, &exp, (uint64_t)new_value);
  *expected = (bool)exp;
  atomic_on_cas(a, success);
  return success;
}

References atomic_on_cas(), and bool.

Referenced by handle_image_frame_packet(), keyboard_help_check_signal_cancel(), log_lock_terminal(), log_search_check_signal_cancel(), splash_intro_start(), and symbol_cache_resolve_batch().

atomic_cas_bool_impl()

bool atomic_cas_bool_impl	(	atomic_t *	a,
		bool *	expected,
		bool	new_value
	)

Definition at line 36 of file atomic.c.

                                                                       {
  if (!a || !expected)
    return false;
  uint64_t exp = (uint64_t)*expected;
  bool success = atomic_compare_exchange_strong((_Atomic(uint64_t) *)&a->impl, &exp, (uint64_t)new_value);
  *expected = (bool)exp;
  return success;
}

References bool.

atomic_cas_int()

bool atomic_cas_int	(	atomic_t *	a,
		int *	expected,
		int	new_value
	)

Atomically compare-and-swap an int.

Parameters

a	Pointer to atomic_t
expected	Expected current value (passed by reference)
new_value	Value to store if comparison succeeds

Returns

true if swap succeeded, false otherwise

Definition at line 225 of file atomic.c.

                                                               {
  if (!a || !expected)
    return false;
  bool success = atomic_cas_int_impl(a, expected, new_value);
  atomic_on_cas(a, success);
  return success;
}

References atomic_cas_int_impl(), and atomic_on_cas().

Referenced by lifecycle_init(), and lifecycle_init_once().

atomic_cas_int_impl()

bool atomic_cas_int_impl	(	atomic_t *	a,
		int *	expected,
		int	new_value
	)

Definition at line 107 of file atomic.c.

                                                                    {
  if (!a || !expected)
    return false;
  uint64_t expected_u64 = (uint64_t)(int64_t)*expected;
  bool result =
      atomic_compare_exchange_strong((_Atomic(uint64_t) *)&a->impl, &expected_u64, (uint64_t)(int64_t)new_value);
  *expected = (int)(int32_t)expected_u64;
  return result;
}

Referenced by atomic_cas_int().

atomic_cas_u64()

bool atomic_cas_u64	(	atomic_t *	a,
		uint64_t *	expected,
		uint64_t	new_value
	)

Atomically compare-and-swap a uint64_t.

Parameters

a	Pointer to atomic_t
expected	Expected current value (passed by reference)
new_value	Value to store if comparison succeeds

Returns

true if swap succeeded, false otherwise

Definition at line 264 of file atomic.c.

                                                                         {
  if (!a || !expected)
    return false;
  bool success = atomic_compare_exchange_strong((_Atomic(uint64_t) *)&a->impl, expected, new_value);
  atomic_on_cas(a, success);
  return success;
}

References atomic_on_cas().

Referenced by buffer_pool_alloc(), create_mixed_ascii_frame_for_client(), lifecycle_destroy_once(), lifecycle_init(), lifecycle_init_once(), lifecycle_reset(), lifecycle_shutdown(), lifecycle_shutdown_forever(), and websocket_callback_timing_record().

atomic_cas_u64_impl()

bool atomic_cas_u64_impl	(	atomic_t *	a,
		uint64_t *	expected,
		uint64_t	new_value
	)

Definition at line 101 of file atomic.c.

                                                                              {
  if (!a || !expected)
    return false;
  return atomic_compare_exchange_strong((_Atomic(uint64_t) *)&a->impl, expected, new_value);
}

atomic_exchange_bool()

bool atomic_exchange_bool	(	atomic_t *	a,
		bool	new_value
	)

Atomically exchange a boolean and return the old value.

Parameters

a	Pointer to atomic_t
new_value	Boolean value to store

Returns

Previous boolean value

Atomically swaps the new value for the old value and returns the old value. Avoids TOCTOU race conditions present in load+check+cas patterns.

Definition at line 303 of file atomic.c.

                                                       {
  if (!a)
    return false;
  bool result = (bool)atomic_exchange((_Atomic(uint64_t) *)&a->impl, (uint64_t)new_value);
  atomic_on_store(a);
  return result;
}

References atomic_on_store(), and bool.

Referenced by audio_ring_buffer_read(), disconnect_client_for_bad_data(), display_disable_logging_for_first_frame(), handle_image_frame_h265_packet(), and session_display_write_ascii().

atomic_exchange_bool_impl()

bool atomic_exchange_bool_impl	(	atomic_t *	a,
		bool	new_value
	)

Definition at line 145 of file atomic.c.

                                                            {
  if (!a)
    return false;
  return (bool)atomic_exchange((_Atomic(uint64_t) *)&a->impl, (uint64_t)new_value);
}

atomic_exchange_int()

int atomic_exchange_int	(	atomic_t *	a,
		int	new_value
	)

Atomically exchange an int and return the old value.

Parameters

a	Pointer to atomic_t
new_value	Int value to store

Returns

Previous int value

Definition at line 311 of file atomic.c.

                                                    {
  if (!a)
    return 0;
  int result = (int)(int32_t)atomic_exchange((_Atomic(uint64_t) *)&a->impl, (uint64_t)(int32_t)new_value);
  atomic_on_store(a);
  return result;
}

References atomic_on_store().

atomic_exchange_int_impl()

int atomic_exchange_int_impl	(	atomic_t *	a,
		int	new_value
	)

Definition at line 151 of file atomic.c.

                                                         {
  if (!a)
    return 0;
  return (int)(int32_t)atomic_exchange((_Atomic(uint64_t) *)&a->impl, (uint64_t)(int32_t)new_value);
}

atomic_exchange_u64()

uint64_t atomic_exchange_u64	(	atomic_t *	a,
		uint64_t	new_value
	)

Atomically exchange a uint64_t and return the old value.

Parameters

a	Pointer to atomic_t
new_value	Value to store

Returns

Previous uint64_t value

Used for atomic min/max updates and other exchange patterns where you need the old value atomically. Avoids TOCTOU race conditions present in load+check+cas.

Example (atomic minimum):

uint64_t old = atomic_exchange_u64(&stats->min_val, 0);
// old is the previous value, atomically

Definition at line 319 of file atomic.c.

                                                              {
  if (!a)
    return 0;
  uint64_t result = atomic_exchange((_Atomic(uint64_t) *)&a->impl, new_value);
  atomic_on_store(a);
  return result;
}

References atomic_on_store().

atomic_exchange_u64_impl()

uint64_t atomic_exchange_u64_impl	(	atomic_t *	a,
		uint64_t	new_value
	)

Definition at line 157 of file atomic.c.

                                                                   {
  if (!a)
    return 0;
  return atomic_exchange((_Atomic(uint64_t) *)&a->impl, new_value);
}

atomic_fetch_add_int()

int atomic_fetch_add_int	(	atomic_t *	a,
		int	delta
	)

Atomically add to an int and return the previous value.

Parameters

a	Pointer to atomic_t
delta	Value to add

Returns

Previous value before the add

Definition at line 209 of file atomic.c.

                                                 {
  if (!a)
    return 0;
  int result = (int)(int32_t)atomic_fetch_add((_Atomic(uint64_t) *)&a->impl, (uint64_t)(int64_t)delta);
  atomic_on_fetch(a);
  return result;
}

References atomic_on_fetch().

atomic_fetch_add_int_impl()

int atomic_fetch_add_int_impl	(	atomic_t *	a,
		int64_t	delta
	)

Definition at line 61 of file atomic.c.

                                                          {
  if (!a)
    return 0;
  return (int)(int32_t)atomic_fetch_add((_Atomic(uint64_t) *)&a->impl, (uint64_t)delta);
}

atomic_fetch_add_u64()

uint64_t atomic_fetch_add_u64	(	atomic_t *	a,
		uint64_t	delta
	)

Atomically add to a uint64_t and return the previous value.

Parameters

a	Pointer to atomic_t
delta	Value to add

Returns

Previous value before the add

Definition at line 248 of file atomic.c.

                                                           {
  if (!a)
    return 0;
  uint64_t result = atomic_fetch_add((_Atomic(uint64_t) *)&a->impl, delta);
  atomic_on_fetch(a);
  return result;
}

References atomic_on_fetch().

Referenced by acds_client_handler(), audio_ring_buffer_read(), buffer_pool_alloc(), buffer_pool_free(), buffer_pool_shrink(), client_send_thread_func(), cond_on_wait(), get_utf8_palette_cache(), log_mmap_rotate(), log_mmap_write(), node_pool_get(), packet_queue_enqueue(), packet_queue_enqueue_packet(), packet_queue_try_dequeue(), ringbuffer_write(), rwlock_on_rdlock(), session_display_write_ascii(), session_log_buffer_append(), symbol_cache_lookup(), video_frame_commit(), and websocket_callback_timing_record().

atomic_fetch_add_u64_impl()

uint64_t atomic_fetch_add_u64_impl	(	atomic_t *	a,
		uint64_t	delta
	)

Definition at line 89 of file atomic.c.

                                                                {
  if (!a)
    return 0;
  return atomic_fetch_add((_Atomic(uint64_t) *)&a->impl, delta);
}

atomic_fetch_sub_int()

int atomic_fetch_sub_int	(	atomic_t *	a,
		int	delta
	)

Atomically subtract from an int and return the previous value.

Parameters

a	Pointer to atomic_t
delta	Value to subtract

Returns

Previous value before the subtract

Definition at line 217 of file atomic.c.

                                                 {
  if (!a)
    return 0;
  int result = (int)(int32_t)atomic_fetch_sub((_Atomic(uint64_t) *)&a->impl, (uint64_t)(int64_t)delta);
  atomic_on_fetch(a);
  return result;
}

References atomic_on_fetch().

atomic_fetch_sub_int_impl()

int atomic_fetch_sub_int_impl	(	atomic_t *	a,
		int64_t	delta
	)

Definition at line 67 of file atomic.c.

                                                          {
  if (!a)
    return 0;
  return (int)(int32_t)atomic_fetch_sub((_Atomic(uint64_t) *)&a->impl, (uint64_t)delta);
}

atomic_fetch_sub_u64()

uint64_t atomic_fetch_sub_u64	(	atomic_t *	a,
		uint64_t	delta
	)

Atomically subtract from a uint64_t and return the previous value.

Parameters

a	Pointer to atomic_t
delta	Value to subtract

Returns

Previous value before the subtract

Definition at line 256 of file atomic.c.

                                                           {
  if (!a)
    return 0;
  uint64_t result = atomic_fetch_sub((_Atomic(uint64_t) *)&a->impl, delta);
  atomic_on_fetch(a);
  return result;
}

References atomic_on_fetch().

Referenced by buffer_pool_alloc(), buffer_pool_free(), buffer_pool_shrink(), cond_on_signal(), log_mmap_write(), node_pool_put(), packet_queue_enqueue(), packet_queue_enqueue_packet(), packet_queue_try_dequeue(), ringbuffer_read(), and rwlock_on_unlock().

atomic_fetch_sub_u64_impl()

uint64_t atomic_fetch_sub_u64_impl	(	atomic_t *	a,
		uint64_t	delta
	)

Definition at line 95 of file atomic.c.

                                                                {
  if (!a)
    return 0;
  return atomic_fetch_sub((_Atomic(uint64_t) *)&a->impl, delta);
}

atomic_load_bool()

bool atomic_load_bool

(

atomic_t *

a

)

Atomically load a boolean value.

Parameters

a	Pointer to atomic_t

Returns

Current boolean value

Definition at line 169 of file atomic.c.

                                   {
  if (!a)
    return false;
  bool result = (bool)atomic_load((const _Atomic(uint64_t) *)&a->impl);
  atomic_on_load(a);
  return result;
}

References atomic_on_load(), and bool.

Referenced by acds_client_handler(), acds_websocket_client_handler(), add_client(), add_webrtc_client(), any_clients_sending_video(), audio_sender_finalize(), audio_start_thread(), audio_stop_thread(), audio_thread_exited(), audio_write_samples(), broadcast_server_state_to_all_clients(), capture_stop_thread(), capture_thread_exited(), client_audio_render_thread(), client_dispatch_thread(), client_receive_thread(), client_send_thread_func(), client_video_render_thread(), debug_sync_is_cleanup_in_progress(), find_client_by_socket(), handle_audio_batch_packet(), handle_audio_opus_packet(), handle_image_frame_h265_packet(), handle_image_frame_packet(), handle_ping_packet(), keepalive_stop_thread(), keepalive_thread_exited(), keyboard_help_is_active(), keyboard_help_is_active_global(), keyboard_help_toggle(), log_lock_terminal(), log_msg(), log_search_needs_rerender(), mutex_stack_cleanup(), mutex_stack_cleanup_current_thread(), packet_queue_enqueue(), packet_queue_enqueue_packet(), packet_queue_try_dequeue(), protocol_connection_lost(), protocol_stop_connection(), remove_client(), send_server_state_to_client(), server_connection_is_active(), server_connection_is_lost(), session_display_has_first_frame(), session_display_write_ascii(), session_pipeline_run_main(), should_exit(), simple_frame_swap_update(), splash_is_running(), splash_wait_for_animation(), stats_logger_thread(), stop_client_render_threads(), tcp_client_is_active(), tcp_client_is_lost(), tcp_client_send_packet(), tcp_client_signal_lost(), tcp_server_run(), threaded_send_audio_batch_packet(), threaded_send_audio_opus(), threaded_send_audio_opus_batch(), threaded_send_packet(), update_server_stats(), video_frame_commit(), video_frame_get_latest(), webrtc_datachannel_is_open(), webrtc_datachannel_send(), websocket_client_is_active(), websocket_client_is_lost(), websocket_client_send_packet(), and websocket_server_run().

atomic_load_bool_impl()

bool atomic_load_bool_impl

(

const atomic_t *

a

)

Definition at line 24 of file atomic.c.

                                              {
  if (!a)
    return false;
  return (bool)atomic_load((const _Atomic(uint64_t) *)&a->impl);
}

atomic_load_int()

int atomic_load_int

(

atomic_t *

a

)

Atomically load an int value.

Parameters

a	Pointer to atomic_t

Returns

Current int value

Definition at line 194 of file atomic.c.

                                 {
  if (!a)
    return 0;
  int result = (int)(int32_t)atomic_load((const _Atomic(uint64_t) *)&a->impl);
  atomic_on_load(a);
  return result;
}

References atomic_on_load().

Referenced by log_console_impl(), log_destroy(), log_disable_file_output(), log_init(), log_msg(), log_plain_msg(), log_search_get_global_highlight(), log_search_get_match_info(), log_search_get_pattern_singleton(), log_search_is_active(), log_search_is_entering(), log_search_is_entering_atomic(), log_truncate_if_large(), mutex_stack_cleanup(), mutex_stack_cleanup_current_thread(), and mutex_stack_get_all_threads().

atomic_load_int_impl()

int atomic_load_int_impl

(

const atomic_t *

a

)

Definition at line 49 of file atomic.c.

                                            {
  if (!a)
    return 0;
  return (int)(int32_t)atomic_load((const _Atomic(uint64_t) *)&a->impl);
}

atomic_load_u64()

uint64_t atomic_load_u64

(

atomic_t *

a

)

Atomically load a uint64_t value.

Parameters

a	Pointer to atomic_t

Returns

Current uint64_t value

Definition at line 233 of file atomic.c.

                                      {
  if (!a)
    return 0;
  uint64_t result = atomic_load((const _Atomic(uint64_t) *)&a->impl);
  atomic_on_load(a);
  return result;
}

References atomic_on_load().

Referenced by asciichat_pcre2_cleanup_all(), asciichat_pcre2_singleton_free(), asciichat_pcre2_singleton_get_code(), asciichat_pcre2_singleton_is_initialized(), audio_ring_buffer_available_read(), audio_ring_buffer_discard_pending(), audio_ring_buffer_peek(), audio_ring_buffer_read(), audio_ring_buffer_write(), buffer_pool_alloc(), buffer_pool_free(), buffer_pool_get_stats(), buffer_pool_log_stats(), buffer_pool_shrink(), client_send_thread_func(), cond_format_state(), cond_on_signal(), create_mixed_ascii_frame_for_client(), get_utf8_palette_cache(), lifecycle_is_dead(), lifecycle_is_initialized(), lifecycle_shutdown_forever(), log_file_msg(), log_get_force_stderr(), log_get_level(), log_get_terminal_output(), log_init(), log_mmap_destroy(), log_mmap_get_stats(), log_mmap_get_usage(), log_mmap_rotate(), log_msg(), log_plain_msg(), log_shutdown_begin(), log_terminal_msg(), node_pool_get(), packet_queue_enqueue(), packet_queue_enqueue_packet(), packet_queue_get_stats(), packet_queue_is_full(), packet_queue_size(), packet_queue_try_dequeue(), protocol_stop_connection(), ringbuffer_peek(), ringbuffer_read(), ringbuffer_size(), ringbuffer_write(), rwlock_format_state(), rwlock_on_unlock(), session_display_write_audio(), session_log_buffer_append(), session_log_buffer_get_recent(), session_server_like_run(), session_server_like_shutdown_requested(), simple_frame_swap_get(), symbol_cache_destroy(), symbol_cache_get_stats(), symbol_cache_print_stats(), threaded_send_client_join_packet(), video_frame_get_stats(), webrtc_get_gathering_state(), webrtc_get_state(), webrtc_is_gathering_timed_out(), websocket_callback_timing_log_stats(), and websocket_callback_timing_record().

atomic_load_u64_impl()

uint64_t atomic_load_u64_impl

(

const atomic_t *

a

)

Definition at line 77 of file atomic.c.

                                                 {
  if (!a)
    return 0;
  return atomic_load((const _Atomic(uint64_t) *)&a->impl);
}

atomic_on_cas()

void atomic_on_cas	(	atomic_t *	a,
		bool	success
	)

Definition at line 348 of file atomic.c.

                                              {
  if (!a || !debug_atomic_is_initialized())
    return;
  a->cas_count++;
  if (success) {
    a->cas_success_count++;
    a->last_store_time_ns = time_get_ns();
  }
}

References atomic_t::cas_count, atomic_t::cas_success_count, debug_atomic_is_initialized(), atomic_t::last_store_time_ns, and time_get_ns().

Referenced by atomic_cas_bool(), atomic_cas_int(), and atomic_cas_u64().

atomic_on_fetch()

void atomic_on_fetch

(

atomic_t *

a

)

Definition at line 358 of file atomic.c.

                                  {
  if (!a || !debug_atomic_is_initialized())
    return;
  a->fetch_count++;
  a->last_store_time_ns = time_get_ns();
}

References debug_atomic_is_initialized(), atomic_t::fetch_count, atomic_t::last_store_time_ns, and time_get_ns().

Referenced by atomic_fetch_add_int(), atomic_fetch_add_u64(), atomic_fetch_sub_int(), and atomic_fetch_sub_u64().

atomic_on_load()

void atomic_on_load

(

atomic_t *

a

)

Definition at line 334 of file atomic.c.

                                 {
  if (!a || !debug_atomic_is_initialized())
    return;
  a->last_load_time_ns = time_get_ns();
  a->load_count++;
}

References debug_atomic_is_initialized(), atomic_t::last_load_time_ns, atomic_t::load_count, and time_get_ns().

Referenced by atomic_load_bool(), atomic_load_int(), and atomic_load_u64().

atomic_on_store()

void atomic_on_store

(

atomic_t *

a

)

Definition at line 341 of file atomic.c.

                                  {
  if (!a || !debug_atomic_is_initialized())
    return;
  a->last_store_time_ns = time_get_ns();
  a->store_count++;
}

References debug_atomic_is_initialized(), atomic_t::last_store_time_ns, atomic_t::store_count, and time_get_ns().

Referenced by atomic_exchange_bool(), atomic_exchange_int(), atomic_exchange_u64(), atomic_store_bool(), atomic_store_int(), and atomic_store_u64().

atomic_ptr_cas()

bool atomic_ptr_cas	(	atomic_ptr_t *	a,
		void **	expected,
		void *	new_value
	)

Atomically compare-and-swap a pointer.

Parameters

a	Pointer to atomic_ptr_t
expected	Expected current pointer (passed by reference)
new_value	Pointer value to store if comparison succeeds

Returns

true if swap succeeded, false otherwise

Definition at line 287 of file atomic.c.

                                                                       {
  if (!a || !expected)
    return false;
  bool success = atomic_compare_exchange_strong((_Atomic(void *) *)&a->impl, expected, new_value);
  atomic_ptr_on_cas(a, success);
  return success;
}

References atomic_ptr_on_cas().

Referenced by buffer_pool_alloc(), buffer_pool_free(), buffer_pool_shrink(), node_pool_get(), node_pool_put(), packet_queue_enqueue(), packet_queue_enqueue_packet(), and packet_queue_try_dequeue().

atomic_ptr_cas_impl()

bool atomic_ptr_cas_impl	(	atomic_ptr_t *	a,
		void **	expected,
		void *	new_value
	)

Definition at line 133 of file atomic.c.

                                                                            {
  if (!a || !expected)
    return false;
  return atomic_compare_exchange_strong((_Atomic(void *) *)&a->impl, expected, new_value);
}

atomic_ptr_exchange()

void * atomic_ptr_exchange	(	atomic_ptr_t *	a,
		void *	new_value
	)

Atomically exchange a pointer and return the old value.

Parameters

a	Pointer to atomic_ptr_t
new_value	Pointer value to store

Returns

Previous pointer value

Definition at line 295 of file atomic.c.

                                                            {
  if (!a)
    return NULL;
  void *result = atomic_exchange((_Atomic(void *) *)&a->impl, new_value);
  atomic_ptr_on_exchange(a);
  return result;
}

References atomic_ptr_on_exchange().

Referenced by buffer_pool_shrink().

atomic_ptr_exchange_impl()

void * atomic_ptr_exchange_impl	(	atomic_ptr_t *	a,
		void *	new_value
	)

Definition at line 139 of file atomic.c.

                                                                 {
  if (!a)
    return NULL;
  return atomic_exchange((_Atomic(void *) *)&a->impl, new_value);
}

atomic_ptr_load()

void * atomic_ptr_load

(

atomic_ptr_t *

a

)

Atomically load a pointer.

Parameters

a	Pointer to atomic_ptr_t

Returns

Current pointer value

Definition at line 272 of file atomic.c.

                                       {
  if (!a)
    return NULL;
  void *result = atomic_load((const _Atomic(void *) *)&a->impl);
  atomic_ptr_on_load(a);
  return result;
}

References atomic_ptr_on_load().

Referenced by buffer_pool_alloc(), buffer_pool_destroy(), buffer_pool_free(), buffer_pool_shrink(), log_get_session_log_buffer(), node_pool_get(), node_pool_put(), options_get(), options_state_destroy(), options_state_init(), options_state_set(), packet_queue_enqueue(), packet_queue_enqueue_packet(), packet_queue_try_dequeue(), and shutdown_is_requested().

atomic_ptr_load_impl()

void * atomic_ptr_load_impl

(

const atomic_ptr_t *

a

)

Definition at line 121 of file atomic.c.

                                                  {
  if (!a)
    return NULL;
  return atomic_load((const _Atomic(void *) *)&a->impl);
}

atomic_ptr_on_cas()

void atomic_ptr_on_cas	(	atomic_ptr_t *	a,
		bool	success
	)

Definition at line 379 of file atomic.c.

                                                      {
  if (!a || !debug_atomic_is_initialized())
    return;
  a->cas_count++;
  if (success) {
    a->cas_success_count++;
    a->last_store_time_ns = time_get_ns();
  }
}

References atomic_ptr_t::cas_count, atomic_ptr_t::cas_success_count, debug_atomic_is_initialized(), atomic_ptr_t::last_store_time_ns, and time_get_ns().

Referenced by atomic_ptr_cas().

atomic_ptr_on_exchange()

void atomic_ptr_on_exchange

(

atomic_ptr_t *

a

)

Definition at line 389 of file atomic.c.

                                             {
  if (!a || !debug_atomic_is_initialized())
    return;
  a->exchange_count++;
  a->last_store_time_ns = time_get_ns();
}

References debug_atomic_is_initialized(), atomic_ptr_t::exchange_count, atomic_ptr_t::last_store_time_ns, and time_get_ns().

Referenced by atomic_ptr_exchange().

atomic_ptr_on_load()

void atomic_ptr_on_load

(

atomic_ptr_t *

a

)

Definition at line 365 of file atomic.c.

                                         {
  if (!a || !debug_atomic_is_initialized())
    return;
  a->last_load_time_ns = time_get_ns();
  a->load_count++;
}

References debug_atomic_is_initialized(), atomic_ptr_t::last_load_time_ns, atomic_ptr_t::load_count, and time_get_ns().

Referenced by atomic_ptr_load().

atomic_ptr_on_store()

void atomic_ptr_on_store

(

atomic_ptr_t *

a

)

Definition at line 372 of file atomic.c.

                                          {
  if (!a || !debug_atomic_is_initialized())
    return;
  a->last_store_time_ns = time_get_ns();
  a->store_count++;
}

References debug_atomic_is_initialized(), atomic_ptr_t::last_store_time_ns, atomic_ptr_t::store_count, and time_get_ns().

Referenced by atomic_ptr_store().

atomic_ptr_store()

void atomic_ptr_store	(	atomic_ptr_t *	a,
		void *	value
	)

Atomically store a pointer.

Parameters

a	Pointer to atomic_ptr_t
value	Pointer value to store

Definition at line 280 of file atomic.c.

                                                    {
  if (!a)
    return;
  atomic_store((_Atomic(void *) *)&a->impl, value);
  atomic_ptr_on_store(a);
}

References atomic_ptr_on_store().

Referenced by buffer_pool_alloc(), buffer_pool_create(), buffer_pool_free(), buffer_pool_shrink(), log_clear_session_log_buffer(), log_set_session_log_buffer(), node_pool_create(), node_pool_get(), node_pool_put(), options_state_destroy(), options_state_init(), packet_queue_create_with_pools(), packet_queue_enqueue(), packet_queue_enqueue_packet(), packet_queue_try_dequeue(), session_display_set_global_context(), and shutdown_register_callback().

atomic_ptr_store_impl()

void atomic_ptr_store_impl	(	atomic_ptr_t *	a,
		void *	value
	)

Definition at line 127 of file atomic.c.

                                                         {
  if (!a)
    return;
  atomic_store((_Atomic(void *) *)&a->impl, value);
}

atomic_store_bool()

void atomic_store_bool	(	atomic_t *	a,
		bool	value
	)

Atomically store a boolean value.

Parameters

a	Pointer to atomic_t
value	Value to store

Definition at line 177 of file atomic.c.

                                                {
  if (!a)
    return;
  atomic_store((_Atomic(uint64_t) *)&a->impl, (uint64_t)value);
  atomic_on_store(a);
}

References atomic_on_store().

Referenced by acds_server_init(), acds_server_shutdown(), acip_websocket_client_transport_create(), add_client(), add_webrtc_client(), app_client_create(), audio_destroy(), audio_init(), audio_ring_buffer_clear(), audio_ring_buffer_discard_pending(), audio_sender_cleanup(), audio_sender_init(), audio_start_duplex(), audio_start_thread(), audio_stop_duplex(), audio_stop_thread(), capture_start_thread(), client_receive_thread(), client_send_thread_func(), create_client_render_threads(), debug_sync_cleanup_thread(), debug_sync_print_backtrace_delayed(), debug_sync_print_state_delayed(), debug_sync_start_thread(), debug_sync_trigger_print(), disconnect_client_for_bad_data(), display_reset_for_new_connection(), handle_client_leave_packet(), handle_stream_start_packet(), handle_stream_stop_packet(), keepalive_start_thread(), keyboard_help_signal_cancel(), keyboard_help_toggle(), log_destroy(), log_init(), log_search_enter_mode(), log_search_exit_mode(), log_search_handle_key(), log_search_init(), log_search_needs_rerender(), log_search_signal_cancel(), log_set_level(), log_shutdown_begin(), mutex_stack_cleanup(), packet_queue_create_with_pools(), protocol_start_connection(), remove_client(), server_connection_close(), server_connection_establish(), server_connection_init(), server_connection_lost(), server_connection_set_transport(), server_connection_shutdown(), session_display_create(), session_display_reset_first_frame(), session_pipeline_create(), session_pipeline_destroy(), session_pipeline_run_main(), session_server_like_run(), signal_exit(), simple_frame_swap_create(), simple_frame_swap_update(), splash_intro_start(), splash_wait_for_animation(), stop_client_render_threads(), stop_client_threads(), tcp_client_close(), tcp_client_connect(), tcp_client_create(), tcp_client_shutdown(), tcp_client_signal_lost(), tcp_server_destroy(), tcp_server_init(), video_frame_buffer_create(), video_frame_commit(), video_frame_get_latest(), webrtc_close_datachannel(), webrtc_create_datachannel(), webrtc_datachannel_set_open_state(), websocket_client_close(), websocket_client_connect(), websocket_client_create(), websocket_client_shutdown(), websocket_client_signal_lost(), websocket_server_destroy(), and websocket_server_init().

atomic_store_bool_impl()

void atomic_store_bool_impl	(	atomic_t *	a,
		uint64_t	value
	)

Definition at line 30 of file atomic.c.

                                                         {
  if (!a)
    return;
  atomic_store((_Atomic(uint64_t) *)&a->impl, value);
}

atomic_store_int()

void atomic_store_int	(	atomic_t *	a,
		int	value
	)

Atomically store an int value.

Parameters

a	Pointer to atomic_t
value	Value to store

Definition at line 202 of file atomic.c.

                                              {
  if (!a)
    return;
  atomic_store((_Atomic(uint64_t) *)&a->impl, (uint64_t)(int32_t)value);
  atomic_on_store(a);
}

References atomic_on_store().

Referenced by lifecycle_init_abort(), lifecycle_init_commit(), lifecycle_shutdown(), log_destroy(), log_disable_file_output(), log_init(), log_search_enter_mode(), log_search_exit_mode(), log_search_init(), log_set_json_output(), and mutex_stack_cleanup().

atomic_store_int_impl()

void atomic_store_int_impl	(	atomic_t *	a,
		uint64_t	value
	)

Definition at line 55 of file atomic.c.

                                                        {
  if (!a)
    return;
  atomic_store((_Atomic(uint64_t) *)&a->impl, value);
}

atomic_store_u64()

void atomic_store_u64	(	atomic_t *	a,
		uint64_t	value
	)

Atomically store a uint64_t value.

Parameters

a	Pointer to atomic_t
value	Value to store

Definition at line 241 of file atomic.c.

                                                   {
  if (!a)
    return;
  atomic_store((_Atomic(uint64_t) *)&a->impl, value);
  atomic_on_store(a);
}

References atomic_on_store().

Referenced by acds_server_init(), add_client(), add_webrtc_client(), asciichat_pcre2_cleanup_all(), asciichat_pcre2_singleton_compile(), asciichat_pcre2_singleton_get_code(), audio_ring_buffer_clear(), audio_ring_buffer_discard_pending(), audio_ring_buffer_read(), audio_ring_buffer_write(), buffer_pool_alloc(), buffer_pool_create(), buffer_pool_free(), client_send_thread_func(), client_video_render_thread(), cond_on_broadcast(), get_utf8_palette_cache(), lifecycle_destroy_commit(), lifecycle_init_abort(), lifecycle_init_commit(), log_init(), log_lock_terminal(), log_mmap_init(), log_mmap_rotate(), log_set_flush_delay(), log_set_force_stderr(), log_set_format(), log_set_level(), log_set_terminal_output(), log_shutdown_end(), log_truncate_if_large(), log_unlock_terminal(), node_pool_create(), packet_queue_create_with_pools(), packet_queue_stop(), ringbuffer_clear(), ringbuffer_read(), ringbuffer_write(), session_display_write_audio(), session_log_buffer_append(), session_log_buffer_clear(), session_log_buffer_create(), session_pipeline_create(), session_server_like_run(), simple_frame_swap_create(), simple_frame_swap_update(), splash_intro_done(), symbol_cache_init(), video_frame_buffer_create(), webrtc_create_peer_connection(), and websocket_callback_timing_reset().

atomic_store_u64_impl()

void atomic_store_u64_impl	(	atomic_t *	a,
		uint64_t	value
	)

Definition at line 83 of file atomic.c.

                                                        {
  if (!a)
    return;
  atomic_store((_Atomic(uint64_t) *)&a->impl, value);
}

debug_atomic_is_initialized()

bool debug_atomic_is_initialized ( void  )

extern

Definition at line 38 of file debug/atomic.c.

                                       {
  return g_atomic_debug_initialized;
}

Referenced by atomic_on_cas(), atomic_on_fetch(), atomic_on_load(), atomic_on_store(), atomic_ptr_on_cas(), atomic_ptr_on_exchange(), atomic_ptr_on_load(), and atomic_ptr_on_store().