From 7e85d15cb61229e9ba1b4a0f1f6c4ab19d436ac7 Mon Sep 17 00:00:00 2001
From: Daniel Silverstone <dsilvers@netsurf-browser.org>
Date: Sat, 12 Mar 2011 15:08:07 +0000
Subject: Add a deaf monkey frontend.  TODO: Make it listen

svn path=/trunk/netsurf/; revision=11968
---
 monkey/poll.c | 108 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 108 insertions(+)
 create mode 100644 monkey/poll.c

(limited to 'monkey/poll.c')

diff --git a/monkey/poll.c b/monkey/poll.c
new file mode 100644
index 000000000..ee7a32d4a
--- /dev/null
+++ b/monkey/poll.c
@@ -0,0 +1,108 @@
+/*
+ * Copyright 2011 Daniel Silverstone <dsilvers@digital-scurf.org>
+ *
+ * This file is part of NetSurf, http://www.netsurf-browser.org/
+ *
+ * NetSurf is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; version 2 of the License.
+ *
+ * NetSurf is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include <assert.h>
+
+#include "desktop/browser.h"
+#include "desktop/gui.h"
+#include "monkey/schedule.h"
+#include "monkey/browser.h"
+#include "content/fetchers/curl.h"
+
+#ifdef DEBUG_POLL_LOOP
+#include "utils/log.h"
+#else
+#define LOG(X)
+#endif
+
+
+#include <glib.h>
+
+void gui_poll(bool active)
+{
+  CURLMcode code;
+  fd_set read_fd_set, write_fd_set, exc_fd_set;
+  int max_fd;
+  GPollFD *fd_list[1000];
+  unsigned int fd_count = 0;
+  bool block = true;
+        
+  if (browser_reformat_pending)
+    block = false;
+
+  if (active) {
+    FD_ZERO(&read_fd_set);
+    FD_ZERO(&write_fd_set);
+    FD_ZERO(&exc_fd_set);
+    code = curl_multi_fdset(fetch_curl_multi,
+                            &read_fd_set,
+                            &write_fd_set,
+                            &exc_fd_set,
+                            &max_fd);
+    assert(code == CURLM_OK);
+    LOG(("maxfd from curl is %d", max_fd));
+    for (int i = 0; i <= max_fd; i++) {
+      if (FD_ISSET(i, &read_fd_set)) {
+        GPollFD *fd = malloc(sizeof *fd);
+        fd->fd = i;
+        fd->events = G_IO_IN | G_IO_HUP | G_IO_ERR;
+        g_main_context_add_poll(0, fd, 0);
+        fd_list[fd_count++] = fd;
+        LOG(("Want to read %d", i));
+      }
+      if (FD_ISSET(i, &write_fd_set)) {
+        GPollFD *fd = malloc(sizeof *fd);
+        fd->fd = i;
+        fd->events = G_IO_OUT | G_IO_ERR;
+        g_main_context_add_poll(0, fd, 0);
+        fd_list[fd_count++] = fd;
+        LOG(("Want to write %d", i));
+      }
+      if (FD_ISSET(i, &exc_fd_set)) {
+        GPollFD *fd = malloc(sizeof *fd);
+        fd->fd = i;
+        fd->events = G_IO_ERR;
+        g_main_context_add_poll(0, fd, 0);
+        fd_list[fd_count++] = fd;
+        LOG(("Want to check %d", i));
+      }
+    }
+  }
+  
+  LOG(("Iterate %sactive %sblocking", active?"":"in", block?"":"non-"));
+  if (block && !active) {
+    fprintf(stdout, "GENERIC POLL BLOCKING\n");
+  }
+  g_main_context_iteration(g_main_context_default(), block && !active);
+
+  for (unsigned int i = 0; i != fd_count; i++) {
+    g_main_context_remove_poll(0, fd_list[i]);
+    free(fd_list[i]);
+  }
+
+  schedule_run();
+
+  if (browser_reformat_pending)
+    monkey_window_process_reformats();
+}
+
+
+void gui_multitask(void)
+{
+  g_main_context_iteration(g_main_context_default(), false);
+}
-- 
cgit v1.2.3