[interchange-cvs] interchange - racke modified lib/Vend/Dispatch.pm

[interchange-cvs at icdevgroup.org]

User:      racke
Date:      2005-10-04 10:53:35 GMT
Modified:  lib/Vend Dispatch.pm
Log:
trackdb option added to keep track of your jobs

Revision  Changes    Path
1.58      +20 -2     interchange/lib/Vend/Dispatch.pm


rev 1.58, prev_rev 1.57
Index: Dispatch.pm
===================================================================
RCS file: /anon_cvs/repository/interchange/lib/Vend/Dispatch.pm,v
retrieving revision 1.57
retrieving revision 1.58
diff -u -r1.57 -r1.58
--- Dispatch.pm	27 Jul 2005 09:37:26 -0000	1.57
+++ Dispatch.pm	4 Oct 2005 10:53:34 -0000	1.58
@@ -1,6 +1,6 @@
 # Vend::Dispatch - Handle Interchange page requests
 #
-# $Id: Dispatch.pm,v 1.57 2005/07/27 09:37:26 racke Exp $
+# $Id: Dispatch.pm,v 1.58 2005/10/04 10:53:34 racke Exp $
 #
 # Copyright (C) 2002-2005 Interchange Development Group
 # Copyright (C) 2002 Mike Heins <mike at perusion.net>
@@ -26,7 +26,7 @@
 package Vend::Dispatch;
 
 use vars qw($VERSION);
-$VERSION = substr(q$Revision: 1.57 $, 10);
+$VERSION = substr(q$Revision: 1.58 $, 10);
 
 use POSIX qw(strftime);
 use Vend::Util;
@@ -751,6 +751,19 @@
 	undef $Vend::Session;
 	
 	if(@itl) {
+		# Track job
+		my ($trackdb, $trackid);
+		
+		if ($jobscfg->{trackdb}) {
+			if ($trackdb = database_exists_ref($jobscfg->{trackdb})) {
+				$trackid = $trackdb->set_slice('', [qw(name begin_run pid)],
+											   [$job, Vend::Interpolate::mvtime(undef, {}, '%Y-%m-%d %H:%M'), $$]);
+			}
+			else {
+				::logError ("Invalid jobs tracking database $jobscfg->{trackdb}");
+			}
+		}
+		
 		# Run once at beginning
 		run_macro($jobscfg->{initialize});
 
@@ -772,6 +785,11 @@
 
 			# Run once at end of each job
 			run_macro($jobscfg->{autoend});
+		}
+
+		if ($trackid) {
+			$trackdb->set_field($trackid, 'end_run',
+								Vend::Interpolate::mvtime(undef, {}, '%Y-%m-%d %H:%M'));
 		}
 	}
 	else {