sync.c File Reference

Go to the source code of this file.

Data Structures
struct	sync_row_t
struct	sync_sample_t
	sync row keeps the values that move through the subsystem: key, owner, waiter, generation. Some members are pointers into caller- or subsystem-owned memory, so lifetime follows the API that populated them rather than the struct copy itself. More...

Macros
#define	TUI_SYNC_NAME_BUFFER_SIZE   256
#define	TUI_SYNC_TYPE_BUFFER_SIZE   24
#define	TUI_SYNC_FILE_BUFFER_SIZE   160
#define	TUI_SYNC_OUTPUT_BUFFER_SIZE   2048
#define	TUI_SYNC_LINE_BUFFER_SIZE   2048
#define	TUI_SYNC_LABEL_BUFFER_SIZE   288
#define	TUI_SYNC_DEADLOCK_BUFFER_SIZE   128
#define	TUI_SYNC_LINE_SHORT_BUFFER_SIZE   1024
#define	TUI_SYNC_NAME_EXTENDED_BUFFER_SIZE   288
#define	TUI_SYNC_STATE_BUFFER_SIZE   128
#define	TUI_SYNC_PADDED_STATE_BUFFER_SIZE   256
#define	TUI_SYNC_PLAIN_ACTIONS_BUFFER_SIZE   32
#define	TUI_SYNC_ACTIONS_BUFFER_SIZE   256
#define	TUI_SYNC_PADDED_ACTIONS_BUFFER_SIZE   32
#define	TUI_SYNC_CHANGES_BUFFER_SIZE   64
#define	TUI_SYNC_PADDED_WAIT_BUFFER_SIZE   48
#define	TUI_SYNC_COLORED_WAIT_BUFFER_SIZE   512
#define	TUI_SYNC_LOCKS_BUFFER_SIZE   96
#define	TUI_SYNC_UNLOCKS_BUFFER_SIZE   96
#define	TUI_SYNC_NUMBERS_BUFFER_SIZE   512
#define	TUI_SYNC_FULL_NAME_BUFFER_SIZE   288
#define	TUI_SYNC_COLORED_NAME_BUFFER_SIZE   640
#define	TUI_SYNC_OUTPUT_SHORT_BUFFER_SIZE   512
#define	SYNC_WAIT_SNAPSHOT_CAPACITY   256
#define	SYNC_ROW_CAPACITY   128
#define	SYNC_OUTPUT_BUFFER_SIZE   (64 * 1024)

Functions
asciichat_error_t	ui_sync_start (int fd)
void	ui_sync_stop (void)
bool	ui_sync_is_visible (void)
int	ui_sync_output_fd (void)
keyboard_key_t	ui_sync_handle_key (keyboard_key_t key)
void	ui_sync_render (terminal_size_t size)

Macro Definition Documentation

SYNC_OUTPUT_BUFFER_SIZE

#define SYNC_OUTPUT_BUFFER_SIZE   (64 * 1024)

Definition at line 30 of file sync.c.

SYNC_ROW_CAPACITY

#define SYNC_ROW_CAPACITY   128

Definition at line 29 of file sync.c.

Referenced by ui_sync_render().

SYNC_WAIT_SNAPSHOT_CAPACITY

#define SYNC_WAIT_SNAPSHOT_CAPACITY   256

Definition at line 28 of file sync.c.

TUI_SYNC_ACTIONS_BUFFER_SIZE

#define TUI_SYNC_ACTIONS_BUFFER_SIZE   256

Definition at line 15 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_CHANGES_BUFFER_SIZE

#define TUI_SYNC_CHANGES_BUFFER_SIZE   64

Definition at line 17 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_COLORED_NAME_BUFFER_SIZE

#define TUI_SYNC_COLORED_NAME_BUFFER_SIZE   640

Definition at line 24 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_COLORED_WAIT_BUFFER_SIZE

#define TUI_SYNC_COLORED_WAIT_BUFFER_SIZE   512

Definition at line 19 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_DEADLOCK_BUFFER_SIZE

#define TUI_SYNC_DEADLOCK_BUFFER_SIZE   128

Definition at line 9 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_FILE_BUFFER_SIZE

#define TUI_SYNC_FILE_BUFFER_SIZE   160

Definition at line 5 of file sync.c.

TUI_SYNC_FULL_NAME_BUFFER_SIZE

