summaryrefslogtreecommitdiffstats
path: root/qemu/qga/channel-posix.c
diff options
context:
space:
mode:
Diffstat (limited to 'qemu/qga/channel-posix.c')
-rw-r--r--qemu/qga/channel-posix.c270
1 files changed, 0 insertions, 270 deletions
diff --git a/qemu/qga/channel-posix.c b/qemu/qga/channel-posix.c
deleted file mode 100644
index 63458c663..000000000
--- a/qemu/qga/channel-posix.c
+++ /dev/null
@@ -1,270 +0,0 @@
-#include "qemu/osdep.h"
-#include <glib.h>
-#include <termios.h>
-#include "qapi/error.h"
-#include "qemu/sockets.h"
-#include "qga/channel.h"
-
-#ifdef CONFIG_SOLARIS
-#include <stropts.h>
-#endif
-
-#define GA_CHANNEL_BAUDRATE_DEFAULT B38400 /* for isa-serial channels */
-
-struct GAChannel {
- GIOChannel *listen_channel;
- GIOChannel *client_channel;
- GAChannelMethod method;
- GAChannelCallback event_cb;
- gpointer user_data;
-};
-
-static int ga_channel_client_add(GAChannel *c, int fd);
-
-static gboolean ga_channel_listen_accept(GIOChannel *channel,
- GIOCondition condition, gpointer data)
-{
- GAChannel *c = data;
- int ret, client_fd;
- bool accepted = false;
- struct sockaddr_un addr;
- socklen_t addrlen = sizeof(addr);
-
- g_assert(channel != NULL);
-
- client_fd = qemu_accept(g_io_channel_unix_get_fd(channel),
- (struct sockaddr *)&addr, &addrlen);
- if (client_fd == -1) {
- g_warning("error converting fd to gsocket: %s", strerror(errno));
- goto out;
- }
- qemu_set_nonblock(client_fd);
- ret = ga_channel_client_add(c, client_fd);
- if (ret) {
- g_warning("error setting up connection");
- close(client_fd);
- goto out;
- }
- accepted = true;
-
-out:
- /* only accept 1 connection at a time */
- return !accepted;
-}
-
-/* start polling for readable events on listen fd, new==true
- * indicates we should use the existing s->listen_channel
- */
-static void ga_channel_listen_add(GAChannel *c, int listen_fd, bool create)
-{
- if (create) {
- c->listen_channel = g_io_channel_unix_new(listen_fd);
- }
- g_io_add_watch(c->listen_channel, G_IO_IN, ga_channel_listen_accept, c);
-}
-
-static void ga_channel_listen_close(GAChannel *c)
-{
- g_assert(c->method == GA_CHANNEL_UNIX_LISTEN);
- g_assert(c->listen_channel);
- g_io_channel_shutdown(c->listen_channel, true, NULL);
- g_io_channel_unref(c->listen_channel);
- c->listen_channel = NULL;
-}
-
-/* cleanup state for closed connection/session, start accepting new
- * connections if we're in listening mode
- */
-static void ga_channel_client_close(GAChannel *c)
-{
- g_assert(c->client_channel);
- g_io_channel_shutdown(c->client_channel, true, NULL);
- g_io_channel_unref(c->client_channel);
- c->client_channel = NULL;
- if (c->method == GA_CHANNEL_UNIX_LISTEN && c->listen_channel) {
- ga_channel_listen_add(c, 0, false);
- }
-}
-
-static gboolean ga_channel_client_event(GIOChannel *channel,
- GIOCondition condition, gpointer data)
-{
- GAChannel *c = data;
- gboolean client_cont;
-
- g_assert(c);
- if (c->event_cb) {
- client_cont = c->event_cb(condition, c->user_data);
- if (!client_cont) {
- ga_channel_client_close(c);
- return false;
- }
- }
- return true;
-}
-
-static int ga_channel_client_add(GAChannel *c, int fd)
-{
- GIOChannel *client_channel;
- GError *err = NULL;
-
- g_assert(c && !c->client_channel);
- client_channel = g_io_channel_unix_new(fd);
- g_assert(client_channel);
- g_io_channel_set_encoding(client_channel, NULL, &err);
- if (err != NULL) {
- g_warning("error setting channel encoding to binary");
- g_error_free(err);
- return -1;
- }
- g_io_add_watch(client_channel, G_IO_IN | G_IO_HUP,
- ga_channel_client_event, c);
- c->client_channel = client_channel;
- return 0;
-}
-
-static gboolean ga_channel_open(GAChannel *c, const gchar *path, GAChannelMethod method)
-{
- int ret;
- c->method = method;
-
- switch (c->method) {
- case GA_CHANNEL_VIRTIO_SERIAL: {
- int fd = qemu_open(path, O_RDWR | O_NONBLOCK
-#ifndef CONFIG_SOLARIS
- | O_ASYNC
-#endif
- );
- if (fd == -1) {
- g_critical("error opening channel: %s", strerror(errno));
- return false;
- }
-#ifdef CONFIG_SOLARIS
- ret = ioctl(fd, I_SETSIG, S_OUTPUT | S_INPUT | S_HIPRI);
- if (ret == -1) {
- g_critical("error setting event mask for channel: %s",
- strerror(errno));
- close(fd);
- return false;
- }
-#endif
- ret = ga_channel_client_add(c, fd);
- if (ret) {
- g_critical("error adding channel to main loop");
- close(fd);
- return false;
- }
- break;
- }
- case GA_CHANNEL_ISA_SERIAL: {
- struct termios tio;
- int fd = qemu_open(path, O_RDWR | O_NOCTTY | O_NONBLOCK);
- if (fd == -1) {
- g_critical("error opening channel: %s", strerror(errno));
- return false;
- }
- tcgetattr(fd, &tio);
- /* set up serial port for non-canonical, dumb byte streaming */
- tio.c_iflag &= ~(IGNBRK | BRKINT | IGNPAR | PARMRK | INPCK | ISTRIP |
- INLCR | IGNCR | ICRNL | IXON | IXOFF | IXANY |
- IMAXBEL);
- tio.c_oflag = 0;
- tio.c_lflag = 0;
- tio.c_cflag |= GA_CHANNEL_BAUDRATE_DEFAULT;
- /* 1 available byte min or reads will block (we'll set non-blocking
- * elsewhere, else we have to deal with read()=0 instead)
- */
- tio.c_cc[VMIN] = 1;
- tio.c_cc[VTIME] = 0;
- /* flush everything waiting for read/xmit, it's garbage at this point */
- tcflush(fd, TCIFLUSH);
- tcsetattr(fd, TCSANOW, &tio);
- ret = ga_channel_client_add(c, fd);
- if (ret) {
- g_critical("error adding channel to main loop");
- close(fd);
- return false;
- }
- break;
- }
- case GA_CHANNEL_UNIX_LISTEN: {
- Error *local_err = NULL;
- int fd = unix_listen(path, NULL, strlen(path), &local_err);
- if (local_err != NULL) {
- g_critical("%s", error_get_pretty(local_err));
- error_free(local_err);
- return false;
- }
- ga_channel_listen_add(c, fd, true);
- break;
- }
- default:
- g_critical("error binding/listening to specified socket");
- return false;
- }
-
- return true;
-}
-
-GIOStatus ga_channel_write_all(GAChannel *c, const gchar *buf, gsize size)
-{
- GError *err = NULL;
- gsize written = 0;
- GIOStatus status = G_IO_STATUS_NORMAL;
-
- while (size) {
- g_debug("sending data, count: %d", (int)size);
- status = g_io_channel_write_chars(c->client_channel, buf, size,
- &written, &err);
- if (status == G_IO_STATUS_NORMAL) {
- size -= written;
- buf += written;
- } else if (status != G_IO_STATUS_AGAIN) {
- g_warning("error writing to channel: %s", err->message);
- return status;
- }
- }
-
- do {
- status = g_io_channel_flush(c->client_channel, &err);
- } while (status == G_IO_STATUS_AGAIN);
-
- if (status != G_IO_STATUS_NORMAL) {
- g_warning("error flushing channel: %s", err->message);
- }
-
- return status;
-}
-
-GIOStatus ga_channel_read(GAChannel *c, gchar *buf, gsize size, gsize *count)
-{
- return g_io_channel_read_chars(c->client_channel, buf, size, count, NULL);
-}
-
-GAChannel *ga_channel_new(GAChannelMethod method, const gchar *path,
- GAChannelCallback cb, gpointer opaque)
-{
- GAChannel *c = g_new0(GAChannel, 1);
- c->event_cb = cb;
- c->user_data = opaque;
-
- if (!ga_channel_open(c, path, method)) {
- g_critical("error opening channel");
- ga_channel_free(c);
- return NULL;
- }
-
- return c;
-}
-
-void ga_channel_free(GAChannel *c)
-{
- if (c->method == GA_CHANNEL_UNIX_LISTEN
- && c->listen_channel) {
- ga_channel_listen_close(c);
- }
- if (c->client_channel) {
- ga_channel_client_close(c);
- }
- g_free(c);
-}