chroma

public

Lightweight wallpaper daemon for Wayland

clone

ssh://git@git.notashelf.dev:33/notashelf/chroma.git

#include <errno.h>
#include <stdarg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/time.h>
#include <time.h>
#include <unistd.h>

#include "../include/chroma.h"

// Global logging level (using CHROMA_LOG_* constants)
static int log_level = CHROMA_LOG_WARN; // Default to WARN and ERROR only

// Initialize chroma state
int chroma_init(chroma_state_t *state) {
  if (!state) {
    return CHROMA_ERROR_INIT;
  }

  // Initialize all fields to zero
  memset(state, 0, sizeof(chroma_state_t));

  // Set initial state
  state->running = false;
  state->initialized = false;
  state->egl_display = EGL_NO_DISPLAY;
  state->egl_context = EGL_NO_CONTEXT;

  // Initialize stb_image
  chroma_image_init_stb();

  state->initialized = true;
  chroma_log("INFO", "Chroma state initialized");
  chroma_log_resource_allocation("chroma_state", sizeof(chroma_state_t),
                                 "main application state");

  return CHROMA_OK;
}

// Cleanup chroma state
void chroma_cleanup(chroma_state_t *state) {
  if (!state || !state->initialized) {
    return;
  }

  chroma_log("INFO", "Cleaning up chroma state");
  chroma_log_memory_stats("pre-cleanup");

  // Stop the main loop
  state->running = false;

  // Clean up all images
  chroma_images_cleanup(state);

  // Clean up EGL
  chroma_egl_cleanup(state);

  // Clean up Wayland
  chroma_wayland_disconnect(state);

  // Clean up configuration
  chroma_config_free(&state->config);

  state->initialized = false;
  chroma_log_resource_deallocation("chroma_state", sizeof(chroma_state_t),
                                   "main application state");
  chroma_log("INFO", "Chroma cleanup complete");
}

// Assign wallpaper to an output
static int assign_wallpaper_to_output(chroma_state_t *state,
                                      chroma_output_t *output) {
  if (!state || !output || !output->active) {
    return CHROMA_ERROR_INIT;
  }

  // Get image path for this output
  const char *image_path = chroma_config_get_image_for_output(
      &state->config, output->name ? output->name : "unknown");
  if (!image_path) {
    chroma_log("WARN", "No wallpaper configured for output %u (%s)", output->id,
               output->name ? output->name : "unknown");
    return CHROMA_ERROR_CONFIG;
  }

  // Load or get cached image
  chroma_image_t *image = chroma_image_get_or_load(state, image_path);
  if (!image) {
    chroma_log("ERROR", "Failed to load image for output %u: %s", output->id,
               image_path);
    return CHROMA_ERROR_IMAGE;
  }

  // Check if image changed and invalidate texture cache if neceessary
  bool image_changed = (output->image != image);
  if (image_changed && output->image) {
    chroma_output_invalidate_texture(output);
    chroma_log("DEBUG", "Image changed for output %u, invalidated texture",
               output->id);
  }

  // Assign image to output
  output->image = image;

  // Store old configuration values for comparison
  chroma_scale_mode_t old_scale_mode = output->scale_mode;
  chroma_filter_quality_t old_filter_quality = output->filter_quality;
  bool had_config = output->config_loaded;

  // Load configuration for this output (scale mode and filter quality)
  if (chroma_config_get_mapping_for_output(
          &state->config, output->name ? output->name : "unknown",
          &output->scale_mode, &output->filter_quality) == CHROMA_OK) {
    output->config_loaded = true;
    chroma_log("DEBUG", "Loaded config for output %u: scale=%d, filter=%d",
               output->id, output->scale_mode, output->filter_quality);

    // Check if configuration changed and invalidate texture if needed
    if (had_config && (old_scale_mode != output->scale_mode ||
                       old_filter_quality != output->filter_quality)) {
      chroma_output_invalidate_texture(output);
      chroma_log("DEBUG",
                 "Configuration changed for output %u, invalidated texture",
                 output->id);
    }
  } else {
    output->config_loaded = false;
    chroma_log("WARN", "Failed to load config for output %u", output->id);
  }

  // Create surface if it doesn't exist
  if (!output->surface) {
    int ret = chroma_surface_create(state, output);
    if (ret != CHROMA_OK) {
      chroma_log("ERROR", "Failed to create surface for output %u", output->id);
      return ret;
    }
  }

  // Render wallpaper
  int ret = chroma_render_wallpaper(state, output);
  if (ret != CHROMA_OK) {
    chroma_log("ERROR", "Failed to render wallpaper for output %u", output->id);
    return ret;
  }

  chroma_log("INFO", "Assigned wallpaper to output %u (%s): %s", output->id,
             output->name ? output->name : "unknown", image_path);
  chroma_log_memory_stats("post-wallpaper-assignment");

  return CHROMA_OK;
}

