Blame 0003-iohandlers-Add-enable-disable_write_fd_handler-funct.patch

Justin M. Forbes fc5c27
>From c8cf564bc5c080540287ecd5bd944d85873755df Mon Sep 17 00:00:00 2001
Hans de Goede 3f1f29
From: Amit Shah <amit.shah@redhat.com>
Hans de Goede 3f1f29
Date: Mon, 21 Mar 2011 20:32:58 +0100
Justin M. Forbes fc5c27
Subject: [PATCH 03/28] iohandlers: Add enable/disable_write_fd_handler()
Hans de Goede 3f1f29
 functions
Hans de Goede 3f1f29
Hans de Goede 3f1f29
These will be used to provide a cleaner API for the nonblocking case.
Hans de Goede 3f1f29
Hans de Goede 3f1f29
Signed-off-by: Amit Shah <amit.shah@redhat.com>
Hans de Goede 3f1f29
---
Hans de Goede 3f1f29
 iohandler.c |   35 +++++++++++++++++++++++++++++++++++
Hans de Goede 3f1f29
 qemu-char.h |    3 +++
Hans de Goede 3f1f29
 2 files changed, 38 insertions(+), 0 deletions(-)
Hans de Goede 3f1f29
Hans de Goede 3f1f29
diff --git a/iohandler.c b/iohandler.c
Hans de Goede 3f1f29
index 2b82421..8e6628b 100644
Hans de Goede 3f1f29
--- a/iohandler.c
Hans de Goede 3f1f29
+++ b/iohandler.c
Hans de Goede 3f1f29
@@ -44,6 +44,41 @@ typedef struct IOHandlerRecord {
Hans de Goede 3f1f29
 static QLIST_HEAD(, IOHandlerRecord) io_handlers =
Hans de Goede 3f1f29
     QLIST_HEAD_INITIALIZER(io_handlers);
Hans de Goede 3f1f29
 
Hans de Goede 3f1f29
+static IOHandlerRecord *find_iohandler(int fd)
Hans de Goede 3f1f29
+{
Hans de Goede 3f1f29
+    IOHandlerRecord *ioh;
Hans de Goede 3f1f29
+
Hans de Goede 3f1f29
+    QLIST_FOREACH(ioh, &io_handlers, next) {
Hans de Goede 3f1f29
+        if (ioh->fd == fd) {
Hans de Goede 3f1f29
+            return ioh;
Hans de Goede 3f1f29
+        }
Hans de Goede 3f1f29
+    }
Hans de Goede 3f1f29
+    return NULL;
Hans de Goede 3f1f29
+}
Hans de Goede 3f1f29
+
Hans de Goede 3f1f29
+void enable_write_fd_handler(int fd, IOHandler *fd_write)
Hans de Goede 3f1f29
+{
Hans de Goede 3f1f29
+    IOHandlerRecord *ioh;
Hans de Goede 3f1f29
+
Hans de Goede 3f1f29
+    ioh = find_iohandler(fd);
Hans de Goede 3f1f29
+    if (!ioh) {
Hans de Goede 3f1f29
+        return;
Hans de Goede 3f1f29
+    }
Hans de Goede 3f1f29
+
Hans de Goede 3f1f29
+    ioh->fd_write = fd_write;
Hans de Goede 3f1f29
+}
Hans de Goede 3f1f29
+
Hans de Goede 3f1f29
+void disable_write_fd_handler(int fd)
Hans de Goede 3f1f29
+{
Hans de Goede 3f1f29
+    IOHandlerRecord *ioh;
Hans de Goede 3f1f29
+
Hans de Goede 3f1f29
+    ioh = find_iohandler(fd);
Hans de Goede 3f1f29
+    if (!ioh) {
Hans de Goede 3f1f29
+        return;
Hans de Goede 3f1f29
+    }
Hans de Goede 3f1f29
+
Hans de Goede 3f1f29
+    ioh->fd_write = NULL;
Hans de Goede 3f1f29
+}
Hans de Goede 3f1f29
 
Hans de Goede 3f1f29
 /* XXX: fd_read_poll should be suppressed, but an API change is
Hans de Goede 3f1f29
    necessary in the character devices to suppress fd_can_read(). */
Hans de Goede 3f1f29
diff --git a/qemu-char.h b/qemu-char.h
Justin M. Forbes 5e10b1
index b8372ea..9fe1b82 100644
Hans de Goede 3f1f29
--- a/qemu-char.h
Hans de Goede 3f1f29
+++ b/qemu-char.h
Justin M. Forbes 5e10b1
@@ -123,6 +123,9 @@ size_t qemu_chr_mem_osize(const CharDriverState *chr);
Hans de Goede 3f1f29
 
Hans de Goede 3f1f29
 /* async I/O support */
Hans de Goede 3f1f29
 
Hans de Goede 3f1f29
+void enable_write_fd_handler(int fd, IOHandler *fd_write);
Hans de Goede 3f1f29
+void disable_write_fd_handler(int fd);
Hans de Goede 3f1f29
+
Hans de Goede 3f1f29
 int qemu_set_fd_handler2(int fd,
Hans de Goede 3f1f29
                          IOCanReadHandler *fd_read_poll,
Hans de Goede 3f1f29
                          IOHandler *fd_read,
Hans de Goede 3f1f29
-- 
Hans de Goede 3f1f29
1.7.5.1
Hans de Goede 3f1f29