This commit was generated by cvs2svn to compensate for changes in r2,

[vsys.git] / dirwatcher.ml

diff --git a/dirwatcher.ml b/dirwatcher.ml
new file mode 100644 (file)
index 0000000..5bd4d6c
--- /dev/null
+++ b/dirwatcher.ml
@@ -0,0 +1,56 @@
+open Inotify
+open Fdwatcher
+open Printf
+open Globals
+
+(* I don't know if a wd corresponding to a deleted directory is evicted or just
+ * leaks - fix implementation of rmdir accordingly
+ *)
+
+let wdmap = Hashtbl.create 1024
+
+let fd = Inotify.init ()
+
+let handle_dir_event dirname evlist str = 
+    let fname = String.concat "/" [dirname;str] in
+        printf "File: %s. " fname;List.iter 
+                  (fun e -> 
+                     printf "Event: %s\n" (string_of_event e)) 
+                  evlist;
+        flush Pervasives.stdout
+
+let add_watch dir events handler =
+  printf "Adding watch for %s\n" dir;
+  let wd = Inotify.add_watch fd dir events in
+      Hashtbl.add wdmap wd (dir,handler)
+
+let asciiz s =
+  let rec findfirstnul str idx len =
+    if ((idx==len) || 
+      (str.[idx]==(char_of_int 0))) then idx
+      else
+        findfirstnul str (idx+1) len
+  in
+  let nulterm = findfirstnul s 0 (String.length s) in
+    String.sub s 0 nulterm
+
+let receive_event (eventdescriptor:fd_and_fname) (bla:fd_and_fname) =
+  let (_,fd) = eventdescriptor in
+      let evs = Inotify.read fd in
+        List.iter (fun x->
+                match x with
+                  | (wd,evlist,_,Some(str)) ->
+                      let purestr = asciiz(str) in
+                      let (dirname,handler) = 
+                        try Hashtbl.find wdmap wd with Not_found->printf "Unknown watch descriptor\n";raise Not_found
+                      in
+                        (
+                        match handler with
+                          | None->handle_dir_event dirname evlist purestr
+                          | Some(handler)->handler dirname evlist purestr
+                        )
+                  | _ -> ()) 
+          evs
+
+let initialize () =
+  Fdwatcher.add_fd (None,fd) (None,fd) receive_event