mirror of
https://codeberg.org/dnkl/foot.git
synced 2026-02-05 04:06:08 -05:00
Add fdm_signal_add() and fdm_signal_del(). Signals added to the fdm will be monitored, and the provided callback called as “soon as possible” from the main context (i.e not from the signal handler context). Monitored signals are *blocked* by default. We use epoll_pwait() to unblock them while we’re polling. This allows us to do race-free signal detection. We use a single handler for all monitored signals; the handler simply updates the signal’s slot in a global array (sized to fit SIGRTMAX signals). When epoll_pwait() returns EINTR, we loop the global array. The callback associated with each signal that fired is called.
313 lines
7.1 KiB
C
313 lines
7.1 KiB
C
#include <stdlib.h>
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <unistd.h>
|
|
#include <errno.h>
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#include <sys/epoll.h>
|
|
#include <sys/timerfd.h>
|
|
#include <sys/mman.h>
|
|
#include <fcntl.h>
|
|
|
|
#include "async.h"
|
|
#include "config.h"
|
|
#include "reaper.h"
|
|
#include "sixel.h"
|
|
#include "user-notification.h"
|
|
#include "vt.h"
|
|
|
|
extern bool fdm_ptmx(struct fdm *fdm, int fd, int events, void *data);
|
|
|
|
static void
|
|
usage(const char *prog_name)
|
|
{
|
|
printf(
|
|
"Usage: %s stimuli-file1 stimuli-file2 ... stimuli-fileN\n",
|
|
prog_name);
|
|
}
|
|
|
|
enum async_write_status
|
|
async_write(int fd, const void *data, size_t len, size_t *idx)
|
|
{
|
|
return ASYNC_WRITE_DONE;
|
|
}
|
|
|
|
bool
|
|
fdm_add(struct fdm *fdm, int fd, int events, fdm_fd_handler_t handler, void *data)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
bool
|
|
fdm_del(struct fdm *fdm, int fd)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
bool
|
|
fdm_event_add(struct fdm *fdm, int fd, int events)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
bool
|
|
fdm_event_del(struct fdm *fdm, int fd, int events)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
bool
|
|
render_resize_force(struct terminal *term, int width, int height)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
void render_refresh(struct terminal *term) {}
|
|
void render_refresh_csd(struct terminal *term) {}
|
|
void render_refresh_title(struct terminal *term) {}
|
|
|
|
bool
|
|
render_xcursor_set(struct seat *seat, struct terminal *term, const char *xcursor)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
struct wl_window *
|
|
wayl_win_init(struct terminal *term)
|
|
{
|
|
return NULL;
|
|
}
|
|
|
|
void wayl_win_destroy(struct wl_window *win) {}
|
|
|
|
bool
|
|
spawn(struct reaper *reaper, const char *cwd, char *const argv[],
|
|
int stdin_fd, int stdout_fd, int stderr_fd)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
pid_t
|
|
slave_spawn(
|
|
int ptmx, int argc, const char *cwd, char *const *argv, const char *term_env,
|
|
const char *conf_shell, bool login_shell,
|
|
const user_notifications_t *notifications)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
int
|
|
render_worker_thread(void *_ctx)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
struct extraction_context *
|
|
extract_begin(enum selection_kind kind)
|
|
{
|
|
return NULL;
|
|
}
|
|
|
|
bool
|
|
extract_one(
|
|
const struct terminal *term, const struct row *row, const struct cell *cell,
|
|
int col, void *context)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
bool
|
|
extract_finish(struct extraction_context *context, char **text, size_t *len)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
void cmd_scrollback_up(struct terminal *term, int rows) {}
|
|
void cmd_scrollback_down(struct terminal *term, int rows) {}
|
|
|
|
void ime_enable(struct seat *seat) {}
|
|
void ime_disable(struct seat *seat) {}
|
|
|
|
void
|
|
notify_notify(const struct terminal *term, const char *title, const char *body)
|
|
{
|
|
}
|
|
|
|
void reaper_add(struct reaper *reaper, pid_t pid, reaper_cb cb, void *cb_data) {}
|
|
void reaper_del(struct reaper *reaper, pid_t pid) {}
|
|
|
|
|
|
int
|
|
main(int argc, const char *const *argv)
|
|
{
|
|
if (argc < 2) {
|
|
usage(argv[0]);
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
const int row_count = 67;
|
|
const int col_count = 135;
|
|
const int grid_row_count = 16384;
|
|
|
|
int lower_fd = timerfd_create(CLOCK_MONOTONIC, TFD_CLOEXEC | TFD_NONBLOCK);
|
|
if (lower_fd < 0)
|
|
return EXIT_FAILURE;
|
|
|
|
int upper_fd = timerfd_create(CLOCK_MONOTONIC, TFD_CLOEXEC | TFD_NONBLOCK);
|
|
if (upper_fd < 0) {
|
|
close(lower_fd);
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
struct row **rows = calloc(grid_row_count, sizeof(rows[0]));
|
|
for (int i = 0; i < grid_row_count; i++) {
|
|
rows[i] = calloc(1, sizeof(*rows[i]));
|
|
rows[i]->cells = calloc(col_count, sizeof(rows[i]->cells[0]));
|
|
}
|
|
|
|
struct config conf = {
|
|
.tweak = {
|
|
.delayed_render_lower_ns = 500000, /* 0.5ms */
|
|
.delayed_render_upper_ns = 16666666 / 2, /* half a frame period (60Hz) */
|
|
},
|
|
};
|
|
|
|
struct wayland wayl = {
|
|
.seats = tll_init(),
|
|
.monitors = tll_init(),
|
|
.terms = tll_init(),
|
|
};
|
|
|
|
struct terminal term = {
|
|
.conf = &conf,
|
|
.wl = &wayl,
|
|
.grid = &term.normal,
|
|
.normal = {
|
|
.num_rows = grid_row_count,
|
|
.num_cols = col_count,
|
|
.rows = rows,
|
|
.cur_row = rows[0],
|
|
},
|
|
.alt = {
|
|
.num_rows = grid_row_count,
|
|
.num_cols = col_count,
|
|
.rows = rows,
|
|
.cur_row = rows[0],
|
|
},
|
|
.scale = 1,
|
|
.width = col_count * 8,
|
|
.height = row_count * 15,
|
|
.cols = col_count,
|
|
.rows = row_count,
|
|
.cell_width = 8,
|
|
.cell_height = 15,
|
|
.scroll_region = {
|
|
.start = 0,
|
|
.end = row_count,
|
|
},
|
|
.selection = {
|
|
.start = {-1, -1},
|
|
.end = {-1, -1},
|
|
},
|
|
.delayed_render_timer = {
|
|
.lower_fd = lower_fd,
|
|
.upper_fd = upper_fd
|
|
},
|
|
.sixel = {
|
|
.palette_size = SIXEL_MAX_COLORS,
|
|
.max_width = SIXEL_MAX_WIDTH,
|
|
.max_height = SIXEL_MAX_HEIGHT,
|
|
},
|
|
};
|
|
|
|
tll_push_back(wayl.terms, &term);
|
|
|
|
int ret = EXIT_FAILURE;
|
|
|
|
for (int i = 1; i < argc; i++) {
|
|
struct stat st;
|
|
if (stat(argv[i], &st) < 0) {
|
|
fprintf(stderr, "error: %s: failed to stat: %s\n",
|
|
argv[i], strerror(errno));
|
|
goto out;
|
|
}
|
|
|
|
uint8_t *data = malloc(st.st_size);
|
|
if (data == NULL) {
|
|
fprintf(stderr, "error: %s: failed to allocate buffer: %s\n",
|
|
argv[i], strerror(errno));
|
|
goto out;
|
|
}
|
|
|
|
int fd = open(argv[1], O_RDONLY);
|
|
if (fd < 0) {
|
|
fprintf(stderr, "error: %s: failed to open: %s\n",
|
|
argv[i], strerror(errno));
|
|
goto out;
|
|
}
|
|
|
|
ssize_t amount = read(fd, data, st.st_size);
|
|
if (amount != st.st_size) {
|
|
fprintf(stderr, "error: %s: failed to read: %s\n",
|
|
argv[i], strerror(errno));
|
|
goto out;
|
|
}
|
|
|
|
close(fd);
|
|
|
|
#if defined(MEMFD_CREATE)
|
|
int mem_fd = memfd_create("foot-pgo-ptmx", MFD_CLOEXEC);
|
|
#elif defined(__FreeBSD__)
|
|
// memfd_create on FreeBSD 13 is SHM_ANON without sealing support
|
|
int mem_fd = shm_open(SHM_ANON, O_RDWR | O_CLOEXEC, 0600);
|
|
#else
|
|
char name[] = "/tmp/foot-pgo-ptmx-XXXXXX";
|
|
int mem_fd = mkostemp(name, O_CLOEXEC);
|
|
unlink(name);
|
|
#endif
|
|
if (mem_fd < 0) {
|
|
fprintf(stderr, "error: failed to create memory FD\n");
|
|
goto out;
|
|
}
|
|
|
|
if (write(mem_fd, data, st.st_size) < 0) {
|
|
fprintf(stderr, "error: failed to write memory FD\n");
|
|
close(mem_fd);
|
|
goto out;
|
|
}
|
|
|
|
free(data);
|
|
|
|
term.ptmx = mem_fd;
|
|
lseek(mem_fd, 0, SEEK_SET);
|
|
|
|
printf("Feeding VT parser with %s (%lld bytes)\n",
|
|
argv[i], (long long)st.st_size);
|
|
|
|
while (lseek(mem_fd, 0, SEEK_CUR) < st.st_size) {
|
|
if (!fdm_ptmx(NULL, -1, EPOLLIN, &term)) {
|
|
fprintf(stderr, "error: fdm_ptmx() failed\n");
|
|
close(mem_fd);
|
|
goto out;
|
|
}
|
|
}
|
|
close(mem_fd);
|
|
}
|
|
|
|
ret = EXIT_SUCCESS;
|
|
|
|
out:
|
|
tll_free(wayl.terms);
|
|
|
|
for (int i = 0; i < grid_row_count; i++) {
|
|
free(rows[i]->cells);
|
|
free(rows[i]);
|
|
}
|
|
|
|
free(rows);
|
|
close(lower_fd);
|
|
close(upper_fd);
|
|
return ret;
|
|
}
|