// Assign wallpapers to all active outputs
static int assign_wallpapers_to_all_outputs(chroma_state_t *state) {
  if (!state) {
    return CHROMA_ERROR_INIT;
  }

  int success_count = 0;
  int error_count = 0;

  for (int i = 0; i < state->output_count; i++) {
    chroma_output_t *output = &state->outputs[i];

    if (!output->active) {
      chroma_log("DEBUG", "Skipping inactive output %u", output->id);
      continue;
    }

    if (assign_wallpaper_to_output(state, output) == CHROMA_OK) {
      success_count++;
    } else {
      error_count++;
    }
  }

  chroma_log("INFO", "Wallpaper assignment complete: %d success, %d errors",
             success_count, error_count);

  return (success_count > 0) ? CHROMA_OK : CHROMA_ERROR_IMAGE;
}

// Handle output configuration complete event
void handle_output_done(chroma_state_t *state, chroma_output_t *output) {
  if (!state || !output) {
    return;
  }

  chroma_log("INFO",
             "Output %u (%s) configuration complete: %dx%d@%d, scale=%d",
             output->id, output->name ? output->name : "unknown", output->width,
             output->height, 0, output->scale);

  /* Assign wallpaper to this output */
  if (assign_wallpaper_to_output(state, output) != CHROMA_OK) {
    chroma_log("ERROR", "Failed to assign wallpaper to output %u", output->id);
  }
}

// Process Wayland events
static int process_wayland_events(chroma_state_t *state) {
  if (!state || !state->display) {
    return CHROMA_ERROR_WAYLAND;
  }

  // Dispatch pending events
  if (wl_display_dispatch_pending(state->display) == -1) {
    chroma_log("ERROR", "Failed to dispatch pending Wayland events: %s",
               strerror(errno));
    return CHROMA_ERROR_WAYLAND;
  }

  // Read events from the server
  if (wl_display_read_events(state->display) == -1) {
    chroma_log("ERROR", "Failed to read Wayland events: %s", strerror(errno));
    return CHROMA_ERROR_WAYLAND;
  }

  // Dispatch the read events
  if (wl_display_dispatch_pending(state->display) == -1) {
    chroma_log("ERROR", "Failed to dispatch read Wayland events: %s",
               strerror(errno));
    return CHROMA_ERROR_WAYLAND;
  }

  return CHROMA_OK;
}

// Main event loop
int chroma_run(chroma_state_t *state) {
  if (!state || !state->initialized) {
    return CHROMA_ERROR_INIT;
  }

  chroma_log("INFO", "Starting main event loop");
  chroma_log_memory_stats("main-loop-start");
  state->running = true;

  // Initial wallpaper assignment
  chroma_log("INFO", "Performing initial wallpaper assignment");
  assign_wallpapers_to_all_outputs(state);

  // Main event loop
  while (state->running && !chroma_should_quit) {
    // Dispatch any pending events first
    if (wl_display_dispatch_pending(state->display) == -1) {
      chroma_log("ERROR", "Failed to dispatch pending events: %s",
                 strerror(errno));
      break;
    }

    // Prepare to read events
    if (wl_display_prepare_read(state->display) == -1) {
      chroma_log("ERROR", "Failed to prepare Wayland display for reading");
      break;
    }

    // Flush outgoing requests
    if (wl_display_flush(state->display) == -1) {
      chroma_log("ERROR", "Failed to flush Wayland display: %s",
                 strerror(errno));
      wl_display_cancel_read(state->display);
      break;
    }

    // Get the display file descriptor
    int fd = wl_display_get_fd(state->display);
    if (fd == -1) {
      chroma_log("ERROR", "Failed to get Wayland display file descriptor");
      wl_display_cancel_read(state->display);
      break;
    }

    // Use select() to wait for events with timeout
    fd_set readfds;
    struct timeval timeout;

    FD_ZERO(&readfds);
    FD_SET(fd, &readfds);

    timeout.tv_sec = 1; // 1s timeout
    timeout.tv_usec = 0;

    int select_result = select(fd + 1, &readfds, NULL, NULL, &timeout);

    if (select_result == -1) {
      if (errno == EINTR) {
        // Interrupted by signal, check if we should quit
        wl_display_cancel_read(state->display);
        continue;
      }
      chroma_log("ERROR", "select() failed: %s", strerror(errno));
      wl_display_cancel_read(state->display);
      break;
    }

    if (select_result == 0) {
      // Timeout - no events available
      wl_display_cancel_read(state->display);
      continue;
    }

    // Events are available
    if (FD_ISSET(fd, &readfds)) {
      if (process_wayland_events(state) != CHROMA_OK) {
        break;
      }
    } else {
      wl_display_cancel_read(state->display);
    }
  }

  state->running = false;
  chroma_log("INFO", "Main event loop ended");

  return CHROMA_OK;
}

