1 files changed, 57 insertions, 0 deletions
diff --git a/lib/wayland-glib/wl-source.vala b/lib/wayland-glib/wl-source.vala
new file mode 100644
index 0000000..57b9866
--- /dev/null
+++ b/lib/wayland-glib/wl-source.vala
@@ -0,0 +1,57 @@
+namespace WlSource {
+public class WlSource : Source {
+
+  public Wl.Display display;
+  public void* fd;
+  public int error;
+
+  public override bool dispatch(SourceFunc callback) {
+    IOCondition revents = this.query_unix_fd(this.fd);
+    if(this.error > 0 || (revents & (IOCondition.ERR | IOCondition.HUP)) != 0) {
+      errno = this.error;
+      if(callback != null) return callback();
+      return Source.REMOVE;
+    }
+    if(this.display.dispatch_pending() < 0) {
+      if(callback != null) return callback();
+      return Source.REMOVE;
+    }
+    return Source.CONTINUE;
+  }
+
+  public override bool check() {
+    if(this.error > 0) return true;
+    IOCondition revents = this.query_unix_fd(this.fd);
+    if((revents & IOCondition.IN) != 0) {
+      if(this.display.read_events() < 0) {
+        this.error = errno;
+      }
+    }
+    else {
+      this.display.cancel_read();
+    }
+    return revents > 0;
+  }
+
+  public override bool prepare(out int timeout) {
+    timeout = 0;
+    if(this.display.prepare_read() != 0) return true;
+    else if (this.display.flush() < 0 ){
+      this.error = errno;
+      return true;
+    }
+    timeout = -1;
+    return false;
+  }
+
+  public WlSource() {
+    base();
+    this.display = Wl.Display.connect(null);
+    if(this.display == null) return;
+    this.fd = this.add_unix_fd(this.display.get_fd(), IOCondition.IN | IOCondition.ERR | IOCondition.HUP);
+    this.attach(null);
+  }
+
+}
+}
+