--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/nodejs/X_supp_njs.c	Sat Jun 05 22:24:04 2010 +0800
@@ -0,0 +1,126 @@
+/*! \brief Implement X11 backend for nodejs plugin.
+ *
+ * Since nodejs use libev to handle event loops, part of X11 backend
+ * code can not be used directly.  The part of code should be rewrote.
+ * The part is about
+ */
+#include <stdio.h>
+#include <X11/Xlib.h>
+#include <X11/Xutil.h>
+#include <ev.h>
+#include "mb_X_supp.h"
+#include "mb_tools.h"
+
+#ifndef ASSERT
+#define ASSERT(x)
+#endif
+
+typedef struct _njs_ev_data {
+    ev_io iowatcher;
+    ev_timer tmwatcher;
+    int enable_timer;
+    void *rt;
+} njs_ev_data_t;
+
+static void timer_cb(EV_P_ ev_timer *tmwatcher, int revent);
+
+/*! \brief Register next timeout with libev.
+ */
+static void
+set_next_timeout(njs_ev_data_t *ev_data) {
+    mb_tman_t *tman;
+    mb_timeval_t now, tmo;
+    ev_tstamp tout;
+    int r;
+    
+    tman = X_MB_tman(ev_data->rt);
+    get_now(&now);
+    r = mb_tman_next_timeout(tman, &now, &tmo);
+    if(r == 0) {
+	MB_TIMEVAL_DIFF(&tmo, &now);
+	tout = (ev_tstamp)MB_TIMEVAL_SEC(&tmo) +
+	    (ev_tstamp)MB_TIMEVAL_USEC(&tmo) / 1000000;
+	ev_timer_init(&ev_data->tmwatcher, timer_cb, tout, 0);
+	ev_timer_start(&ev_data->tmwatcher);
+	ev_data->enable_timer = 1;
+    } else
+	ev_data->enable_timer = 0;
+}
+
+static void
+x_conn_cb(EV_P_ ev_io *iowatcher, int revent) {
+    njs_ev_data_t *ev_data = MEM2OBJ(iowatcher, njs_ev_data_t, iowatcher);
+    redraw_man_t *rdman;
+    extern void _X_MB_handle_x_event_for_nodejs(X_MB_runtime_t *rt);
+
+    rdman = X_MB_rdman(ev_data->rt);
+    _X_MB_handle_x_event_for_nodejs(ev_data->rt);
+    rdman_redraw_changed(rdman);
+    
+    if(ev_data->enable_timer == 0) /* no installed timeout */
+	set_next_timeout(ev_data);
+}
+
+static void
+timer_cb(EV_P_ ev_timer *tmwatcher, int revent) {
+    njs_ev_data_t *ev_data = MEM2OBJ(tmwatcher, njs_ev_data_t, tmwatcher);
+    mb_tman_t *tman;
+    redraw_man_t *rdman;
+    mb_timeval_t now;
+    extern int _X_MB_flush_x_conn_nodejs(X_MB_runtime_t *rt);
+    
+    tman = X_MB_tman(ev_data->rt);
+    get_now(&now);
+    mb_tman_handle_timeout(tman, &now);
+
+    rdman = X_MB_rdman(ev_data->rt);
+    rdman_redraw_changed(rdman);
+    _X_MB_flush_x_conn_nodejs(ev_data->rt);
+    
+    set_next_timeout(ev_data);
+}
+
+/*! \brief Handle connection coming data and timeout of timers.
+ *
+ * \param rt is a runtime object for X.
+ */
+void X_MB_handle_connection_njs(void *rt) {
+    X_MB_runtime_t *_rt = (X_MB_runtime_t *)rt;
+    njs_ev_data_t *ev_data;
+    mb_tman_t *tman;
+    mb_timeval_t now, tmo;
+    ev_tstamp tout;
+    int fd;
+    int r;
+    extern int _X_MB_get_x_conn_for_nodejs(X_MB_runtime_t *rt);
+
+    ev_data = (njs_ev_data_t *)malloc(sizeof(njs_ev_data_t));
+    ASSERT(ev_data != NULL);
+    
+    _X_MB_set_data_nodejs(_rt, ev_data);
+    ev_data->rt = _rt;
+    ev_default_loop(0);
+    
+    /*
+     * Setup watcher for X connection.
+     */
+    fd = _X_MB_get_x_conn_for_nodejs(_rt);
+    ev_io_init(&ev_data->iowatcher, x_conn_cb, fd, EV_READ);
+    ev_io_start(&ev_data->iowatcher);
+
+    set_next_timeout(ev_data);
+}
+
+void X_MB_stop_njs(void *rt) {
+    X_MB_runtime_t *_rt = (X_MB_runtime_t *)rt;
+    njs_ev_data_t *ev_data;
+
+    ev_data = (njs_ev_data_t *)_X_MB_get_x_conn_for_nodejs(_rt);
+    
+    /*
+     * stop IO and timer watcher
+     */
+    ev_io_stop(&ev_data->iowatcher);
+    if(ev_data->enable_timer)
+	ev_timer_stop(&ev_data->tmwatcher);
+}