X-Git-Url: http://matita.cs.unibo.it/gitweb/?a=blobdiff_plain;f=helm%2Fhttp_getter%2Fhttp_getter_map.ml;h=b7ac1c605d7a4d435f9642205dd1a315e07fc2c6;hb=1c7fb836e2af4f2f3d18afd0396701f2094265ff;hp=9ee87618104003943e0f49484c7e98be736a1a0a;hpb=86e80bc65186bf4c2824dc94f5f4dd5966843f14;p=helm.git diff --git a/helm/http_getter/http_getter_map.ml b/helm/http_getter/http_getter_map.ml index 9ee876181..b7ac1c605 100644 --- a/helm/http_getter/http_getter_map.ml +++ b/helm/http_getter/http_getter_map.ml @@ -1,5 +1,7 @@ (* - * Copyright (C) 2000, HELM Team. + * Copyright (C) 2003: + * Stefano Zacchiroli + * for the HELM Team http://helm.cs.unibo.it/ * * This file is part of HELM, an Hypertextual, Electronic * Library of Mathematics, developed at the Computer Science @@ -21,7 +23,7 @@ * MA 02111-1307, USA. * * For details, see the HELM World-Wide-Web page, - * http://cs.unibo.it/helm/. + * http://helm.cs.unibo.it/ *) exception Key_already_in of string;; @@ -29,12 +31,15 @@ exception Key_not_found of string;; class map dbname = let perm = 420 in (* permission 644 in decimal notation *) - let db = Dbm.opendbm dbname [ Dbm.Dbm_rdwr; Dbm.Dbm_create ] perm in + let open_dbm () = Dbm.opendbm dbname [ Dbm.Dbm_rdwr; Dbm.Dbm_create ] perm in + object (self) inherit ThreadSafe.threadSafe - initializer Gc.finalise Dbm.close db (* close db on GC *) + val mutable db = open_dbm () + + (*initializer Gc.finalise Dbm.close db (* close db on GC *)*) method add key value = self#doWriter (lazy ( @@ -43,6 +48,11 @@ class map dbname = with Dbm.Dbm_error "Entry already exists" -> raise (Key_already_in key) )) + method replace key value = + self#doWriter (lazy ( + Dbm.replace db key value + )) + method remove key = self#doWriter (lazy ( try @@ -60,9 +70,26 @@ class map dbname = Dbm.iter f db )) + method sync = + self#doWriter (lazy ( + Dbm.close db; + db <- open_dbm () + )) + method clear = self#doWriter (lazy ( - Dbm.iter (fun k _ -> Dbm.remove db k) db + Dbm.close db; + List.iter + (fun ext -> + let file = dbname ^ ext in + if Sys.file_exists file then Sys.remove file) + [".dir"; ".pag"; ".db"]; + db <- open_dbm () + )) + + method close = + self#doWriter (lazy ( + Dbm.close db )) end