Add a deaf monkey frontend. TODO: Make it listen

svn path=/trunk/netsurf/; revision=11968

1 files changed, 108 insertions, 0 deletions

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);
+}