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

Justin M. Forbes d4cdad
From f896c023201863927853c5d97e62916e0753fede Mon Sep 17 00:00:00 2001
Justin M. Forbes d4cdad
From: Amit Shah <amit.shah@redhat.com>
Justin M. Forbes d4cdad
Date: Mon, 21 Mar 2011 20:32:58 +0100
Justin M. Forbes d4cdad
Subject: [PATCH 108/118] iohandlers: Add enable/disable_write_fd_handler()
Justin M. Forbes d4cdad
 functions
Justin M. Forbes d4cdad
Justin M. Forbes d4cdad
These will be used to provide a cleaner API for the nonblocking case.
Justin M. Forbes d4cdad
Justin M. Forbes d4cdad
Signed-off-by: Amit Shah <amit.shah@redhat.com>
Justin M. Forbes d4cdad
---
Justin M. Forbes d4cdad
 iohandler.c |   35 +++++++++++++++++++++++++++++++++++
Justin M. Forbes d4cdad
 main-loop.h |    3 +++
Justin M. Forbes d4cdad
 2 files changed, 38 insertions(+), 0 deletions(-)
Justin M. Forbes d4cdad
Justin M. Forbes d4cdad
diff --git a/iohandler.c b/iohandler.c
Justin M. Forbes d4cdad
index 5640d49..a9a62cb 100644
Justin M. Forbes d4cdad
--- a/iohandler.c
Justin M. Forbes d4cdad
+++ b/iohandler.c
Justin M. Forbes d4cdad
@@ -45,6 +45,41 @@ typedef struct IOHandlerRecord {
Justin M. Forbes d4cdad
 static QLIST_HEAD(, IOHandlerRecord) io_handlers =
Justin M. Forbes d4cdad
     QLIST_HEAD_INITIALIZER(io_handlers);
Justin M. Forbes d4cdad
Justin M. Forbes d4cdad
+static IOHandlerRecord *find_iohandler(int fd)
Justin M. Forbes d4cdad
+{
Justin M. Forbes d4cdad
+    IOHandlerRecord *ioh;
Justin M. Forbes d4cdad
+
Justin M. Forbes d4cdad
+    QLIST_FOREACH(ioh, &io_handlers, next) {
Justin M. Forbes d4cdad
+        if (ioh->fd == fd) {
Justin M. Forbes d4cdad
+            return ioh;
Justin M. Forbes d4cdad
+        }
Justin M. Forbes d4cdad
+    }
Justin M. Forbes d4cdad
+    return NULL;
Justin M. Forbes d4cdad
+}
Justin M. Forbes d4cdad
+
Justin M. Forbes d4cdad
+void enable_write_fd_handler(int fd, IOHandler *fd_write)
Justin M. Forbes d4cdad
+{
Justin M. Forbes d4cdad
+    IOHandlerRecord *ioh;
Justin M. Forbes d4cdad
+
Justin M. Forbes d4cdad
+    ioh = find_iohandler(fd);
Justin M. Forbes d4cdad
+    if (!ioh) {
Justin M. Forbes d4cdad
+        return;
Justin M. Forbes d4cdad
+    }
Justin M. Forbes d4cdad
+
Justin M. Forbes d4cdad
+    ioh->fd_write = fd_write;
Justin M. Forbes d4cdad
+}
Justin M. Forbes d4cdad
+
Justin M. Forbes d4cdad
+void disable_write_fd_handler(int fd)
Justin M. Forbes d4cdad
+{
Justin M. Forbes d4cdad
+    IOHandlerRecord *ioh;
Justin M. Forbes d4cdad
+
Justin M. Forbes d4cdad
+    ioh = find_iohandler(fd);
Justin M. Forbes d4cdad
+    if (!ioh) {
Justin M. Forbes d4cdad
+        return;
Justin M. Forbes d4cdad
+    }
Justin M. Forbes d4cdad
+
Justin M. Forbes d4cdad
+    ioh->fd_write = NULL;
Justin M. Forbes d4cdad
+}
Justin M. Forbes d4cdad
Justin M. Forbes d4cdad
 /* XXX: fd_read_poll should be suppressed, but an API change is
Justin M. Forbes d4cdad
    necessary in the character devices to suppress fd_can_read(). */
Justin M. Forbes d4cdad
diff --git a/main-loop.h b/main-loop.h
Justin M. Forbes d4cdad
index 8a716b1..c5a96cd 100644
Justin M. Forbes d4cdad
--- a/main-loop.h
Justin M. Forbes d4cdad
+++ b/main-loop.h
Justin M. Forbes d4cdad
@@ -167,6 +167,9 @@ typedef void IOReadHandler(void *opaque, const uint8_t *buf, int size);
Justin M. Forbes d4cdad
 typedef int IOCanReadHandler(void *opaque);
Justin M. Forbes d4cdad
 typedef void IOHandler(void *opaque);
Justin M. Forbes d4cdad
Justin M. Forbes d4cdad
+void enable_write_fd_handler(int fd, IOHandler *fd_write);
Justin M. Forbes d4cdad
+void disable_write_fd_handler(int fd);
Justin M. Forbes d4cdad
+
Justin M. Forbes d4cdad
 /**
Justin M. Forbes d4cdad
  * qemu_set_fd_handler2: Register a file descriptor with the main loop
Justin M. Forbes d4cdad
  *
Justin M. Forbes d4cdad
-- 
Justin M. Forbes d4cdad
1.7.7.5
Justin M. Forbes d4cdad