#define TUI_SYNC_FULL_NAME_BUFFER_SIZE   288

Definition at line 23 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_LABEL_BUFFER_SIZE

#define TUI_SYNC_LABEL_BUFFER_SIZE   288

Definition at line 8 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_LINE_BUFFER_SIZE

#define TUI_SYNC_LINE_BUFFER_SIZE   2048

Definition at line 7 of file sync.c.

TUI_SYNC_LINE_SHORT_BUFFER_SIZE

#define TUI_SYNC_LINE_SHORT_BUFFER_SIZE   1024

Definition at line 10 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_LOCKS_BUFFER_SIZE

#define TUI_SYNC_LOCKS_BUFFER_SIZE   96

Definition at line 20 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_NAME_BUFFER_SIZE

#define TUI_SYNC_NAME_BUFFER_SIZE   256

Definition at line 3 of file sync.c.

TUI_SYNC_NAME_EXTENDED_BUFFER_SIZE

#define TUI_SYNC_NAME_EXTENDED_BUFFER_SIZE   288

Definition at line 11 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_NUMBERS_BUFFER_SIZE

#define TUI_SYNC_NUMBERS_BUFFER_SIZE   512

Definition at line 22 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_OUTPUT_BUFFER_SIZE

#define TUI_SYNC_OUTPUT_BUFFER_SIZE   2048

Definition at line 6 of file sync.c.

TUI_SYNC_OUTPUT_SHORT_BUFFER_SIZE

#define TUI_SYNC_OUTPUT_SHORT_BUFFER_SIZE   512

Definition at line 25 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_PADDED_ACTIONS_BUFFER_SIZE

#define TUI_SYNC_PADDED_ACTIONS_BUFFER_SIZE   32

Definition at line 16 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_PADDED_STATE_BUFFER_SIZE

#define TUI_SYNC_PADDED_STATE_BUFFER_SIZE   256

Definition at line 13 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_PADDED_WAIT_BUFFER_SIZE

#define TUI_SYNC_PADDED_WAIT_BUFFER_SIZE   48

Definition at line 18 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_PLAIN_ACTIONS_BUFFER_SIZE

#define TUI_SYNC_PLAIN_ACTIONS_BUFFER_SIZE   32

Definition at line 14 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_STATE_BUFFER_SIZE

#define TUI_SYNC_STATE_BUFFER_SIZE   128

Definition at line 12 of file sync.c.

Referenced by ui_sync_render().

TUI_SYNC_TYPE_BUFFER_SIZE

#define TUI_SYNC_TYPE_BUFFER_SIZE   24

Definition at line 4 of file sync.c.

TUI_SYNC_UNLOCKS_BUFFER_SIZE

#define TUI_SYNC_UNLOCKS_BUFFER_SIZE   96

Definition at line 21 of file sync.c.

Referenced by ui_sync_render().

Function Documentation

ui_sync_handle_key()

keyboard_key_t ui_sync_handle_key

(

keyboard_key_t

key

)

Definition at line 364 of file sync.c.

                                                      {
  if (key == KEY_0) {
    ui_controller_select_interactive(ui_sync_is_visible() ? -1 : UI_SCREEN_SYNC);
    return KEY_NONE;
  }
  if (!ui_sync_is_visible())
    return key;
  // Leave sync selected until the replacement has a complete snapshot.
  if (key == '=' || key == KEY_BACKTICK || key == KEY_QUESTION || key == ']' || key == 'o' || key == 'O' || key == 15)
    return key;
  if (key == KEY_ESCAPE) {
    ui_controller_select_interactive(-1);
    return KEY_NONE;
  }
  ui_viewport_t viewport = {.selected = (size_t)atomic_load(&g_sync_selected),
                            .page_size = (size_t)atomic_load(&g_sync_page_size)};
  ui_viewport_key(&viewport, (size_t)atomic_load(&g_sync_total), viewport.page_size, key);
  atomic_store(&g_sync_selected, (int)viewport.selected);
  return key == 'q' || key == 3 ? key : KEY_NONE;
}

References KEY_0, KEY_BACKTICK, KEY_ESCAPE, KEY_NONE, KEY_QUESTION, ui_viewport_t::page_size, ui_viewport_t::selected, ui_controller_select_interactive(), UI_SCREEN_SYNC, ui_sync_is_visible(), and ui_viewport_key().

