X-Git-Url: http://git.annexia.org/?p=whenjobs.git;a=blobdiff_plain;f=lib%2Fwhenexpr.mli;h=73103870624372596a0a4c4e71afeae2c90acaed;hp=f1b8e2e5a17439af2291f439d30314005c9d0a61;hb=2ce29ff559f9bc36733ab2dde5b657eaa76ea8a6;hpb=cffe87109d9c868eefd48f7d5255a4863a578e4d

diff --git a/lib/whenexpr.mli b/lib/whenexpr.mli
index f1b8e2e..7310387 100644
--- a/lib/whenexpr.mli
+++ b/lib/whenexpr.mli
@@ -60,18 +60,6 @@ type shell_script = {
 }
 (** A shell script. *)
 
-type result = {
-  res_job_name : string;                (** Job name. *)
-  res_serial : Big_int.big_int;         (** Job serial number. *)
-  res_code : int;                       (** Return code from the script. *)
-  res_tmpdir : string;                  (** Temporary directory. *)
-  res_output : string;                  (** Filename of output from job. *)
-}
-(** Result of the run of a job. *)
-
-type cleanup = result -> unit
-(** A cleanup function. *)
-
 type variable =
   | T_unit
   | T_bool of bool
@@ -88,6 +76,34 @@ val rpc_of_variable : variable -> Whenproto_aux.variable
 type variables = variable Whenutils.StringMap.t
 (** A set of variables. *)
 
+type preinfo = {
+  pi_job_name : string;                 (** Job name. *)
+  pi_serial : Big_int.big_int;          (** Job serial number. *)
+  pi_variables : (string * variable) list; (** Variables set in job. *)
+  pi_running : preinfo_running_job list; (** List of running jobs. *)
+}
+and preinfo_running_job = {
+  pirun_job_name : string;              (** Running job name. *)
+  pirun_serial : Big_int.big_int;       (** Running job serial number. *)
+  pirun_start_time : float;             (** Running job start time. *)
+  pirun_pid : int;                      (** Running job process ID. *)
+}
+(** Information available to pre function before the job runs. *)
+
+type result = {
+  res_job_name : string;                (** Job name. *)
+  res_serial : Big_int.big_int;         (** Job serial number. *)
+  res_code : int;                       (** Return code from the script. *)
+  res_tmpdir : string;                  (** Temporary directory. *)
+  res_output : string;                  (** Filename of output from job. *)
+  res_start_time : float;               (** When the job started. *)
+}
+(** Result of the run of a job. *)
+
+type pre = preinfo -> bool
+type post = result -> unit
+(** Pre and post functions. *)
+
 type job_cond =
   | When_job of whenexpr                (** when ... : << >> *)
   | Every_job of periodexpr             (** every ... : << >> *)
@@ -95,7 +111,8 @@ type job_cond =
 type job = {
   job_loc : Camlp4.PreCast.Loc.t;
   job_name : string;
-  job_cleanup : cleanup option;
+  job_pre : pre option;
+  job_post : post option;
   job_cond : job_cond;
   job_script : shell_script;
 }