X-Git-Url: http://matita.cs.unibo.it/gitweb/?a=blobdiff_plain;f=matitaB%2Fmatita%2FmatitaFilesystem.ml;h=2686fff42991037c26ee03ee09a4f38388bee38e;hb=63397acf074c9fe79704b881f9e5ff5582883465;hp=aef55c3b6428247e68c9d404af45a5c3421612b7;hpb=5952e8ed7a1deffe8766f4ffb4cd6f97ba803d06;p=helm.git diff --git a/matitaB/matita/matitaFilesystem.ml b/matitaB/matita/matitaFilesystem.ml index aef55c3b6..2686fff42 100644 --- a/matitaB/matita/matitaFilesystem.ml +++ b/matitaB/matita/matitaFilesystem.ml @@ -25,6 +25,10 @@ exception SvnError of string;; +let mutex = Mutex.create ();; + +let to_be_committed = ref [];; + let exec_process cmd = let (stdout, stdin, stderr) as chs = Unix.open_process_full cmd [||] in let outlines = ref [] in @@ -48,6 +52,8 @@ let exec_process cmd = errno, output ^ "\n\n" ^ errors | _ -> assert false)) +(* this should be executed only for a freshly created user + * so no CS is needed *) let checkout user = let rt_dir = Helm_registry.get "matita.rt_base_dir" in let repo = Helm_registry.get "matita.weblib" in @@ -64,20 +70,20 @@ let html_of_library uid = let basedir = (Helm_registry.get "matita.rt_base_dir") ^ "/users/" ^ uid in - let branch text acc = + let branch lpath children = let id = newid () in - let name = Filename.basename text in + let name = Filename.basename lpath in let name = if name <> "." then name else "cic:/matita" in - "\n" ^ + "\n" ^ "\n" ^ name ^ "
\n" ^ "\n" ^ - acc ^ "\n" + children ^ "\n
" in - let leaf text = + let leaf lpath = "\n" ^ - "" ^ - (Filename.basename text) ^ "
" + "" ^ + (Filename.basename lpath) ^ "
" in let rec aux path = @@ -111,5 +117,41 @@ let html_of_library uid = let reset_lib () = let to_be_removed = (Helm_registry.get "matita.rt_base_dir") ^ "/users/*" in - Sys.command ("rm -rf " ^ to_be_removed) + ignore (Sys.command ("rm -rf " ^ to_be_removed)) +;; + +(* adds a user to the commit queue; concurrent instances possible, so we + * enclose the update in a CS + *) +let add_user uid = + Mutex.lock mutex; + to_be_committed := uid::List.filter (fun x -> x <> uid) !to_be_committed; + Mutex.unlock mutex; +;; + +(* this function and the next one should only be called by the server itself (or + * the admin) at a scheduled time, so no concurrent instances and no CS needed + * also, svn should already be safe as far as concurrency is concerned *) +let commit user = + let rt_dir = Helm_registry.get "matita.rt_base_dir" in + let repo = Helm_registry.get "matita.weblib" in + + let errno, outstr = exec_process + ("svn ci --message \"commit by user " ^ user ^ "\" " ^ rt_dir ^ "/users/" ^ user ^ "/") + in + if errno = 0 then () + else raise (SvnError outstr) + +let do_global_commit () = + prerr_endline ("to be committed: " ^ String.concat " " !to_be_committed); + List.fold_left + (fun acc u -> + try + commit u; + acc + with + | SvnError outstr -> + prerr_endline outstr; + u::acc) + [] (List.rev !to_be_committed) ;;