Referenced by ui_input_poll_sync(), and ui_input_read_key().

ui_sync_is_visible()

bool ui_sync_is_visible

(

void

)

Definition at line 357 of file sync.c.

                              {
  return ui_controller_interactive_screen() == UI_SCREEN_SYNC;
}

References ui_controller_interactive_screen(), and UI_SCREEN_SYNC.

Referenced by ui_sync_handle_key(), and ui_sync_stop().

ui_sync_output_fd()

int ui_sync_output_fd

(

void

)

Definition at line 360 of file sync.c.

                            {
  return g_sync_fd;
}

Referenced by ui_sync_render().

ui_sync_render()

void ui_sync_render

(

terminal_size_t

size

)

Called only by the presentation thread; uses already-owned snapshots.

Definition at line 486 of file sync.c.

                                          {
  colored_string_set_output_fd(ui_sync_output_fd() >= 0 ? ui_sync_output_fd() : STDOUT_FILENO);
  terminal_capabilities_t caps = detect_terminal_capabilities(options_terminal_settings());
  terminal_color_mode_t mode = GET_OPTION(color_mode);
  g_sync_use_color = mode != TERM_COLOR_NONE && GET_OPTION(color) != COLOR_SETTING_FALSE && !GET_OPTION(strip_ansi) &&
                     (mode != TERM_COLOR_AUTO || caps.color_level != TERM_COLOR_NONE);
  g_sync_use_utf8 = terminal_should_use_utf8(GET_OPTION(force_utf8));
  // Copy only the visible page before terminal writes; the collector never
  // waits for output, and the renderer never waits for collection.
  sync_row_t rows[SYNC_ROW_CAPACITY];
  size_t count = 0, total = 0, cycles = 0;
  size_t mutexes = 0, conditions = 0, rwlocks = 0, atomics = 0;
  uint64_t sampled = 0;
  bool waits_complete = false, limited = false;
  enum { header_rows = 4, detail_rows = 3, footer_rows = 1 };
  const int fixed_rows = header_rows + detail_rows + footer_rows;
  int name_width = (int)strlen("Name");
  ui_layout_t layout;
  if (ui_layout_measure(size, header_rows, detail_rows, footer_rows, &layout) != ASCIICHAT_OK)
    return;
  int per_page = layout.body_rows > 0 ? layout.body_rows : 1;
  if (per_page > 128)
    per_page = 128;
  atomic_store(&g_sync_page_size, per_page);
  int selected = atomic_load(&g_sync_selected);
  int page = 0, pages = 1;
  int slot = atomic_load(&g_sync_published);
  if (slot >= 0) {
    // Keep the last complete screen if collection is reusing this mailbox.
    if (atomic_flag_test_and_set(&g_sync_samples[slot].busy)) {
      return;
    }
    sync_sample_t *s = &g_sync_samples[slot];
    total = s->count;
    atomic_store(&g_sync_total, total > INT_MAX ? INT_MAX : (int)total);
    if ((size_t)selected >= total) {
      int previous = selected;
      selected = total ? (int)total - 1 : 0;
      // Do not overwrite a key received while the renderer copies a sample.
      atomic_compare_exchange_strong(&g_sync_selected, &previous, selected);
    }
    pages = total ? (int)((total + per_page - 1) / per_page) : 1;
    page = selected / per_page;
    size_t first = (size_t)page * per_page;
    count = total > first ? total - first : 0;
    if (count > (size_t)per_page)
      count = per_page;
    if (count)
      memcpy(rows, s->rows + first, count * sizeof(*rows));
    for (size_t i = 0; i < total; ++i) {
      cycles += s->rows[i].cycle;
      const char *type = s->rows[i].type;
      mutexes += !strcmp(type, "mutex");
      conditions += !strcmp(type, "cond");
      rwlocks += !strcmp(type, "rwlock");
      atomics += !strncmp(type, "atomic", 6);
      char label[TUI_SYNC_LABEL_BUFFER_SIZE];
      sync_row_label(&s->rows[i], label, sizeof(label));
      int width = (int)strlen(label);
      if (width > name_width)
        name_width = width;
    }
    sampled = s->sampled_ns;
    waits_complete = s->waits_complete;
    limited = s->limited;
    atomic_flag_clear(&s->busy);
  }
  if (name_width > 30)
    name_width = 30;
  uint64_t now = time_get_ns();
  selected %= per_page;
  if ((size_t)selected >= count)
    selected = count ? (int)count - 1 : 0;
  char deadlock[TUI_SYNC_DEADLOCK_BUFFER_SIZE];
  snprintf(deadlock, sizeof(deadlock), "%s%s%s", sync_color(LOG_COLOR_ERROR),
           g_sync_use_utf8 ? "DEADLOCK ❌" : "DEADLOCK!", sync_color(LOG_COLOR_RESET));
  int measured_width = 0;
  for (int pass = 0; pass < 2; ++pass) {
    int *measure = pass == 0 ? &measured_width : NULL;
    char line[TUI_SYNC_LINE_SHORT_BUFFER_SIZE];
    if (!measure)
      sync_write("\033[?2026h\033[H", 11);
    snprintf(line, sizeof(line), "Sync primitives | %zu objects | page %d/%d | item %zu/%zu | age %.1fs", total,
             page + 1, pages, count ? (size_t)page * per_page + selected + 1 : 0, total,
             sampled ? (double)(now - sampled) / NS_PER_SEC_INT : 0.0);
    sync_write_numbers(line, size.cols, measure);
    snprintf(line, sizeof(line), "%s%s | M=%zu RW=%zu C=%zu A=%zu | %zu mutexes in wait cycles%s",
             cycles ? sync_color(LOG_COLOR_ERROR) : "",
             !sampled                         ? "Waiting for registry"
             : now - sampled > NS_PER_SEC_INT ? "STALE: collection unavailable"
                                              : "Live registered",
             mutexes, rwlocks, conditions, atomics, cycles,
             !waits_complete ? " | wait tracker busy"
             : limited       ? " | wait tracker capacity reached"
                             : "");
    sync_write_numbers(line, size.cols, measure);
    snprintf(line, sizeof(line), "%s %-8s %-*s %-12s  %13s %6s %6s %7s %12s%s", sync_color(LOG_COLOR_GREY), "Type",
             name_width, "Name", "State/value", "Total Actions", "L/s", "U/s", "Change/s", "Total Wait",
             sync_color(LOG_COLOR_RESET));
    sync_write_line(line, size.cols, true, measure);
    sync_separator(size.cols, measure);
    for (size_t i = 0; i < count; ++i) {
      sync_row_t *r = &rows[i];
      // Parent names may be media paths; keep the primitive visible in the table.
      // The detail row identifies the source location and address.
      char name[TUI_SYNC_NAME_EXTENDED_BUFFER_SIZE];
      sync_row_label(r, name, sizeof(name));
      if (strlen(name) > (size_t)name_width) {
        const char *suffix = strrchr(name, '.');
        size_t suffix_bytes = suffix && strspn(suffix + 1, "0123456789") == strlen(suffix + 1) ? strlen(suffix) : 0;
        if (suffix_bytes >= (size_t)name_width - 1)
          suffix_bytes = 0;
        size_t used = 0;
        int columns = 0;
        while (name[used]) {
          int bytes = utf8_next_char_bytes(name + used, strlen(name + used));
          if (bytes <= 0)
            break;
          int width = utf8_display_width_n(name + used, bytes);
          if (columns + width > name_width - 1 - (int)suffix_bytes)
            break;
          used += bytes;
          columns += width;
        }
        name[used++] = '~';
        if (suffix_bytes) {
          memmove(name + used, suffix, suffix_bytes);
          used += suffix_bytes;
        }
        name[used] = '\0';
      }
      char state[TUI_SYNC_STATE_BUFFER_SIZE];
      if (r->cycle)
        snprintf(state, sizeof(state), "DEADLOCK");
      else if (!strcmp(r->type, "mutex"))
        snprintf(state, sizeof(state), "%s t=%" PRIxPTR " w=%u",
                 r->cycle   ? "CYCLE"
                 : r->owner ? "HELD"
                            : "FREE",
                 r->owner, r->waiters);
      else if (!strcmp(r->type, "rwlock"))
        snprintf(state, sizeof(state), "W=%" PRIxPTR " R=%" PRIu64, r->owner, r->value);
      else if (!strcmp(r->type, "cond"))
        snprintf(state, sizeof(state), "waiting=%" PRIu64, r->value);
      else
        snprintf(state, sizeof(state), "0x%" PRIx64 " (%" PRIu64 ")", r->value, r->value);
      // Prefer the complete hex value over a clipped redundant decimal copy.
      if (!strncmp(r->type, "atomic", 6) && strlen(state) > 12)
        snprintf(state, sizeof(state), "0x%" PRIx64, r->value);
      char padded_state[TUI_SYNC_PADDED_STATE_BUFFER_SIZE];
      if (r->cycle) {
        int width = utf8_display_width(g_sync_use_utf8 ? "DEADLOCK ❌" : "DEADLOCK!");
        snprintf(padded_state, sizeof(padded_state), "%s%*s", deadlock, 12 - width, "");
      } else {
        snprintf(padded_state, sizeof(padded_state), "%-12.12s", state);
      }
      char plain_actions[TUI_SYNC_PLAIN_ACTIONS_BUFFER_SIZE], actions[TUI_SYNC_ACTIONS_BUFFER_SIZE];
      format_number_compact(r->actions, plain_actions, sizeof(plain_actions));
      char padded_actions[TUI_SYNC_PADDED_ACTIONS_BUFFER_SIZE];
      snprintf(padded_actions, sizeof(padded_actions), "%13s", plain_actions);
      sync_color_numbers(padded_actions, actions, sizeof(actions));
      char changes[TUI_SYNC_CHANGES_BUFFER_SIZE];
      if (!strncmp(r->type, "atomic", 6))
        snprintf(changes, sizeof(changes), "%s%7.1f", sync_rate_color(r->change_rate), r->change_rate);
      else
        snprintf(changes, sizeof(changes), "%s%7s", sync_color(LOG_COLOR_RESET), "-");
      char wait[TIME_DURATION_BUFFER_SIZE] = "-";
      if (!strcmp(r->type, "cond")) {
        if (r->wait_known)
          time_pretty(r->wait_ns, -1, wait, sizeof(wait));
        else
          snprintf(wait, sizeof(wait), "busy");
      }
      char padded_wait[TUI_SYNC_PADDED_WAIT_BUFFER_SIZE], colored_wait[TUI_SYNC_COLORED_WAIT_BUFFER_SIZE];
      snprintf(padded_wait, sizeof(padded_wait), "%12s", wait);
      sync_color_numbers(padded_wait, colored_wait, sizeof(colored_wait));
      char locks[TUI_SYNC_LOCKS_BUFFER_SIZE], unlocks[TUI_SYNC_UNLOCKS_BUFFER_SIZE];
      snprintf(locks, sizeof(locks), "%s%6.1f%s", sync_rate_color(r->lock_rate), r->lock_rate,
               sync_color(LOG_COLOR_RESET));
      snprintf(unlocks, sizeof(unlocks), "%s%6.1f%s", sync_rate_color(r->unlock_rate), r->unlock_rate,
               sync_color(LOG_COLOR_RESET));
      const ui_table_column_t columns[] = {
          {"Type", 8, UI_ALIGN_LEFT, false},         {"Name", name_width, UI_ALIGN_LEFT, false},
          {"State/value", 13, UI_ALIGN_LEFT, false}, {"Total Actions", 13, UI_ALIGN_RIGHT, false},
          {"L/s", 6, UI_ALIGN_RIGHT, false},         {"U/s", 6, UI_ALIGN_RIGHT, false},
          {"Change/s", 7, UI_ALIGN_RIGHT, false},    {"Total Wait", 12, UI_ALIGN_RIGHT, false}};
      const char *cells[] = {r->type, name, padded_state, actions, locks, unlocks, changes, colored_wait};
      ui_table_row(line, sizeof(line), columns, cells, 8, name_width + 83, true, (int)i == selected);
      sync_write_line(line, size.cols, true, measure);
    }
    if (!measure) {
      // Clear only unused table rows, leaving the live footer in place.
      for (int row = header_rows + (int)count + 1; row < size.rows - 3; ++row) {
        snprintf(line, sizeof(line), "\033[%d;1H\033[K", row);
        sync_write(line, strlen(line));
      }
      snprintf(line, sizeof(line), "\033[%d;1H", size.rows > 3 ? size.rows - 3 : 1);
      sync_write(line, strlen(line));
    }
    sync_separator(size.cols, measure);
    if (count) {
      sync_row_t *r = &rows[selected];
      snprintf(line, sizeof(line), "%d @0x%" PRIxPTR, r->line, r->key);
      char numbers[TUI_SYNC_NUMBERS_BUFFER_SIZE];
      sync_color_numbers(line, numbers, sizeof(numbers));
      char full_name[TUI_SYNC_FULL_NAME_BUFFER_SIZE], colored_name[TUI_SYNC_COLORED_NAME_BUFFER_SIZE];
      sync_row_label(r, full_name, sizeof(full_name));
      sync_color_numbers(full_name, colored_name, sizeof(colored_name));
      snprintf(line, sizeof(line), "%s%s%s:%s | %s", sync_color(LOG_COLOR_DEV), r->file, sync_color(LOG_COLOR_RESET),
               numbers, colored_name);
      sync_write_line(line, size.cols, true, measure);
      snprintf(line, sizeof(line),
               "owner=0x%" PRIxPTR " waiter=0x%" PRIxPTR " | value=%" PRIu64 " | last operation %.2fs ago%s%s",
               r->owner, r->waiter, r->value, r->last_ns ? (double)(now - r->last_ns) / NS_PER_SEC_INT : 0.0,
               r->cycle ? " " : "", r->cycle ? deadlock : "");
      sync_write_numbers(line, size.cols, measure);
    } else if (!measure) {
      snprintf(line, sizeof(line), "\033[%d;1H\033[K\033[%d;1H\033[K", size.rows - 2, size.rows - 1);
      sync_write(line, strlen(line));
    }
    snprintf(line, sizeof(line), "\033[%d;1H", size.rows);
    if (!measure)
      sync_write(line, strlen(line));
    snprintf(line, sizeof(line),
             "%s0%s/%sEsc%s close | %s?%s help | %sLeft%s/%sRight%s page | %sUp%s/%sDown%s select | "
             "%sHome%s/%sEnd%s first/last",
             sync_color(LOG_COLOR_FATAL), sync_color(LOG_COLOR_RESET), sync_color(LOG_COLOR_WARN),
             sync_color(LOG_COLOR_RESET), sync_color(LOG_COLOR_WARN), sync_color(LOG_COLOR_RESET),
             sync_color(LOG_COLOR_WARN), sync_color(LOG_COLOR_RESET), sync_color(LOG_COLOR_WARN),
             sync_color(LOG_COLOR_RESET), sync_color(LOG_COLOR_WARN), sync_color(LOG_COLOR_RESET),
             sync_color(LOG_COLOR_WARN), sync_color(LOG_COLOR_RESET), sync_color(LOG_COLOR_WARN),
             sync_color(LOG_COLOR_RESET), sync_color(LOG_COLOR_WARN), sync_color(LOG_COLOR_RESET));
    sync_write_line(line, size.cols, false, measure);
    if (measure) {
      terminal_size_t minimum = {.cols = measured_width + 1, .rows = fixed_rows + 1};
      if (ui_too_small(size, minimum)) {
        char output[TUI_SYNC_OUTPUT_SHORT_BUFFER_SIZE];
        size_t length = ui_too_small_format(output, sizeof(output), size, minimum);
        ui_controller_write(g_sync_fd, output, length);
        return;
      }
    }
  }
  sync_write("\033[?2026l", 8);
  sync_flush();
}

