console_socket.c

#include <sys/socket.h>
#include <sys/un.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>
#include <stdlib.h>

#include "console_socket.h"
#include "ge.h"
#include "console.h"
#include "log.h"

static const char socket_path[] = "/tmp/gemu.console";
static int console_socket_fd = -1;

static int console_socket_init(struct ge *ge, void *ctx)
{
    int sd;
    struct sockaddr_un sock;
    (void)ge;
    (void)ctx;
    unlink(socket_path);
    memset(&sock, 0, sizeof(sock));
    sock.sun_family = AF_UNIX;
    strcpy(sock.sun_path, socket_path);
    sd = socket(AF_UNIX, SOCK_DGRAM, 0);
    if (sd < 0)
        return sd;
    fcntl(sd, F_SETFL, O_NONBLOCK);
    if (bind(sd, (struct sockaddr *)&sock, sizeof(sock)) != 0) {
        close(sd);
        return -1;
    }

    console_socket_fd = sd;
    return 0;
}


static int console_socket_check(struct ge *ge, void *ctx)
{
    char buf[1024];
    struct sockaddr_un dst;
    ssize_t ret;
    socklen_t socket_size = sizeof(struct sockaddr_un);
    struct ge_console console;

    (void)ctx;

    if (console_socket_fd < 0) {
        return -1;
    }

    ge_fill_console_data(ge, &console);

    ret = recvfrom(console_socket_fd, buf, 1024, 0,
                   (struct sockaddr *)&dst, &socket_size);
    if (ret > 0) {
        ge_log(LOG_DEBUG, "doing check\n");
        sendto(console_socket_fd, (unsigned char *)(&console),
               sizeof(struct ge_console), 0, (struct sockaddr *)&dst,
               socket_size);
    }

    return 0;
}

static struct ge_peri console_socket = {
    .init = console_socket_init,
    .on_pulse = console_socket_check,
};

int console_socket_register(struct ge *ge)
{
    return ge_register_peri(ge, &console_socket);
}