directory structure change

git-svn-id: http://svn.irssi.org/repos/irssi-python@4312 dbcabf3a-b0e7-0310-adc4-f8d773084564

1 files changed, 130 insertions, 0 deletions

diff --git a/src/pysource.c b/src/pysource.c
new file mode 100644
index 0000000..413ab2c
--- /dev/null
+++ b/src/pysource.c
@@ -0,0 +1,130 @@
+#include <Python.h>
+#include "pyirssi.h"
+#include "pysource.h"
+
+typedef struct _PY_SOURCE_REC
+{
+    int tag;
+    GSList **tag_list;
+    int fd;
+    PyObject *func;
+    PyObject *data;
+} PY_SOURCE_REC;
+
+static PY_SOURCE_REC *py_source_rec_new(GSList **tag_list, int fd, PyObject *func, PyObject *data)
+{
+    PY_SOURCE_REC *rec;
+
+    rec = g_new0(PY_SOURCE_REC, 1);
+    rec->tag_list = tag_list;
+    rec->fd = fd;
+    rec->func = func;
+    rec->data = data;
+
+    Py_INCREF(func);
+    Py_XINCREF(data);
+
+    return rec;
+}
+
+static int py_remove_tag(GSList **list, int handle)
+{
+    GSList *node;
+
+    node = g_slist_find(*list, GINT_TO_POINTER(handle));
+    if (!node)
+        return 0;
+
+    *list = g_slist_delete_link(*list, node);
+
+    return 1;
+}
+
+static void py_source_destroy(PY_SOURCE_REC *rec)
+{
+    g_return_if_fail(py_remove_tag(rec->tag_list, rec->tag) == 1);
+    Py_DECREF(rec->func);
+    Py_XDECREF(rec->data);
+    g_free(rec);
+}
+
+static int py_handle_ret(PyObject *ret)
+{
+    int res;
+
+    if (!ret)
+    {
+        PyErr_Print();
+        res = FALSE; 
+    }
+    else
+    {
+        res = PyObject_IsTrue(ret);
+        Py_DECREF(ret);
+    }
+
+    return res;
+}
+
+static int py_timeout_proxy(PY_SOURCE_REC *rec)
+{
+    PyObject *ret;
+
+    g_return_val_if_fail(rec != NULL, FALSE);
+    
+    if (rec->data)
+        ret = PyObject_CallFunction(rec->func, "O", rec->data);
+    else
+        ret = PyObject_CallFunction(rec->func, "");
+
+    return py_handle_ret(ret);
+}
+
+static int py_io_proxy(GIOChannel *src, GIOCondition condition, PY_SOURCE_REC *rec)
+{
+    PyObject *ret;
+
+    g_return_val_if_fail(rec != NULL, FALSE);
+
+    if (rec->data)
+        ret = PyObject_CallFunction(rec->func, "iiO", rec->fd, condition, rec->data);
+    else
+        ret = PyObject_CallFunction(rec->func, "ii", rec->fd, condition);
+
+    return py_handle_ret(ret);
+}
+
+int pysource_timeout_add_list(GSList **list, int msecs, PyObject *func, PyObject *data)
+{
+    PY_SOURCE_REC *rec;
+
+    g_return_val_if_fail(func != NULL, -1);
+
+    rec = py_source_rec_new(list, -1, func, data);
+    rec->tag = g_timeout_add_full(G_PRIORITY_DEFAULT, msecs, 
+            (GSourceFunc)py_timeout_proxy, rec, 
+            (GDestroyNotify)py_source_destroy);
+    
+    *list = g_slist_append(*list, GINT_TO_POINTER(rec->tag));
+    
+    return rec->tag;
+}
+
+int pysource_io_add_watch_list(GSList **list, int fd, int cond, PyObject *func, PyObject *data)
+{
+    PY_SOURCE_REC *rec;
+    GIOChannel *channel;
+
+    g_return_val_if_fail(func != NULL, 1);
+
+    rec = py_source_rec_new(list, fd, func, data);
+    channel = g_io_channel_unix_new(fd);
+    rec->tag = g_io_add_watch_full(channel, G_PRIORITY_DEFAULT, cond, 
+            (GIOFunc)py_io_proxy, rec,
+            (GDestroyNotify)py_source_destroy);
+    g_io_channel_unref(channel);
+   
+    *list = g_slist_append(*list, GINT_TO_POINTER(rec->tag));
+    
+    return rec->tag;
+}