X-Git-Url: http://git.onelab.eu/?p=vsys.git;a=blobdiff_plain;f=dirwatcher.ml;h=53c4c1cddfac4b57d6e00801cf84221738c3cd25;hp=a50416fb72097235219dc513e54b5c7279ce137b;hb=57622e7436de3e40f2dc56b17381eb0bfb18d23c;hpb=7ae75ecaa4e7772450202515acf892685ee6179e

diff --git a/dirwatcher.ml b/dirwatcher.ml
index a50416f..53c4c1c 100644
--- a/dirwatcher.ml
+++ b/dirwatcher.ml
@@ -9,7 +9,6 @@ open Globals
  * leaks - fix implementation of rmdir accordingly
  *)
 let wdmap = Hashtbl.create 1024
-let masks = Hashtbl.create 1024
 
 let fd = Inotify.init ()
 
@@ -18,34 +17,23 @@ let rec list_check lst elt =
     | [] -> false
     | car::cdr -> if (car==elt) then true else list_check cdr elt
 
-let handle_dir_event dirname evlist str = 
-  let fname = String.concat "/" [dirname;str] in
-    logprint "File: %s. " fname;
+let pevlist evlist =
     List.iter 
       (fun e -> 
          logprint "Event: %s\n" (string_of_event e)) 
       evlist
 
+let handle_dir_event dirname evlist str = 
+  let fname = String.concat "/" [dirname;str] in
+    logprint "File: %s. " fname;
+    pevlist evlist
+
 let add_watch dir events handler =
   let wd = Inotify.add_watch fd dir events in
     Hashtbl.add wdmap wd (dir,Some(handler))
       (* Ignore the possibility that the whole directory can disappear and come
        * back while it is masked *)
 
-let mask_watch fqp =
-  try 
-    Hashtbl.replace masks fqp true
-  with _ ->
-    ()
-
-let unmask_watch fqp =
-  if (Hashtbl.mem masks fqp) then
-    begin
-      Hashtbl.remove masks fqp
-    end
-  else
-    logprint "WARNING: %s -- Unpaired unmask\n" fqp
-  
 let asciiz s =
   let rec findfirstnul str idx len =
     if ((idx==len) || 
@@ -67,28 +55,15 @@ let receive_event (eventdescriptor:fname_and_fd) (bla:fname_and_fd) =
                                let (dirname,handler) = 
                                  try Hashtbl.find wdmap wd with Not_found->("",None)
                                in
-                                   match handler with
-                                     | None->logprint "Unhandled watch descriptor\n"
-                                     | Some(handler)->
-                                         let fqp = String.concat "/" [dirname;purestr] in
-                                           logprint "Received event from %s\n" fqp;
-                                         let mask_filter = Hashtbl.mem masks fqp in
-                                           begin
-                                           if ((not mask_filter)) then
-                                             begin
-                                               (*
-                                                logprint "Received event for - %s\n"
-                                                        fqp;*)
-                                                handler wd dirname evlist
-                                                 purestr
-                                             end
-                                           else
-                                             begin
-                                                (*logprint "Unmasking %s\n"
-                                                 * fqp;*)
-                                                unmask_watch fqp
-                                             end
-                                           end
+                                 match handler with
+                                   | None->
+                                       logprint "Unhandled watch descriptor\n"
+                                   | Some(handler)->
+                                       let fqp = String.concat "/" [dirname;purestr] in
+                                         begin
+                                         handler wd dirname evlist
+                                           purestr
+                                         end
                        end
                    | _ -> ()) 
       evs