summaryrefslogtreecommitdiff
path: root/libs/cairo-1.16.0/util/cairo-sphinx/sphinx.c
diff options
context:
space:
mode:
Diffstat (limited to 'libs/cairo-1.16.0/util/cairo-sphinx/sphinx.c')
-rw-r--r--libs/cairo-1.16.0/util/cairo-sphinx/sphinx.c1545
1 files changed, 0 insertions, 1545 deletions
diff --git a/libs/cairo-1.16.0/util/cairo-sphinx/sphinx.c b/libs/cairo-1.16.0/util/cairo-sphinx/sphinx.c
deleted file mode 100644
index 238d400..0000000
--- a/libs/cairo-1.16.0/util/cairo-sphinx/sphinx.c
+++ /dev/null
@@ -1,1545 +0,0 @@
-/*
- * The intention for sphinx is for detection of rendering errors inside
- * applications by simultaneously rendering on to the target device and on
- * an image surface and comparing the two. If it found a discrepancy, it
- * would then dump the trace that reproduces the error. (Then apply
- * delta-debugging to reduce that down to a minimal trace.)
- */
-
-#ifdef HAVE_CONFIG_H
-#include "config.h"
-#endif
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <sys/stat.h>
-#include <sys/mman.h>
-#include <sys/socket.h>
-#include <sys/poll.h>
-#include <sys/un.h>
-#include <unistd.h>
-#include <fcntl.h>
-#include <signal.h>
-#include <errno.h>
-#include <assert.h>
-#include <pthread.h>
-
-#include <cairo.h>
-#include <cairo-script.h>
-#include <cairo-script-interpreter.h>
-#include <cairo-boilerplate.h>
-
-#include <glib.h> /* for checksumming */
-
-#ifndef CAIRO_HAS_REAL_PTHREAD
-# error "cairo-sphinx needs real pthreads"
-#endif
-
-#ifndef MAP_NORESERVE
-#define MAP_NORESERVE 0
-#endif
-
-#define DATA_SIZE (256 << 20)
-#define SHM_PATH_XXX "/shmem-cairo-sphinx"
-
-struct client {
- int sk;
- const cairo_boilerplate_target_t *target;
- cairo_surface_t *surface;
- void *base;
-
- cairo_script_interpreter_t *csi;
- struct context_closure {
- struct context_closure *next;
- unsigned long id;
- cairo_t *context;
- cairo_surface_t *surface;
- cairo_surface_t *original;
- } *contexts;
-
- unsigned long context_id;
-};
-
-struct surface_tag {
- long width, height;
-};
-static const cairo_user_data_key_t surface_tag;
-
-static int
-client_socket (const char *socket_path);
-
-static int
-writen (int fd, const void *ptr, int len)
-{
-#if 1
- const uint8_t *data = ptr;
- while (len) {
- int ret = write (fd, data, len);
- if (ret < 0) {
- switch (errno) {
- case EAGAIN:
- case EINTR:
- continue;
- default:
- return FALSE;
- }
- } else if (ret == 0) {
- return FALSE;
- } else {
- data += ret;
- len -= ret;
- }
- }
- return TRUE;
-#else
- int ret = send (fd, ptr, len, 0);
- return ret == len;
-#endif
-}
-
-static int
-readn (int fd, void *ptr, int len)
-{
-#if 0
- uint8_t *data = ptr;
- while (len) {
- int ret = read (fd, data, len);
- if (ret < 0) {
- switch (errno) {
- case EAGAIN:
- case EINTR:
- continue;
- default:
- return FALSE;
- }
- } else if (ret == 0) {
- return FALSE;
- } else {
- data += ret;
- len -= ret;
- }
- }
- return TRUE;
-#else
- int ret = recv (fd, ptr, len, MSG_WAITALL);
- return ret == len;
-#endif
-}
-static int
-open_devnull_to_fd (int want_fd, int flags)
-{
- int error;
- int got_fd;
-
- close (want_fd);
-
- got_fd = open("/dev/null", flags | O_CREAT, 0700);
- if (got_fd == -1)
- return -1;
-
- error = dup2 (got_fd, want_fd);
- close (got_fd);
-
- return error;
-}
-
-static int
-daemonize (void)
-{
- void (*oldhup) (int);
-
- /* Let the parent go. */
- switch (fork ()) {
- case -1: return -1;
- case 0: break;
- default: _exit (0);
- }
-
- /* Become session leader. */
- if (setsid () == -1)
- return -1;
-
- /* Refork to yield session leadership. */
- oldhup = signal (SIGHUP, SIG_IGN);
- switch (fork ()) {
- case -1: return -1;
- case 0: break;
- default: _exit (0);
- }
- signal (SIGHUP, oldhup);
-
- /* Establish stdio. */
- if (open_devnull_to_fd (0, O_RDONLY) == -1)
- return -1;
- if (open_devnull_to_fd (1, O_WRONLY | O_APPEND) == -1)
- return -1;
- if (dup2 (1, 2) == -1)
- return -1;
-
- return 0;
-}
-
-static int
-server_socket (const char *socket_path)
-{
- long flags;
- struct sockaddr_un addr;
- int sk;
-
- unlink (socket_path);
-
- sk = socket (PF_UNIX, SOCK_STREAM, 0);
- if (sk == -1)
- return -1;
-
- memset (&addr, 0, sizeof (addr));
- addr.sun_family = AF_UNIX;
- strcpy (addr.sun_path, socket_path);
- if (bind (sk, (struct sockaddr *) &addr, sizeof (addr)) == -1) {
- close (sk);
- return -1;
- }
-
- flags = fcntl (sk, F_GETFL);
- if (flags == -1 || fcntl (sk, F_SETFL, flags | O_NONBLOCK) == -1) {
- close (sk);
- return -1;
- }
-
- if (listen (sk, 5) == -1) {
- close (sk);
- return -1;
- }
-
- return sk;
-}
-
-static int
-readline (int fd, char *line, int max)
-{
- int len = 0;
- do {
- int ret = read (fd, &line[len], 1);
- if (ret <= 0)
- return -1;
- } while (line[len] != '\n' && ++len < max);
- line[len] = '\0';
- return len;
-}
-
-struct clients {
- int count, size;
- int complete;
-
- cairo_surface_t *recording;
- unsigned long serial;
-
- struct client_info {
- int sk;
- int trace;
- unsigned long image_serial;
- cairo_surface_t *image;
- char *name;
- char *target;
- char *reference;
-
- uint8_t *out_buf;
- int out_len;
- int out_size;
- } *clients;
- const char *shm_path;
- unsigned long offset;
- uint8_t *base;
-};
-
-static void *
-clients_shm (const char *shm_path)
-{
- void *base;
- int fd;
-
- shm_unlink (shm_path);
- fd = shm_open (shm_path, O_RDWR | O_EXCL | O_CREAT, 0777);
- if (fd == -1)
- return MAP_FAILED;
-
- if (ftruncate (fd, DATA_SIZE) == -1) {
- close (fd);
- return MAP_FAILED;
- }
-
- base = mmap (NULL, DATA_SIZE, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
- close (fd);
-
- return base;
-}
-
-static int
-clients_init (struct clients *clients)
-{
- clients->count = 0;
- clients->complete = 0;
- clients->size = 4;
- clients->clients = xmalloc (clients->size * sizeof (struct client_info));
-
- clients->shm_path = SHM_PATH_XXX;
- clients->base = clients_shm (clients->shm_path);
- if (clients->base == MAP_FAILED)
- return -1;
- clients->offset = 0;
-
- clients->recording = NULL;
- clients->serial = 0;
-
- return 0;
-}
-
-static void
-clients_add_command (struct clients *clients, int fd, char *info)
-{
- struct client_info *c;
- char buf[1024];
- int len;
- char *str;
-
- if (clients->count == clients->size) {
- clients->size *= 2;
- clients->clients = xrealloc (clients->clients,
- clients->size * sizeof (struct client_info));
- }
-
- c = &clients->clients[clients->count++];
- c->sk = fd;
- c->trace = -1;
- c->image_serial = 0;
- c->image = NULL;
- c->name = c->target = c->reference = NULL;
-
- c->out_size = 8192;
- c->out_buf = xmalloc (c->out_size);
- c->out_len = 0;
-
- str = strstr (info, "name=");
- if (str != NULL) {
- char *sp = strchr (str + 5, ' ');
- int len;
- if (sp)
- len = sp - str - 5;
- else
- len = strlen (str + 5);
- c->name = xmalloc (len + 1);
- memcpy (c->name, str + 5, len);
- c->name[len] = '\0';
- }
-
- str = strstr (info, "target=");
- if (str != NULL) {
- char *sp = strchr (str + 7, ' ');
- int len;
- if (sp)
- len = sp - str - 7;
- else
- len = strlen (str + 7);
- c->target = xmalloc (len + 1);
- memcpy (c->target, str + 7, len);
- c->target[len] = '\0';
- }
-
- str = strstr (info, "reference=");
- if (str != NULL) {
- char *sp = strchr (str + 10, ' ');
- int len;
- if (sp)
- len = sp - str - 10;
- else
- len = strlen (str + 10);
- c->reference = xmalloc (len + 1);
- memcpy (c->reference, str + 10, len);
- c->reference[len] = '\0';
- }
-
- len = sprintf (buf, "%s\n", clients->shm_path);
- writen (fd, buf, len);
-}
-
-static void
-clients_add_trace (struct clients *clients, int fd, char *info)
-{
- char *str, *sp;
- char *name;
- int i;
-
- str = strstr (info, "name=");
- assert (str != NULL);
- sp = strchr (str + 5, ' ');
- if (sp)
- i = sp - str - 5;
- else
- i = strlen (str + 5);
-
- name = xmalloc (i + 1);
- memcpy (name, str + 5, i);
- name[i] = '\0';
-
- for (i = 0; i < clients->count; i++) {
- struct client_info *c = &clients->clients[i];
- if (strcmp (name, c->name) == 0) {
- c->trace = fd;
- break;
- }
- }
-
- free (name);
-}
-
-static int
-clients_image (struct clients *clients, int fd, char *info)
-{
- struct client_info *c = NULL;
- int format, width, height, stride, size;
- int i;
-
- for (i = 0; i < clients->count; i++) {
- if (clients->clients[i].sk == fd) {
- c = &clients->clients[i];
- break;
- }
- }
-
- if (c == NULL)
- return 0;
-
- if (sscanf (info, "%lu %d %d %d %d",
- &c->image_serial, &format, &width, &height, &stride) != 5)
- {
- return 0;
- }
-
- size = height * stride;
- size = (size + 4095) & -4096;
- assert (clients->offset + size <= DATA_SIZE);
-
- c->image =
- cairo_image_surface_create_for_data (clients->base + clients->offset,
- format, width, height, stride);
-
- if (! writen (fd, &clients->offset, sizeof (clients->offset)))
- return 0;
-
- clients->offset += size;
-
- return 1;
-}
-
-static int
-u8_cmp (const void *A, const void *B)
-{
- const uint8_t *a = A, *b = B;
- return (int) *a - (int) *b;
-}
-
-static uint8_t
-median (uint8_t *values, int count)
-{
- /* XXX could use a fast median here if we cared */
- qsort (values, count, 1, u8_cmp);
- return values[count/2];
-}
-
-static uint32_t
-get_pixel32 (int x, int y, const uint8_t *data, int stride)
-{
- return ((uint32_t *)(data + y * stride))[x];
-}
-
-static uint8_t
-get_median_32 (int x, int y, int channel,
- const uint8_t *data, int width, int height, int stride)
-{
- uint8_t neighbourhood[25];
- int cnt = 0;
- int xx, yy;
-
- for (yy = y - 2; yy <= y + 2; yy++) {
- if (yy < 0)
- continue;
- if (yy >= height)
- continue;
-
- for (xx = x - 2; xx <= x + 2; xx++) {
- if (xx < 0)
- continue;
- if (xx >= width)
- continue;
-
- neighbourhood[cnt++] = (get_pixel32 (xx, yy, data, stride) >> (channel*8)) & 0xff;
- }
- }
-
- return median (neighbourhood, cnt);
-}
-
-static uint8_t
-get_pixel8 (int x, int y, const uint8_t *data, int stride)
-{
- return data[y * stride + x];
-}
-
-static uint8_t
-get_median_8 (int x, int y, const uint8_t *data, int width, int height, int stride)
-{
- uint8_t neighbourhood[25];
- int cnt = 0;
- int xx, yy;
-
- for (yy = y - 2; yy <= y + 2; yy++) {
- if (yy < 0)
- continue;
- if (yy >= height)
- continue;
-
- for (xx = x - 2; xx <= x + 2; xx++) {
- if (xx < 0)
- continue;
- if (xx >= width)
- continue;
-
- neighbourhood[cnt++] = get_pixel8 (xx, yy, data, stride);
- }
- }
-
- return median (neighbourhood, cnt);
-}
-
-static cairo_bool_t
-compare_images (cairo_surface_t *a,
- cairo_surface_t *b)
-{
- int width, height, stride;
- const uint8_t *aa, *bb;
- int x, y;
-
- if (cairo_surface_status (a) || cairo_surface_status (b))
- return FALSE;
-
- if (cairo_surface_get_type (a) != cairo_surface_get_type (b))
- return FALSE;
-
- if (cairo_image_surface_get_format (a) != cairo_image_surface_get_format (b))
- return FALSE;
-
- if (cairo_image_surface_get_width (a) != cairo_image_surface_get_width (b))
- return FALSE;
-
- if (cairo_image_surface_get_height (a) != cairo_image_surface_get_height (b))
- return FALSE;
-
- if (cairo_image_surface_get_stride (a) != cairo_image_surface_get_stride (b))
- return FALSE;
-
-
- width = cairo_image_surface_get_width (a);
- height = cairo_image_surface_get_height (a);
- stride = cairo_image_surface_get_stride (a);
-
- aa = cairo_image_surface_get_data (a);
- bb = cairo_image_surface_get_data (b);
- switch (cairo_image_surface_get_format (a)) {
- case CAIRO_FORMAT_ARGB32:
- for (y = 0; y < height; y++) {
- const uint32_t *ua = (uint32_t *) aa;
- const uint32_t *ub = (uint32_t *) bb;
- for (x = 0; x < width; x++) {
- if (ua[x] != ub[x]) {
- int channel;
-
- for (channel = 0; channel < 4; channel++) {
- unsigned va, vb, diff;
-
- va = (ua[x] >> (channel*8)) & 0xff;
- vb = (ub[x] >> (channel*8)) & 0xff;
- diff = abs (va - vb);
- if (diff > 1) {
- va = get_median_32 (x, y, channel, aa, width, height, stride);
- vb = get_median_32 (x, y, channel, bb, width, height, stride);
- diff = abs (va - vb);
- if (diff > 1)
- return FALSE;
- }
- }
- }
- }
- aa += stride;
- bb += stride;
- }
- break;
-
- case CAIRO_FORMAT_RGB24:
- for (y = 0; y < height; y++) {
- const uint32_t *ua = (uint32_t *) aa;
- const uint32_t *ub = (uint32_t *) bb;
- for (x = 0; x < width; x++) {
- if ((ua[x] & 0x00ffffff) != (ub[x] & 0x00ffffff)) {
- int channel;
-
- for (channel = 0; channel < 3; channel++) {
- unsigned va, vb, diff;
-
- va = (ua[x] >> (channel*8)) & 0xff;
- vb = (ub[x] >> (channel*8)) & 0xff;
- diff = abs (va - vb);
- if (diff > 1) {
- va = get_median_32 (x, y, channel, aa, width, height, stride);
- vb = get_median_32 (x, y, channel, bb, width, height, stride);
- diff = abs (va - vb);
- if (diff > 1)
- return FALSE;
- }
- }
- }
- }
- aa += stride;
- bb += stride;
- }
- break;
-
- case CAIRO_FORMAT_A8:
- for (y = 0; y < height; y++) {
- for (x = 0; x < width; x++) {
- if (aa[x] != bb[x]) {
- unsigned diff = abs (aa[x] - bb[x]);
- if (diff > 1) {
- uint8_t va, vb;
-
- va = get_median_8 (x, y, aa, width, height, stride);
- vb = get_median_8 (x, y, bb, width, height, stride);
- diff = abs (va - vb);
- if (diff > 1)
- return FALSE;
- }
-
- }
- }
- aa += stride;
- bb += stride;
- }
- break;
-
- case CAIRO_FORMAT_A1:
- width /= 8;
- for (y = 0; y < height; y++) {
- if (memcmp (aa, bb, width))
- return FALSE;
- aa += stride;
- bb += stride;
- }
- break;
-
- case CAIRO_FORMAT_INVALID:
- case CAIRO_FORMAT_RGB16_565: /* XXX */
- break;
- }
-
- return TRUE;
-}
-
-static int
-check_images (struct clients *clients)
-{
- int i, j;
-
- for (i = 0; i < clients->count; i++) {
- struct client_info *c = &clients->clients[i];
-
- if (c->reference == NULL)
- continue;
-
- for (j = 0; j < clients->count; j++) {
- struct client_info *ref = &clients->clients[j];
-
- if (strcmp (c->reference, ref->name))
- continue;
-
- if (! compare_images (c->image, ref->image))
- return 0;
- }
- }
-
- return 1;
-}
-
-static gchar *
-checksum (const char *filename)
-{
- gchar *str = NULL;
- gchar *data;
- gsize len;
-
- if (g_file_get_contents (filename, &data, &len, NULL)) {
- str = g_compute_checksum_for_data (G_CHECKSUM_SHA1, (guchar *) data, len);
- g_free (data);
- }
-
- return str;
-}
-
-static void
-write_trace (struct clients *clients)
-{
- cairo_device_t *ctx;
- gchar *csum;
- char buf[4096];
- int i;
-
- mkdir ("output", 0777);
-
- ctx = cairo_script_create ("output/cairo-sphinx.trace");
- cairo_script_from_recording_surface (ctx, clients->recording);
- cairo_device_destroy (ctx);
-
- csum = checksum ("output/cairo-sphinx.trace");
-
- sprintf (buf, "output/%s.trace", csum);
- if (! g_file_test (buf, G_FILE_TEST_EXISTS)) {
- rename ("output/cairo-sphinx.trace", buf);
-
- sprintf (buf, "output/%s.recording.png", csum);
- cairo_surface_write_to_png (clients->recording, buf);
-
- for (i = 0; i < clients->count; i++) {
- struct client_info *c = &clients->clients[i];
- if (c->image != NULL) {
- sprintf (buf, "output/%s.%s.png", csum, c->name);
- cairo_surface_write_to_png (c->image, buf);
- }
- }
- }
-}
-
-static void
-clients_complete (struct clients *clients, int fd)
-{
- int i;
-
- for (i = 0; i < clients->count; i++) {
- if (clients->clients[i].sk == fd) {
- break;
- }
- }
- if (i == clients->count)
- return;
-
- if (++clients->complete != clients->count)
- return;
-
- clients->offset = 0;
- clients->complete = 0;
-
- if (! check_images (clients))
- write_trace (clients);
-
- /* ack */
- for (i = 0; i < clients->count; i++) {
- struct client_info *c = &clients->clients[i];
-
- cairo_surface_destroy (c->image);
- c->image = NULL;
-
- if (! writen (c->sk, &clients->serial, sizeof (clients->serial)))
- continue;
-
- c->image_serial = 0;
- }
-
- clients->recording = NULL;
- clients->serial = 0;
-}
-
-static void
-clients_recording (struct clients *clients, int fd, char *info)
-{
- sscanf (info, "%p %lu", &clients->recording, &clients->serial);
- clients_complete (clients, fd);
-}
-
-static void
-clients_remove (struct clients *clients, int fd)
-{
- int i, j;
-
- for (i = 0; i < clients->count; i++) {
- struct client_info *c = &clients->clients[i];
- if (c->sk == fd) {
- free (c->out_buf);
- break;
- }
- }
-
- for (j = i++; i < clients->count; i++)
- clients->clients[j] = clients->clients[i];
-
- clients->count = j;
-}
-
-static void
-clients_send_trace (struct clients *clients,
- const char * const line, const int len)
-{
- int i;
-
- for (i = 0; i < clients->count; i++) {
- struct client_info *c = &clients->clients[i];
- int ret, rem = len;
-
- if (c->trace == -1)
- continue;
-
- if (c->out_len) {
- ret = write (c->trace, c->out_buf, c->out_len);
- if (ret > 0) {
- c->out_len -= ret;
- if (c->out_len)
- memmove (c->out_buf, c->out_buf + ret, c->out_len);
- }
- }
-
- if (! c->out_len) {
- ret = write (c->trace, line, rem);
- if (ret > 0)
- rem -= ret;
- }
-
- if (rem) {
- if (c->out_len + rem > c->out_size) {
- c->out_size *= 2;
- c->out_buf = xrealloc (c->out_buf, c->out_size);
- }
-
- memcpy (c->out_buf + c->out_len, line, rem);
- c->out_len += rem;
- }
- }
-}
-
-static void
-clients_fini (struct clients *clients)
-{
- shm_unlink (clients->shm_path);
- munmap (clients->base, DATA_SIZE);
- free (clients->clients);
-}
-
-static int
-nonblocking (int fd)
-{
- long flags;
-
- flags = fcntl (fd, F_GETFL);
- if (flags == -1)
- return -1;
-
- return fcntl (fd, F_SETFL, flags | O_NONBLOCK);
-}
-
-static void *
-request_image (struct client *c,
- struct context_closure *closure,
- cairo_format_t format,
- int width, int height, int stride)
-{
- char buf[1024];
- unsigned long offset = -1;
- int len;
-
- assert (format != CAIRO_FORMAT_INVALID);
-
- len = sprintf (buf, ".image %lu %d %d %d %d\n",
- closure->id, format, width, height, stride);
- writen (c->sk, buf, len);
-
- readn (c->sk, &offset, sizeof (offset));
- if (offset == (unsigned long) -1)
- return NULL;
-
- return (uint8_t *) c->base + offset;
-}
-
-static cairo_format_t
-format_for_content (cairo_content_t content)
-{
- switch (content) {
- case CAIRO_CONTENT_ALPHA:
- return CAIRO_FORMAT_A8;
- case CAIRO_CONTENT_COLOR:
- return CAIRO_FORMAT_RGB24;
- default:
- case CAIRO_CONTENT_COLOR_ALPHA:
- return CAIRO_FORMAT_ARGB32;
- }
-}
-
-static void
-get_surface_size (cairo_surface_t *surface,
- int *width, int *height,
- cairo_format_t *format)
-{
- if (cairo_surface_get_type (surface) == CAIRO_SURFACE_TYPE_IMAGE) {
- *width = cairo_image_surface_get_width (surface);
- *height = cairo_image_surface_get_height (surface);
- *format = cairo_image_surface_get_format (surface);
- } else {
- struct surface_tag *tag;
-
- tag = cairo_surface_get_user_data (surface, &surface_tag);
- if (tag != NULL) {
- *width = tag->width;
- *height = tag->height;
- } else {
- double x0, x1, y0, y1;
- cairo_t *cr;
-
- /* presumably created using cairo_surface_create_similar() */
- cr = cairo_create (surface);
- cairo_clip_extents (cr, &x0, &y0, &x1, &y1);
- cairo_destroy (cr);
-
- tag = xmalloc (sizeof (*tag));
- *width = tag->width = ceil (x1 - x0);
- *height = tag->height = ceil (y1 - y0);
-
- if (cairo_surface_set_user_data (surface, &surface_tag, tag, free))
- exit (-1);
- }
- }
-}
-
-
-static void
-send_surface (struct client *c,
- struct context_closure *closure)
-{
- cairo_surface_t *source = closure->surface;
- cairo_surface_t *image;
- cairo_format_t format = CAIRO_FORMAT_INVALID;
- cairo_t *cr;
- int width, height, stride;
- void *data;
- unsigned long serial;
-
- get_surface_size (source, &width, &height, &format);
- if (format == CAIRO_FORMAT_INVALID)
- format = format_for_content (cairo_surface_get_content (source));
-
- stride = cairo_format_stride_for_width (format, width);
-
- data = request_image (c, closure, format, width, height, stride);
- if (data == NULL)
- exit (-1);
-
- image = cairo_image_surface_create_for_data (data,
- format,
- width, height,
- stride);
- cr = cairo_create (image);
- cairo_surface_destroy (image);
-
- cairo_set_operator (cr, CAIRO_OPERATOR_SOURCE);
- cairo_set_source_surface (cr, source, 0, 0);
- cairo_paint (cr);
- cairo_destroy (cr);
-
- /* signal completion */
- writen (c->sk, ".complete\n", strlen (".complete\n"));
-
- /* wait for image check */
- serial = 0;
- readn (c->sk, &serial, sizeof (serial));
- if (serial != closure->id)
- exit (-1);
-}
-
-static void
-send_recording (struct client *c,
- struct context_closure *closure)
-{
- cairo_surface_t *source = closure->surface;
- char buf[1024];
- int len;
- unsigned long serial;
-
- assert (cairo_surface_get_type (source) == CAIRO_SURFACE_TYPE_RECORDING);
- len = sprintf (buf, ".recording %p %lu\n", source, closure->id);
- writen (c->sk, buf, len);
-
- /* wait for image check */
-
- serial = 0;
- readn (c->sk, &serial, sizeof (serial));
- if (serial != closure->id)
- exit (-1);
-}
-
-static cairo_surface_t *
-_surface_create (void *closure,
- cairo_content_t content,
- double width, double height,
- long uid)
-{
- struct client *c = closure;
- cairo_surface_t *surface;
-
- surface = cairo_surface_create_similar (c->surface,
- content, width, height);
- if (cairo_surface_get_type (surface) != CAIRO_SURFACE_TYPE_IMAGE) {
- struct surface_tag *tag;
-
- tag = xmalloc (sizeof (*tag));
- tag->width = width;
- tag->height = height;
- if (cairo_surface_set_user_data (surface, &surface_tag, tag, free))
- exit (-1);
- }
-
- return surface;
-}
-
-static cairo_t *
-_context_create (void *closure, cairo_surface_t *surface)
-{
- struct client *c = closure;
- struct context_closure *l;
- cairo_bool_t foreign = FALSE;
-
- l = xmalloc (sizeof (*l));
- l->next = c->contexts;
- l->surface = surface;
- l->original = cairo_surface_reference (surface);
- l->id = ++c->context_id;
- if (l->id == 0)
- l->id = ++c->context_id;
- c->contexts = l;
-
- /* record everything, including writes to images */
- if (c->target == NULL) {
- if (cairo_surface_get_type (surface) != CAIRO_SURFACE_TYPE_RECORDING) {
- cairo_format_t format;
- int width, height;
-
- get_surface_size (surface, &width, &height, &format);
- l->surface = cairo_surface_create_similar (c->surface,
- cairo_surface_get_content (surface),
- width, height);
- foreign = TRUE;
- }
- }
-
- l->context = cairo_create (l->surface);
- if (foreign) {
- cairo_set_source_surface (l->context, surface, 0, 0);
- cairo_paint (l->context);
- }
-
- return l->context;
-}
-
-static void
-_context_destroy (void *closure, void *ptr)
-{
- struct client *c = closure;
- struct context_closure *l, **prev = &c->contexts;
-
- while ((l = *prev) != NULL) {
- if (l->context == ptr) {
- if (cairo_surface_status (l->surface) == CAIRO_STATUS_SUCCESS) {
- if (c->target == NULL)
- send_recording (c, l);
- else
- send_surface (c, l);
- } else {
- exit (-1);
- }
-
- cairo_surface_destroy (l->original);
- *prev = l->next;
- free (l);
- return;
- }
- prev = &l->next;
- }
-}
-
-static void *
-recorder (void *arg)
-{
- struct client client;
- const cairo_script_interpreter_hooks_t hooks = {
- .closure = &client,
- .surface_create = _surface_create,
- .context_create = _context_create,
- .context_destroy = _context_destroy,
- };
- char *buf;
- int buf_size;
- int len = 0, ret;
- struct pollfd pfd;
-
- client.target = NULL;
- client.sk = client_socket ("/tmp/cairo-sphinx");
- if (client.sk < 0)
- return NULL;
-
- buf_size = 65536;
- buf = xmalloc (buf_size);
-
- len = sprintf (buf, "client-command target=recording name=.recorder\n");
- if (! writen (client.sk, buf, len))
- return NULL;
-
- /* drain the shm_path */
- len = readline (client.sk, buf, buf_size);
-
- pfd.fd = client_socket ("/tmp/cairo-sphinx");
- if (pfd.fd < 0)
- return NULL;
-
- len = sprintf (buf, "client-trace name=.recorder\n");
- if (! writen (pfd.fd, buf, len))
- return NULL;
-
- client.surface = cairo_recording_surface_create (CAIRO_CONTENT_COLOR_ALPHA,
- NULL);
-
- client.context_id = 0;
- client.csi = cairo_script_interpreter_create ();
- cairo_script_interpreter_install_hooks (client.csi, &hooks);
-
- nonblocking (pfd.fd);
- pfd.events = POLLIN;
- len = 0;
- while (poll (&pfd, 1, -1) > 0) {
- while ((ret = read (pfd.fd, buf + len, buf_size - len)) > 0) {
- int end;
-
- if (ret == buf_size - len) {
- buf_size *= 2;
- buf = xrealloc (buf, buf_size);
- }
- len += ret;
-
- for (end = len; end > 0 && buf[--end] != '\n'; )
- ;
- if (end > 0) {
- buf[end] = '\0';
- cairo_script_interpreter_feed_string (client.csi, buf, end);
-
- len -= end + 1;
- if (len)
- memmove (buf, buf + end + 1, len);
- }
- }
- if (ret == 0)
- break;
- if (! (errno == EAGAIN || errno == EINTR))
- break;
- }
-
- cairo_script_interpreter_finish (client.csi);
- cairo_script_interpreter_destroy (client.csi);
-
- cairo_surface_destroy (client.surface);
- return NULL;
-}
-
-static int
-do_server (const char *path)
-{
- pthread_t thread;
- struct clients clients;
- char line[4096];
- struct pollfd *pfd;
- int num_pfd, size_pfd;
- int n, cnt, ret = 1;
- int sk, source = -1;
- int waiter = -1, waiter_count = 0;
- int len;
-
- signal (SIGPIPE, SIG_IGN);
-
- if (clients_init (&clients) < 0) {
- fprintf (stderr, "Failed to initialise clients structure\n");
- return -1;
- }
-
- sk = server_socket (path);
- if (sk < 0) {
- fprintf (stderr, "Failed to create server socket\n");
- return 1;
- }
-
- if (daemonize () < 0)
- return 1;
-
- if (pthread_create (&thread, NULL, recorder, NULL) < 0) {
- fprintf (stderr, "Failed to create spawn recording thread\n");
- return 1;
- }
-
- size_pfd = 4;
- pfd = xmalloc (sizeof (*pfd) * size_pfd);
- pfd[0].fd = sk;
- pfd[0].events = POLLIN;
- num_pfd = 1;
-
- while ((cnt = poll (pfd, num_pfd, -1)) > 0) {
- int have_source;
-
- if (pfd[0].revents) {
- while ((sk = accept (pfd[0].fd, NULL, NULL)) != -1) {
- len = readline (sk, line, sizeof (line));
- if (strcmp (line, "source") == 0) {
-
- if (source != -1)
- exit (1);
-
- source = sk;
- if (nonblocking (sk) < 0) {
- close (sk);
- continue;
- }
- } else if (strncmp (line, "client-command", 14) == 0) {
- if (source == -1)
- clients_add_command (&clients, sk, line);
- } else if (strncmp (line, "client-trace", 12) == 0) {
- if (source == -1) {
- clients_add_trace (&clients, sk, line);
- if (nonblocking (sk) < 0) {
- close (sk);
- continue;
- }
-
- if (clients.count == waiter_count) {
- for (n = 1; n < num_pfd; n++) {
- if (pfd[n].fd == waiter) {
- pfd[n].fd = -1;
- break;
- }
- }
- close (waiter);
- waiter_count = -1;
- }
- }
- } else if (strncmp (line, "wait", 4) == 0) {
- int count = atoi (line + 5) + 1;
- if (clients.count == count) {
- close (sk);
- continue;
- } else {
- waiter = sk;
- waiter_count = count;
- }
- }
-
- if (num_pfd == size_pfd) {
- size_pfd *= 2;
- pfd = xrealloc (pfd, sizeof (*pfd) * size_pfd);
- }
-
- pfd[num_pfd].fd = sk;
- pfd[num_pfd].events = POLLIN;
- pfd[num_pfd].revents = 0;
- num_pfd++;
- }
- cnt--;
- }
-
- have_source = 0;
- for (n = 1; cnt && n < num_pfd; n++) {
- if (! pfd[n].revents)
- continue;
- cnt--;
-
- if (pfd[n].fd == -1)
- continue;
-
- if (source == pfd[n].fd) {
- have_source = n;
- } else {
- len = readline (pfd[n].fd, line, sizeof (line));
- if (len < 0) {
- clients_remove (&clients, pfd[n].fd);
- close (pfd[n].fd);
- pfd[n].fd = -1;
- continue;
- }
-
- if (strncmp (line, ".image", 6) == 0) {
- if (! clients_image (&clients, pfd[n].fd, line + 7)) {
- clients_remove (&clients, pfd[n].fd);
- close (pfd[n].fd);
- pfd[n].fd = -1;
- continue;
- }
- } else if (strncmp (line, ".complete", 9) == 0) {
- clients_complete (&clients, pfd[n].fd);
- } else if (strncmp (line, ".recording", 10) == 0) {
- clients_recording (&clients, pfd[n].fd, line + 6);
- } else {
- printf ("do_command (%s)\n", line);
- }
- }
- }
-
- if (have_source) {
- do {
- len = read (source, line, sizeof (line));
- if (len > 0) {
- clients_send_trace (&clients, line, len);
- } else if (len == 0) {
- close (source);
- pfd[have_source].fd = source = -1;
- goto done;
- } else
- break;
- } while (1);
- }
-
- for (n = cnt = 1; n < num_pfd; n++) {
- if (pfd[n].fd != -1) {
- if (cnt != n)
- pfd[cnt] = pfd[n];
- cnt++;
- }
- }
- num_pfd = cnt;
- }
-
-done:
- ret = 0;
- for (n = 0; n < num_pfd; n++) {
- if (pfd[n].fd != -1)
- close (pfd[n].fd);
- }
- free (pfd);
- clients_fini (&clients);
-
- return ret;
-}
-
-static void *
-client_shm (const char *shm_path)
-{
- void *base;
- int fd;
-
- fd = shm_open (shm_path, O_RDWR, 0);
- if (fd == -1)
- return MAP_FAILED;
-
- base = mmap (NULL, DATA_SIZE,
- PROT_READ | PROT_WRITE,
- MAP_SHARED | MAP_NORESERVE,
- fd, 0);
- close (fd);
-
- return base;
-}
-
-static int
-client_socket (const char *socket_path)
-{
- struct sockaddr_un addr;
- int sk;
-
- sk = socket (PF_UNIX, SOCK_STREAM, 0);
- if (sk == -1)
- return -1;
-
- memset (&addr, 0, sizeof (addr));
- addr.sun_family = AF_UNIX;
- strcpy (addr.sun_path, socket_path);
-
- if (connect (sk, (struct sockaddr *) &addr, sizeof (addr)) == -1)
- return -1;
-
- return sk;
-}
-
-static int
-do_client (int fd,
- const char *target,
- const char *name,
- const char *reference,
- cairo_content_t content)
-{
- struct client client;
- const cairo_script_interpreter_hooks_t hooks = {
- .closure = &client,
- .surface_create = _surface_create,
- .context_create = _context_create,
- .context_destroy = _context_destroy,
- };
- void *closure;
- char *buf;
- int buf_size;
- int len = 0, ret;
- struct pollfd pfd;
-
- client.sk = fd;
- client.target = cairo_boilerplate_get_target_by_name (target, content);
- client.context_id = 0;
-
- client.surface = client.target->create_surface (NULL, content, 1, 1, 1, 1,
- CAIRO_BOILERPLATE_MODE_TEST,
- &closure);
- if (client.surface == NULL) {
- fprintf (stderr, "Failed to create target surface: %s.\n",
- client.target->name);
- return 1;
- }
-
- buf_size = 65536;
- buf = xmalloc (buf_size);
-
- if (reference != NULL) {
- len = sprintf (buf,
- "client-command name=%s target=%s reference=%s\n",
- name, target, reference);
- } else {
- len = sprintf (buf,
- "client-command name=%s target=%s\n",
- name, target);
- }
- if (! writen (fd, buf, len))
- return 1;
-
- len = readline (fd, buf, buf_size);
- client.base = client_shm (buf);
- if (client.base == MAP_FAILED) {
- fprintf (stderr, "Failed to map shared memory segment '%s'.\n", buf);
- return 1;
- }
-
- if (daemonize () < 0)
- return 1;
-
- pfd.fd = client_socket ("/tmp/cairo-sphinx");
- if (pfd.fd < 0)
- return 1;
-
- len = sprintf (buf, "client-trace name=%s\n", name);
- if (! writen (pfd.fd, buf, len))
- return 1;
-
- client.csi = cairo_script_interpreter_create ();
- cairo_script_interpreter_install_hooks (client.csi, &hooks);
-
- nonblocking (pfd.fd);
- pfd.events = POLLIN;
- len = 0;
- while (poll (&pfd, 1, -1) > 0) {
- while ((ret = read (pfd.fd, buf + len, buf_size - len)) > 0) {
- int end;
-
- if (ret == buf_size - len) {
- buf_size *= 2;
- buf = xrealloc (buf, buf_size);
- }
- len += ret;
-
- for (end = len; end > 0 && buf[--end] != '\n'; )
- ;
- if (end > 0) {
- buf[end] = '\0';
- cairo_script_interpreter_feed_string (client.csi, buf, end);
-
- len -= end + 1;
- if (len)
- memmove (buf, buf + end + 1, len);
- }
- }
- if (ret == 0)
- break;
- if (! (errno == EAGAIN || errno == EINTR))
- break;
- }
-
- cairo_script_interpreter_finish (client.csi);
- cairo_script_interpreter_destroy (client.csi);
-
- cairo_surface_destroy (client.surface);
- close (fd);
-
- return 0;
-}
-
-static int
-do_exec (int fd, char **argv)
-{
- char buf[4096];
-
- if (*argv == NULL)
- return 0;
-
- snprintf (buf, sizeof (buf), "%s/cairo-trace.so", LIBDIR);
- setenv ("LD_PRELOAD", buf, 1);
-
- snprintf (buf, sizeof (buf), "0");
- setenv ("CAIRO_TRACE_LINE_INFO", buf, 1);
-
- snprintf (buf, sizeof (buf), "%d", fd);
- setenv ("CAIRO_TRACE_FD", buf, 1);
- putenv (buf);
-
- return execvp (argv[0], argv);
-}
-
-static int
-do_wait (int fd)
-{
- char buf;
- int ret = read (fd, &buf, 1);
- return ret != 0;
-}
-
-int
-main (int argc, char **argv)
-{
- char buf[4096];
- int len;
- int fd;
-
- if (argc == 1)
- return do_server ("/tmp/cairo-sphinx");
-
- fd = client_socket ("/tmp/cairo-sphinx");
- if (fd < 0)
- return 1;
-
- if (strcmp (argv[1], "client") == 0) {
- return do_client (fd, argv[2], argv[3], argv[4],
- CAIRO_CONTENT_COLOR_ALPHA);
- }
-
- if (strcmp (argv[1], "wait") == 0) {
- len = snprintf (buf, sizeof (buf), "wait %s\n", argv[2]);
- if (! writen (fd, buf, len))
- return 1;
-
- return do_wait (fd);
- }
-
- if (strcmp (argv[1], "exec") == 0) {
- len = snprintf (buf, sizeof (buf), "source\n");
- if (! writen (fd, buf, len))
- return 1;
-
- return do_exec (fd, argv+2);
- }
-
- if (strcmp (argv[1], "replay") == 0) {
- len = snprintf (buf, sizeof (buf), "replay %s\n", argv[2]);
- return ! writen (fd, buf, len);
- }
-
- return 0;
-}
generated by cgit v1.2.1 (git 2.18.0) at 2024-11-01 23:21:28 +0000