// Error code to string conversion
const char *chroma_error_string(chroma_error_t error) {
  switch (error) {
  case CHROMA_OK:
    return "Success";
  case CHROMA_ERROR_INIT:
    return "Initialization error";
  case CHROMA_ERROR_WAYLAND:
    return "Wayland error";
  case CHROMA_ERROR_EGL:
    return "EGL error";
  case CHROMA_ERROR_IMAGE:
    return "Image loading error";
  case CHROMA_ERROR_CONFIG:
    return "Configuration error";
  case CHROMA_ERROR_MEMORY:
    return "Memory allocation error";
  default:
    return "Unknown error";
  }
}

// Convert log level string to numeric level
static int log_level_from_string(const char *level) {
  if (strcmp(level, "ERROR") == 0)
    return CHROMA_LOG_ERROR;
  if (strcmp(level, "WARN") == 0)
    return CHROMA_LOG_WARN;
  if (strcmp(level, "INFO") == 0)
    return CHROMA_LOG_INFO;
  if (strcmp(level, "DEBUG") == 0)
    return CHROMA_LOG_DEBUG;
  if (strcmp(level, "TRACE") == 0)
    return CHROMA_LOG_TRACE;
  return CHROMA_LOG_ERROR; // default to ERROR for unknown levels
}

// Logging function with level filtering
void chroma_log(const char *level, const char *format, ...) {
  int msg_level = log_level_from_string(level);
  if (msg_level > log_level) {
    return;
  }

  va_list args;
  char timestamp[32];
  struct timeval tv;
  struct tm *tm_info;

  gettimeofday(&tv, NULL);
  tm_info = localtime(&tv.tv_sec);

  snprintf(timestamp, sizeof(timestamp), "%04d-%02d-%02d %02d:%02d:%02d.%03d",
           tm_info->tm_year + 1900, tm_info->tm_mon + 1, tm_info->tm_mday,
           tm_info->tm_hour, tm_info->tm_min, tm_info->tm_sec,
           (int)(tv.tv_usec / 1000));

  printf("[%s] %s: ", timestamp, level);

  va_start(args, format);
  vprintf(format, args);
  va_end(args);

  printf("\n");
  fflush(stdout);
}

// Set log level
void chroma_set_log_level(int level) { log_level = level; }

// Get log level
int chroma_get_log_level(void) { return log_level; }

// Handle configuration reload (SIGHUP)
int chroma_reload_config(chroma_state_t *state, const char *config_file) {
  if (!state) {
    return CHROMA_ERROR_INIT;
  }

  chroma_log("INFO", "Reloading configuration");

  // Free current configuration
  chroma_config_free(&state->config);

  // Load new configuration
  int ret = chroma_config_load(&state->config, config_file);
  if (ret != CHROMA_OK) {
    chroma_log("ERROR", "Failed to reload configuration: %s",
               chroma_error_string(ret));
    return ret;
  }

  // Reassign wallpapers with new configuration
  ret = assign_wallpapers_to_all_outputs(state);
  if (ret != CHROMA_OK) {
    chroma_log("ERROR", "Failed to reassign wallpapers after config reload");
    return ret;
  }

  chroma_log("INFO", "Configuration reloaded successfully");
  return CHROMA_OK;
}

// Check if an output needs wallpaper update
static bool output_needs_update(chroma_output_t *output) {
  if (!output || !output->active) {
    return false;
  }

  // Check if output has no surface or image assigned
  if (!output->surface || !output->image) {
    return true;
  }

  // Check if image is no longer loaded
  if (!output->image->loaded) {
    return true;
  }

  return false;
}

