Functions
void	debug_stats_set_main_thread_id (void)
uint64_t	debug_stats_get_main_thread_id (void)
asciichat_error_t	debug_stats_init (void)
void	debug_stats_print (void)
void	debug_stats_set_memory_report_interval (uint64_t interval)
void	debug_stats_trigger_print (void)
void	debug_stats_trigger_memory_report (void)
bool	debug_stats_is_cleanup_in_progress (void)
void	debug_stats_poll (void)
asciichat_error_t	debug_stats_start_thread (void)
void	debug_stats_cleanup_thread (void)
void	debug_stats_destroy (void)

Function Documentation

◆ debug_stats_cleanup_thread()

void debug_stats_cleanup_thread ( void )

Definition at line 131 of file lib/debug/stats.c.

                                      {
  if (!g_debug_stats_started)
    return;
  atomic_store_bool_impl(&g_debug_stats_cleaning, true);
  mutex_lock(&g_debug_stats_mutex);
  atomic_store_bool_impl(&g_debug_stats_exiting, true);
  cond_signal(&g_debug_stats_condition);
  mutex_unlock(&g_debug_stats_mutex);
#ifndef EMSCRIPTEN_BUILD
  // Join fully: diagnostic data must not be destroyed while a reader is alive.
  if (thread_join(&g_debug_stats_thread, NULL) != 0)
    FATAL(ERROR_THREAD, "Cannot join diagnostics worker");
#endif
  g_debug_stats_started = false;
}

References ERROR_THREAD, and FATAL.

Referenced by asciichat_shared_destroy(), and debug_stats_destroy().

◆ debug_stats_destroy()

void debug_stats_destroy ( void )

Definition at line 146 of file lib/debug/stats.c.

                               {
  debug_stats_cleanup_thread();
  if (g_debug_stats_initialized) {
    cond_destroy(&g_debug_stats_condition);
    mutex_destroy(&g_debug_stats_mutex);
    g_debug_stats_initialized = false;
    atomic_store_bool_impl(&g_debug_stats_signal, false);
    atomic_store_bool_impl(&g_debug_stats_memory_signal, false);
    g_debug_stats_memory_deadline = g_debug_stats_memory_interval = 0;
  }
}

References debug_stats_cleanup_thread().

Referenced by asciichat_shared_destroy().

◆ debug_stats_get_main_thread_id()

uint64_t debug_stats_get_main_thread_id ( void )

Definition at line 28 of file lib/debug/stats.c.

                                              {
  return g_debug_stats_main_thread;
}

◆ debug_stats_init()

asciichat_error_t debug_stats_init ( void )

