--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/dbfs/interrupt.c	Tue Nov 18 01:55:13 2008 +0200
@@ -0,0 +1,37 @@
+
+#include "dbfs.h"
+
+void dbfs_interrupt_query (struct fuse_req *req, void *query_ptr) {
+    struct evsql_query *query = query_ptr;
+    err_t err;
+
+    // abort
+    evsql_query_abort(NULL, query);
+
+    // error the req
+    if ((err = -fuse_reply_err(req, EINTR)))
+        PWARNING("fuse_reply_err", err);
+}
+
+void _dbfs_interrupt_ctx (struct fuse_req *req, void *ctx_ptr) {
+    // dereference ctx
+    struct dbfs_interrupt_ctx *ctx = ctx_ptr;
+    
+    // just cancel query if pending
+    if (ctx->query) {
+        evsql_query_abort(NULL, ctx->query);
+        ctx->query = NULL;
+    }
+
+    // mark as interrupted
+    ctx->interrupted = 1;
+}
+
+int dbfs_interrupt_register (struct fuse_req *req, struct dbfs_interrupt_ctx *ctx) {
+    // initialize
+    ctx->query = NULL;
+    ctx->interrupted = 0;
+
+    // just pass over to fuse_req_interrupt_func
+    fuse_req_interrupt_func(req, _dbfs_interrupt_ctx, ctx);
+}