// Update outputs that need wallpaper refresh
int chroma_update_outputs(chroma_state_t *state) {
  if (!state) {
    return CHROMA_ERROR_INIT;
  }

  int updated_count = 0;

  for (int i = 0; i < state->output_count; i++) {
    chroma_output_t *output = &state->outputs[i];

    if (output_needs_update(output)) {
      if (assign_wallpaper_to_output(state, output) == CHROMA_OK) {
        updated_count++;
      }
    }
  }

  if (updated_count > 0) {
    chroma_log("INFO", "Updated wallpapers for %d outputs", updated_count);
  }

  return CHROMA_OK;
}

// Get statistics
void chroma_get_stats(chroma_state_t *state, int *active_outputs,
                      int *loaded_images) {
  if (!state) {
    if (active_outputs)
      *active_outputs = 0;
    if (loaded_images)
      *loaded_images = 0;
    return;
  }

  int active = 0;
  for (int i = 0; i < state->output_count; i++) {
    if (state->outputs[i].active) {
      active++;
    }
  }

  int loaded = 0;
  for (int i = 0; i < state->image_count; i++) {
    if (state->images[i].loaded) {
      loaded++;
    }
  }

  if (active_outputs)
    *active_outputs = active;
  if (loaded_images)
    *loaded_images = loaded;
}

// Get current memory usage from /proc/self/status
// FIXME: some users may choose to confine /proc, we need a cleaner
// way of getting this data in the future
size_t chroma_get_memory_usage(void) {
  FILE *file = fopen("/proc/self/status", "r");
  if (!file) {
    return 0;
  }

  size_t vm_rss = 0;
  char line[256];

  while (fgets(line, sizeof(line), file)) {
    if (strncmp(line, "VmRSS:", 6) == 0) {
      // Parse VmRSS line: "VmRSS:    1234 kB"
      char *ptr = line + 6;
      while (*ptr == ' ' || *ptr == '\t')
        ptr++;                                        // Skip whitespace
      vm_rss = (size_t)strtoul(ptr, NULL, 10) * 1024; // Convert kB to bytes
      break;
    }
  }

  fclose(file);
  return vm_rss;
}

// Log memory statistics with context
void chroma_log_memory_stats(const char *context) {
  size_t memory_usage = chroma_get_memory_usage();
  char mem_str[64];

  chroma_format_memory_size(memory_usage, mem_str, sizeof(mem_str));
  chroma_log("INFO", "Memory usage [%s]: %s", context, mem_str);
}

// Log resource allocation
void chroma_log_resource_allocation(const char *resource_type, size_t size,
                                    const char *description) {
  if (size > 0) {
    char size_str[64];
    chroma_format_memory_size(size, size_str, sizeof(size_str));
    chroma_log("DEBUG", "Allocated %s: %s (%s)", resource_type, size_str,
               description);
  } else {
    chroma_log("DEBUG", "Allocated %s: %s", resource_type, description);
  }

  // Log memory stats after significant allocations (>1MB)
  if (size > 1024 * 1024) {
    chroma_log_memory_stats("post-allocation");
  }
}

// Log resource deallocation
void chroma_log_resource_deallocation(const char *resource_type, size_t size,
                                      const char *description) {
  if (size > 0) {
    char size_str[64];
    chroma_format_memory_size(size, size_str, sizeof(size_str));
    chroma_log("DEBUG", "Deallocated %s: %s (%s)", resource_type, size_str,
               description);
  } else {
    chroma_log("DEBUG", "Deallocated %s: %s", resource_type, description);
  }

  // Log memory stats after significant deallocations (>1MB)
  if (size > 1024 * 1024) {
    chroma_log_memory_stats("post-deallocation");
  }
}