Definition at line 31 of file lib/debug/stats.c.

                                         {
  if (g_debug_stats_initialized)
    return ASCIICHAT_OK;
  if (mutex_init(&g_debug_stats_mutex, "debug_stats") != 0)
    return SET_ERRNO(ERROR_THREAD, "Cannot initialize diagnostics mutex");
  if (cond_init(&g_debug_stats_condition, "debug_stats") != 0) {
    mutex_destroy(&g_debug_stats_mutex);
    return SET_ERRNO(ERROR_THREAD, "Cannot initialize diagnostics condition");
  }
  g_debug_stats_initialized = true;
  atomic_store_bool_impl(&g_debug_stats_cleaning, false);
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, ERROR_THREAD, and SET_ERRNO.

Referenced by debug_stats_start_thread(), and main().

◆ debug_stats_is_cleanup_in_progress()

bool debug_stats_is_cleanup_in_progress ( void )

Definition at line 66 of file lib/debug/stats.c.

                                              {
  return atomic_load_bool_impl(&g_debug_stats_cleaning);
}

◆ debug_stats_poll()

void debug_stats_poll ( void )

Definition at line 69 of file lib/debug/stats.c.

                            {
  if (!g_debug_stats_initialized)
    return;
  uint64_t now = time_get_ns();
  bool all = atomic_exchange_bool_impl(&g_debug_stats_signal, false);
  bool requested_memory = atomic_exchange_bool_impl(&g_debug_stats_memory_signal, false);
  mutex_lock(&g_debug_stats_mutex);
  bool memory = g_debug_stats_memory_deadline && now >= g_debug_stats_memory_deadline;
  if (memory)
    g_debug_stats_memory_deadline = debug_report_deadline_after(now, g_debug_stats_memory_interval);
  mutex_unlock(&g_debug_stats_mutex);
  if (all)
    debug_stats_print();
#if defined(DEBUG_MEMORY) && !defined(NDEBUG)
  if (memory || requested_memory)
    debug_memory_report(GET_OPTION(color));
#else
  (void)memory;
#endif
}

References debug_report_deadline_after(), debug_stats_print(), and GET_OPTION.

◆ debug_stats_print()

void debug_stats_print ( void )

Definition at line 44 of file lib/debug/stats.c.

                             {
  log_info("Diagnostic statistics:");
  asciichat_error_stats_print();
}

References asciichat_error_stats_print(), and log_info.

Referenced by debug_stats_poll().

◆ debug_stats_set_main_thread_id()

void debug_stats_set_main_thread_id ( void )

Definition at line 25 of file lib/debug/stats.c.

                                          {
  g_debug_stats_main_thread = thread_current_id();
}

Referenced by main().

◆ debug_stats_set_memory_report_interval()

void debug_stats_set_memory_report_interval ( uint64_t interval )

Definition at line 48 of file lib/debug/stats.c.

                                                               {
  if (!g_debug_stats_initialized)
    return;
  mutex_lock(&g_debug_stats_mutex);
  g_debug_stats_memory_interval = interval;
  g_debug_stats_memory_deadline = interval ? debug_report_deadline_after(time_get_ns(), interval) : 0;
  cond_signal(&g_debug_stats_condition);
  mutex_unlock(&g_debug_stats_mutex);
}

References debug_report_deadline_after().

Referenced by debug_stats_start_thread().

◆ debug_stats_start_thread()

asciichat_error_t debug_stats_start_thread ( void )

Definition at line 111 of file lib/debug/stats.c.

                                                 {
  if (g_debug_stats_started)
    return ASCIICHAT_OK;
  asciichat_error_t result = debug_stats_init();
  if (result != ASCIICHAT_OK)
    return result;
  atomic_store_bool_impl(&g_debug_stats_exiting, false);
  atomic_store_bool_impl(&g_debug_stats_cleaning, false);
  options_t *opts = options_get();
  if (opts) {
    if (opts->debug_memory_report_interval > 0)
      debug_stats_set_memory_report_interval((uint64_t)(opts->debug_memory_report_interval * NS_PER_SEC_INT));
  }
#ifndef EMSCRIPTEN_BUILD
  if (platform_thread_create(&g_debug_stats_thread, "debug_stats", debug_stats_worker, NULL) != 0)
    return SET_ERRNO(ERROR_THREAD, "Cannot start diagnostics worker");
#endif
  g_debug_stats_started = true;
  return ASCIICHAT_OK;
}

References ASCIICHAT_OK, options_state::debug_memory_report_interval, debug_stats_init(), debug_stats_set_memory_report_interval(), ERROR_THREAD, NS_PER_SEC_INT, options_get(), and SET_ERRNO.

Referenced by main().

◆ debug_stats_trigger_memory_report()

void debug_stats_trigger_memory_report ( void )

Request a deferred memory report from the diagnostics worker.

Definition at line 62 of file lib/debug/stats.c.

                                             {
  // Signal handlers may only set the request; the worker performs the report.
  atomic_store_bool_impl(&g_debug_stats_memory_signal, true);
}

◆ debug_stats_trigger_print()

void debug_stats_trigger_print ( void )

Definition at line 57 of file lib/debug/stats.c.

                                     {
  // Do not signal a condition variable or invoke diagnostic hooks in a signal
  // handler. The worker checks this flag at most 100ms after its next wakeup.
  atomic_store_bool_impl(&g_debug_stats_signal, true);
}

Functions