References sync_row_t::actions, ASCIICHAT_OK, ui_layout_t::body_rows, sync_sample_t::busy, cells, sync_row_t::change_rate, color_mode, COLOR_SETTING_FALSE, colored_string_set_output_fd(), sync_sample_t::count, sync_row_t::cycle, sync_row_t::file, format_number_compact(), GET_OPTION, sync_row_t::key, sync_row_t::last_ns, sync_sample_t::limited, sync_row_t::line, sync_row_t::lock_rate, LOG_COLOR_DEV, LOG_COLOR_ERROR, LOG_COLOR_FATAL, LOG_COLOR_GREY, LOG_COLOR_RESET, LOG_COLOR_WARN, NS_PER_SEC_INT, options_terminal_settings, sync_row_t::owner, sync_sample_t::rows, sync_sample_t::sampled_ns, SYNC_ROW_CAPACITY, TIME_DURATION_BUFFER_SIZE, time_pretty(), TUI_SYNC_ACTIONS_BUFFER_SIZE, TUI_SYNC_CHANGES_BUFFER_SIZE, TUI_SYNC_COLORED_NAME_BUFFER_SIZE, TUI_SYNC_COLORED_WAIT_BUFFER_SIZE, TUI_SYNC_DEADLOCK_BUFFER_SIZE, TUI_SYNC_FULL_NAME_BUFFER_SIZE, TUI_SYNC_LABEL_BUFFER_SIZE, TUI_SYNC_LINE_SHORT_BUFFER_SIZE, TUI_SYNC_LOCKS_BUFFER_SIZE, TUI_SYNC_NAME_EXTENDED_BUFFER_SIZE, TUI_SYNC_NUMBERS_BUFFER_SIZE, TUI_SYNC_OUTPUT_SHORT_BUFFER_SIZE, TUI_SYNC_PADDED_ACTIONS_BUFFER_SIZE, TUI_SYNC_PADDED_STATE_BUFFER_SIZE, TUI_SYNC_PADDED_WAIT_BUFFER_SIZE, TUI_SYNC_PLAIN_ACTIONS_BUFFER_SIZE, TUI_SYNC_STATE_BUFFER_SIZE, TUI_SYNC_UNLOCKS_BUFFER_SIZE, sync_row_t::type, UI_ALIGN_LEFT, UI_ALIGN_RIGHT, ui_controller_write(), ui_layout_measure(), ui_sync_output_fd(), ui_table_row(), ui_too_small(), ui_too_small_format(), sync_row_t::unlock_rate, utf8_display_width(), utf8_display_width_n(), utf8_next_char_bytes(), sync_row_t::value, sync_row_t::wait_known, sync_row_t::wait_ns, sync_row_t::waiter, sync_row_t::waiters, sync_sample_t::waits_complete, and width.