1	#include <errno.h>
2	#include <stdarg.h>
3	#include <stdio.h>
4	#include <stdlib.h>
5	#include <string.h>
6	#include <sys/time.h>
7	#include <time.h>
8	#include <unistd.h>
9
10	#include "../include/chroma.h"
11
12	// Global logging level (using CHROMA_LOG_* constants)
13	static int log_level = CHROMA_LOG_WARN; // Default to WARN and ERROR only
14
15	// Initialize chroma state
16	int chroma_init(chroma_state_t *state) {
17	if (!state) {
18	return CHROMA_ERROR_INIT;
19	}
20
21	// Initialize all fields to zero
22	memset(state, 0, sizeof(chroma_state_t));
23
24	// Set initial state
25	state->running = false;
26	state->initialized = false;
27	state->egl_display = EGL_NO_DISPLAY;
28	state->egl_context = EGL_NO_CONTEXT;
29
30	// Initialize stb_image
31	chroma_image_init_stb();
32
33	state->initialized = true;
34	chroma_log("INFO", "Chroma state initialized");
35	chroma_log_resource_allocation("chroma_state", sizeof(chroma_state_t),
36	"main application state");
37
38	return CHROMA_OK;
39	}
40
41	// Cleanup chroma state
42	void chroma_cleanup(chroma_state_t *state) {
43	if (!state \|\| !state->initialized) {
44	return;
45	}
46
47	chroma_log("INFO", "Cleaning up chroma state");
48	chroma_log_memory_stats("pre-cleanup");
49
50	// Stop the main loop
51	state->running = false;
52
53	// Clean up all images
54	chroma_images_cleanup(state);
55
56	// Clean up EGL
57	chroma_egl_cleanup(state);
58
59	// Clean up Wayland
60	chroma_wayland_disconnect(state);
61
62	// Clean up configuration
63	chroma_config_free(&state->config);
64
65	state->initialized = false;
66	chroma_log_resource_deallocation("chroma_state", sizeof(chroma_state_t),
67	"main application state");
68	chroma_log("INFO", "Chroma cleanup complete");
69	}
70
71	// Assign wallpaper to an output
72	static int assign_wallpaper_to_output(chroma_state_t *state,
73	chroma_output_t *output) {
74	if (!state \|\| !output \|\| !output->active) {
75	return CHROMA_ERROR_INIT;
76	}
77
78	// Get image path for this output
79	const char *image_path = chroma_config_get_image_for_output(
80	&state->config, output->name ? output->name : "unknown");
81	if (!image_path) {
82	chroma_log("WARN", "No wallpaper configured for output %u (%s)", output->id,
83	output->name ? output->name : "unknown");
84	return CHROMA_ERROR_CONFIG;
85	}
86
87	// Load or get cached image
88	chroma_image_t *image = chroma_image_get_or_load(state, image_path);
89	if (!image) {
90	chroma_log("ERROR", "Failed to load image for output %u: %s", output->id,
91	image_path);
92	return CHROMA_ERROR_IMAGE;
93	}
94
95	// Check if image changed and invalidate texture cache if neceessary
96	bool image_changed = (output->image != image);
97	if (image_changed && output->image) {
98	chroma_output_invalidate_texture(output);
99	chroma_log("DEBUG", "Image changed for output %u, invalidated texture",
100	output->id);
101	}
102
103	// Assign image to output
104	output->image = image;
105
106	// Store old configuration values for comparison
107	chroma_scale_mode_t old_scale_mode = output->scale_mode;
108	chroma_filter_quality_t old_filter_quality = output->filter_quality;
109	bool had_config = output->config_loaded;
110
111	// Load configuration for this output (scale mode and filter quality)
112	if (chroma_config_get_mapping_for_output(
113	&state->config, output->name ? output->name : "unknown",
114	&output->scale_mode, &output->filter_quality) == CHROMA_OK) {
115	output->config_loaded = true;
116	chroma_log("DEBUG", "Loaded config for output %u: scale=%d, filter=%d",
117	output->id, output->scale_mode, output->filter_quality);
118
119	// Check if configuration changed and invalidate texture if needed
120	if (had_config && (old_scale_mode != output->scale_mode \|\|
121	old_filter_quality != output->filter_quality)) {
122	chroma_output_invalidate_texture(output);
123	chroma_log("DEBUG",
124	"Configuration changed for output %u, invalidated texture",
125	output->id);
126	}
127	} else {
128	output->config_loaded = false;
129	chroma_log("WARN", "Failed to load config for output %u", output->id);
130	}
131
132	// Create surface if it doesn't exist
133	if (!output->surface) {
134	int ret = chroma_surface_create(state, output);
135	if (ret != CHROMA_OK) {
136	chroma_log("ERROR", "Failed to create surface for output %u", output->id);
137	return ret;
138	}
139	}
140
141	// Render wallpaper
142	int ret = chroma_render_wallpaper(state, output);
143	if (ret != CHROMA_OK) {
144	chroma_log("ERROR", "Failed to render wallpaper for output %u", output->id);
145	return ret;
146	}
147
148	chroma_log("INFO", "Assigned wallpaper to output %u (%s): %s", output->id,
149	output->name ? output->name : "unknown", image_path);
150	chroma_log_memory_stats("post-wallpaper-assignment");
151
152	return CHROMA_OK;
153	}
154
155	// Assign wallpapers to all active outputs
156	static int assign_wallpapers_to_all_outputs(chroma_state_t *state) {
157	if (!state) {
158	return CHROMA_ERROR_INIT;
159	}
160
161	int success_count = 0;
162	int error_count = 0;
163
164	for (int i = 0; i < state->output_count; i++) {
165	chroma_output_t *output = &state->outputs[i];
166
167	if (!output->active) {
168	chroma_log("DEBUG", "Skipping inactive output %u", output->id);
169	continue;
170	}
171
172	if (assign_wallpaper_to_output(state, output) == CHROMA_OK) {
173	success_count++;
174	} else {
175	error_count++;
176	}
177	}
178
179	chroma_log("INFO", "Wallpaper assignment complete: %d success, %d errors",
180	success_count, error_count);
181
182	return (success_count > 0) ? CHROMA_OK : CHROMA_ERROR_IMAGE;
183	}
184
185	// Handle output configuration complete event
186	void handle_output_done(chroma_state_t state, chroma_output_t output) {
187	if (!state \|\| !output) {
188	return;
189	}
190
191	chroma_log("INFO",
192	"Output %u (%s) configuration complete: %dx%d@%d, scale=%d",
193	output->id, output->name ? output->name : "unknown", output->width,
194	output->height, 0, output->scale);
195
196	/* Assign wallpaper to this output */
197	if (assign_wallpaper_to_output(state, output) != CHROMA_OK) {
198	chroma_log("ERROR", "Failed to assign wallpaper to output %u", output->id);
199	}
200	}
201
202	// Process Wayland events
203	static int process_wayland_events(chroma_state_t *state) {
204	if (!state \|\| !state->display) {
205	return CHROMA_ERROR_WAYLAND;
206	}
207
208	// Dispatch pending events
209	if (wl_display_dispatch_pending(state->display) == -1) {
210	chroma_log("ERROR", "Failed to dispatch pending Wayland events: %s",
211	strerror(errno));
212	return CHROMA_ERROR_WAYLAND;
213	}
214
215	// Read events from the server
216	if (wl_display_read_events(state->display) == -1) {
217	chroma_log("ERROR", "Failed to read Wayland events: %s", strerror(errno));
218	return CHROMA_ERROR_WAYLAND;
219	}
220
221	// Dispatch the read events
222	if (wl_display_dispatch_pending(state->display) == -1) {
223	chroma_log("ERROR", "Failed to dispatch read Wayland events: %s",
224	strerror(errno));
225	return CHROMA_ERROR_WAYLAND;
226	}
227
228	return CHROMA_OK;
229	}
230
231	// Main event loop
232	int chroma_run(chroma_state_t *state) {
233	if (!state \|\| !state->initialized) {
234	return CHROMA_ERROR_INIT;
235	}
236
237	chroma_log("INFO", "Starting main event loop");
238	chroma_log_memory_stats("main-loop-start");
239	state->running = true;
240
241	// Initial wallpaper assignment
242	chroma_log("INFO", "Performing initial wallpaper assignment");
243	assign_wallpapers_to_all_outputs(state);
244
245	// Main event loop
246	while (state->running && !chroma_should_quit) {
247	// Dispatch any pending events first
248	if (wl_display_dispatch_pending(state->display) == -1) {
249	chroma_log("ERROR", "Failed to dispatch pending events: %s",
250	strerror(errno));
251	break;
252	}
253
254	// Prepare to read events
255	if (wl_display_prepare_read(state->display) == -1) {
256	chroma_log("ERROR", "Failed to prepare Wayland display for reading");
257	break;
258	}
259
260	// Flush outgoing requests
261	if (wl_display_flush(state->display) == -1) {
262	chroma_log("ERROR", "Failed to flush Wayland display: %s",
263	strerror(errno));
264	wl_display_cancel_read(state->display);
265	break;
266	}
267
268	// Get the display file descriptor
269	int fd = wl_display_get_fd(state->display);
270	if (fd == -1) {
271	chroma_log("ERROR", "Failed to get Wayland display file descriptor");
272	wl_display_cancel_read(state->display);
273	break;
274	}
275
276	// Use select() to wait for events with timeout
277	fd_set readfds;
278	struct timeval timeout;
279
280	FD_ZERO(&readfds);
281	FD_SET(fd, &readfds);
282
283	timeout.tv_sec = 1; // 1s timeout
284	timeout.tv_usec = 0;
285
286	int select_result = select(fd + 1, &readfds, NULL, NULL, &timeout);
287
288	if (select_result == -1) {
289	if (errno == EINTR) {
290	// Interrupted by signal, check if we should quit
291	wl_display_cancel_read(state->display);
292	continue;
293	}
294	chroma_log("ERROR", "select() failed: %s", strerror(errno));
295	wl_display_cancel_read(state->display);
296	break;
297	}
298
299	if (select_result == 0) {
300	// Timeout - no events available
301	wl_display_cancel_read(state->display);
302	continue;
303	}
304
305	// Events are available
306	if (FD_ISSET(fd, &readfds)) {
307	if (process_wayland_events(state) != CHROMA_OK) {
308	break;
309	}
310	} else {
311	wl_display_cancel_read(state->display);
312	}
313	}
314
315	state->running = false;
316	chroma_log("INFO", "Main event loop ended");
317
318	return CHROMA_OK;
319	}
320
321	// Error code to string conversion
322	const char *chroma_error_string(chroma_error_t error) {
323	switch (error) {
324	case CHROMA_OK:
325	return "Success";
326	case CHROMA_ERROR_INIT:
327	return "Initialization error";
328	case CHROMA_ERROR_WAYLAND:
329	return "Wayland error";
330	case CHROMA_ERROR_EGL:
331	return "EGL error";
332	case CHROMA_ERROR_IMAGE:
333	return "Image loading error";
334	case CHROMA_ERROR_CONFIG:
335	return "Configuration error";
336	case CHROMA_ERROR_MEMORY:
337	return "Memory allocation error";
338	default:
339	return "Unknown error";
340	}
341	}
342
343	// Convert log level string to numeric level
344	static int log_level_from_string(const char *level) {
345	if (strcmp(level, "ERROR") == 0)
346	return CHROMA_LOG_ERROR;
347	if (strcmp(level, "WARN") == 0)
348	return CHROMA_LOG_WARN;
349	if (strcmp(level, "INFO") == 0)
350	return CHROMA_LOG_INFO;
351	if (strcmp(level, "DEBUG") == 0)
352	return CHROMA_LOG_DEBUG;
353	if (strcmp(level, "TRACE") == 0)
354	return CHROMA_LOG_TRACE;
355	return CHROMA_LOG_ERROR; // default to ERROR for unknown levels
356	}
357
358	// Logging function with level filtering
359	void chroma_log(const char level, const char format, ...) {
360	int msg_level = log_level_from_string(level);
361	if (msg_level > log_level) {
362	return;
363	}
364
365	va_list args;
366	char timestamp[32];
367	struct timeval tv;
368	struct tm *tm_info;
369
370	gettimeofday(&tv, NULL);
371	tm_info = localtime(&tv.tv_sec);
372
373	snprintf(timestamp, sizeof(timestamp), "%04d-%02d-%02d %02d:%02d:%02d.%03d",
374	tm_info->tm_year + 1900, tm_info->tm_mon + 1, tm_info->tm_mday,
375	tm_info->tm_hour, tm_info->tm_min, tm_info->tm_sec,
376	(int)(tv.tv_usec / 1000));
377
378	printf("[%s] %s: ", timestamp, level);
379
380	va_start(args, format);
381	vprintf(format, args);
382	va_end(args);
383
384	printf("\n");
385	fflush(stdout);
386	}
387
388	// Set log level
389	void chroma_set_log_level(int level) { log_level = level; }
390
391	// Get log level
392	int chroma_get_log_level(void) { return log_level; }
393
394	// Handle configuration reload (SIGHUP)
395	int chroma_reload_config(chroma_state_t state, const char config_file) {
396	if (!state) {
397	return CHROMA_ERROR_INIT;
398	}
399
400	chroma_log("INFO", "Reloading configuration");
401
402	// Free current configuration
403	chroma_config_free(&state->config);
404
405	// Load new configuration
406	int ret = chroma_config_load(&state->config, config_file);
407	if (ret != CHROMA_OK) {
408	chroma_log("ERROR", "Failed to reload configuration: %s",
409	chroma_error_string(ret));
410	return ret;
411	}
412
413	// Reassign wallpapers with new configuration
414	ret = assign_wallpapers_to_all_outputs(state);
415	if (ret != CHROMA_OK) {
416	chroma_log("ERROR", "Failed to reassign wallpapers after config reload");
417	return ret;
418	}
419
420	chroma_log("INFO", "Configuration reloaded successfully");
421	return CHROMA_OK;
422	}
423
424	// Check if an output needs wallpaper update
425	static bool output_needs_update(chroma_output_t *output) {
426	if (!output \|\| !output->active) {
427	return false;
428	}
429
430	// Check if output has no surface or image assigned
431	if (!output->surface \|\| !output->image) {
432	return true;
433	}
434
435	// Check if image is no longer loaded
436	if (!output->image->loaded) {
437	return true;
438	}
439
440	return false;
441	}
442
443	// Update outputs that need wallpaper refresh
444	int chroma_update_outputs(chroma_state_t *state) {
445	if (!state) {
446	return CHROMA_ERROR_INIT;
447	}
448
449	int updated_count = 0;
450
451	for (int i = 0; i < state->output_count; i++) {
452	chroma_output_t *output = &state->outputs[i];
453
454	if (output_needs_update(output)) {
455	if (assign_wallpaper_to_output(state, output) == CHROMA_OK) {
456	updated_count++;
457	}
458	}
459	}
460
461	if (updated_count > 0) {
462	chroma_log("INFO", "Updated wallpapers for %d outputs", updated_count);
463	}
464
465	return CHROMA_OK;
466	}
467
468	// Get statistics
469	void chroma_get_stats(chroma_state_t state, int active_outputs,
470	int *loaded_images) {
471	if (!state) {
472	if (active_outputs)
473	*active_outputs = 0;
474	if (loaded_images)
475	*loaded_images = 0;
476	return;
477	}
478
479	int active = 0;
480	for (int i = 0; i < state->output_count; i++) {
481	if (state->outputs[i].active) {
482	active++;
483	}
484	}
485
486	int loaded = 0;
487	for (int i = 0; i < state->image_count; i++) {
488	if (state->images[i].loaded) {
489	loaded++;
490	}
491	}
492
493	if (active_outputs)
494	*active_outputs = active;
495	if (loaded_images)
496	*loaded_images = loaded;
497	}
498
499	// Get current memory usage from /proc/self/status
500	// FIXME: some users may choose to confine /proc, we need a cleaner
501	// way of getting this data in the future
502	size_t chroma_get_memory_usage(void) {
503	FILE *file = fopen("/proc/self/status", "r");
504	if (!file) {
505	return 0;
506	}
507
508	size_t vm_rss = 0;
509	char line[256];
510
511	while (fgets(line, sizeof(line), file)) {
512	if (strncmp(line, "VmRSS:", 6) == 0) {
513	// Parse VmRSS line: "VmRSS: 1234 kB"
514	char *ptr = line + 6;
515	while (ptr == ' ' \|\| ptr == '\t')
516	ptr++; // Skip whitespace
517	vm_rss = (size_t)strtoul(ptr, NULL, 10) * 1024; // Convert kB to bytes
518	break;
519	}
520	}
521
522	fclose(file);
523	return vm_rss;
524	}
525
526	// Log memory statistics with context
527	void chroma_log_memory_stats(const char *context) {
528	size_t memory_usage = chroma_get_memory_usage();
529	char mem_str[64];
530
531	chroma_format_memory_size(memory_usage, mem_str, sizeof(mem_str));
532	chroma_log("INFO", "Memory usage [%s]: %s", context, mem_str);
533	}
534
535	// Log resource allocation
536	void chroma_log_resource_allocation(const char *resource_type, size_t size,
537	const char *description) {
538	if (size > 0) {
539	char size_str[64];
540	chroma_format_memory_size(size, size_str, sizeof(size_str));
541	chroma_log("DEBUG", "Allocated %s: %s (%s)", resource_type, size_str,
542	description);
543	} else {
544	chroma_log("DEBUG", "Allocated %s: %s", resource_type, description);
545	}
546
547	// Log memory stats after significant allocations (>1MB)
548	if (size > 1024 * 1024) {
549	chroma_log_memory_stats("post-allocation");
550	}
551	}
552
553	// Log resource deallocation
554	void chroma_log_resource_deallocation(const char *resource_type, size_t size,
555	const char *description) {
556	if (size > 0) {
557	char size_str[64];
558	chroma_format_memory_size(size, size_str, sizeof(size_str));
559	chroma_log("DEBUG", "Deallocated %s: %s (%s)", resource_type, size_str,
560	description);
561	} else {
562	chroma_log("DEBUG", "Deallocated %s: %s", resource_type, description);
563	}
564
565	// Log memory stats after significant deallocations (>1MB)
566	if (size > 1024 * 1024) {
567	chroma_log_memory_stats("post-deallocation");
568	}
569	}