X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=fdwatcher.ml;fp=fdwatcher.ml;h=3e3142737ae50e21da16f8888495f54676dfe29c;hb=2955cde23cac50c0ad569745974746993b171524;hp=0000000000000000000000000000000000000000;hpb=0cde795f81e9daba10f22018a4edb36685f412d1;p=vsys.git

diff --git a/fdwatcher.ml b/fdwatcher.ml
new file mode 100644
index 0000000..3e31427
--- /dev/null
+++ b/fdwatcher.ml
@@ -0,0 +1,32 @@
+open Printf
+open Globals
+
+let fdset = ref []
+let cbtable = Hashtbl.create 1024
+
+(* The in descriptor is always open. Thanks to the broken semantics of
+ * fifo outputs, the out descriptor must be opened a nouveau whenever we
+ * want to send out data, and so we keep the associated filename as well.
+ * Same with input fifos. Yipee.*)
+
+let add_fd (evpair:fd_and_fname) (fd_other:fd_and_fname) (callback:fd_and_fname->fd_and_fname->unit) = 
+  let (fname,fd) = evpair in
+  fdset := (fd::!fdset);
+  Hashtbl.replace cbtable fd (callback,(evpair,fd_other))
+
+let del_fd fd =
+  fdset:=List.filter (fun l->l<>fd) !fdset;
+  flush Pervasives.stdout
+
+let start_watch () =
+    while (true)
+    do
+              let (fds,_,_) = try Unix.select !fdset [] [] (-1.) 
+              with e->
+                ([],[],[])
+              in
+                List.iter (fun elt->
+                             let (func,(evd,fd_other)) = Hashtbl.find cbtable elt in
+                               func evd fd_other) fds
+    done
+