abstraction.c

Go to the documentation of this file.

 
#include <errno.h>
#include <ascii-chat/platform/terminal.h>
#include <ascii-chat/platform/abstraction.h>
#include <ascii-chat/options/options.h>
#include <ascii-chat/common.h>
 
// ============================================================================
// Common Platform Functions
// ============================================================================
// This file is reserved for common platform functions that don't need
// OS-specific implementations. Currently all functions are OS-specific.
//
// The OS-specific implementations are in:
// - platform_windows.c (Windows)
// - platform_posix.c (POSIX/Unix/Linux/macOS)
//
// Socket-specific implementations are in:
// - platform/socket.c (Common socket utilities like socket_optimize_for_streaming)
// ============================================================================
 
size_t platform_write_all(int fd, const void *buf, size_t count) {
  if (!buf || count == 0) {
    return 0;
  }
 
  size_t written_total = 0;
  int attempts = 0;
  const int MAX_ATTEMPTS = 1000;
 
  while (written_total < count && attempts < MAX_ATTEMPTS) {
    ssize_t result = platform_write(fd, (const char *)buf + written_total, count - written_total);
 
    if (result > 0) {
      written_total += (size_t)result;
      attempts = 0; // Reset attempt counter on successful write
    } else if (result < 0) {
      // Handle EAGAIN (non-blocking would-block) with sleep instead of tight loop
      if (errno == EAGAIN || errno == EWOULDBLOCK) {
        // Sleep 100us before retrying to avoid busy-waiting and spinning CPU
        platform_sleep_us(100);
      } else {
        // Other write errors - log and retry
        log_warn("platform_write_all: write() error on fd=%d (wrote %zu/%zu so far, errno=%d)", fd, written_total,
                 count, errno);
      }
      attempts++;
    } else {
      // result == 0: no bytes written, retry
      attempts++;
    }
  }
 
  if (attempts >= MAX_ATTEMPTS && written_total < count) {
    log_warn("platform_write_all: Hit retry limit on fd=%d: wrote %zu of %zu bytes", fd, written_total, count);
  }
 
  return written_total;
}
 
bool terminal_should_use_control_sequences(int fd) {
  if (fd < 0) {
    return false;
  }
  if (GET_OPTION(snapshot_mode)) {
    return false;
  }
  const char *testing_env = SAFE_GETENV("TESTING");
  if (testing_env != NULL) {
    return false;
  }
  return platform_isatty(fd) != 0;
}