ui_sync_start()

asciichat_error_t ui_sync_start

(

int

fd

)

Debug-only service. Collection and input never wait on application locks.

Definition at line 311 of file sync.c.

                                        {
  while (atomic_flag_test_and_set(&g_sync_starting))
    platform_sleep_ms(1);
  asciichat_error_t result = ASCIICHAT_OK;
  if (!g_sync_started && platform_isatty(fd) && platform_isatty(STDIN_FILENO)) {
    g_sync_fd = platform_dup(fd);
    if (g_sync_fd < 0) {
      result = SET_ERRNO_SYS(ERROR_FILE_OPERATION, "Cannot retain sync display terminal");
    } else if ((result = keyboard_init()) != ASCIICHAT_OK) {
      platform_close(g_sync_fd);
      g_sync_fd = -1;
    } else {
      atomic_store(&g_sync_stop, false);
      result = platform_thread_create(&g_sync_thread, "sync_collector", sync_collect_main, NULL);
      if (result == ASCIICHAT_OK) {
        g_sync_started = true;
      } else {
        keyboard_destroy();
        platform_close(g_sync_fd);
        g_sync_fd = -1;
        result = SET_ERRNO(ERROR_THREAD, "Cannot start sync collector");
      }
    }
  }
  atomic_flag_clear(&g_sync_starting);
  return result;
}

References ASCIICHAT_OK, ERROR_FILE_OPERATION, ERROR_THREAD, keyboard_destroy(), keyboard_init(), platform_dup(), platform_sleep_ms(), SET_ERRNO, and SET_ERRNO_SYS.

Referenced by ui_controller_start_terminal().

ui_sync_stop()

void ui_sync_stop

(

void

)

Definition at line 339 of file sync.c.

                        {
  if (!g_sync_started)
    return;
  atomic_store(&g_sync_stop, true);
  thread_join(&g_sync_thread, NULL);
  keyboard_destroy();
  platform_close(g_sync_fd);
  g_sync_fd = -1;
  for (int i = 0; i < 3; ++i) {
    UNTRACKED_FREE(g_sync_samples[i].rows);
    g_sync_samples[i].capacity = g_sync_samples[i].count = 0;
  }
  atomic_store(&g_sync_published, -1);
  if (ui_sync_is_visible())
    ui_controller_select_interactive(-1);
  g_sync_started = false;
}

References keyboard_destroy(), ui_controller_select_interactive(), ui_sync_is_visible(), and UNTRACKED_FREE.

Referenced by ui_controller_shutdown().