[Swift-commit] r6180 - branches/faster/libexec

hategan at ci.uchicago.edu hategan at ci.uchicago.edu
Tue Jan 29 15:31:49 CST 2013


Author: hategan
Date: 2013-01-29 15:31:49 -0600 (Tue, 29 Jan 2013)
New Revision: 6180

Removed:
   branches/faster/libexec/execute-default.k
   branches/faster/libexec/execute-dryrun.k
   branches/faster/libexec/execute-typecheck.k
Log:
removed dryrun and typecheck modes

Deleted: branches/faster/libexec/execute-default.k
===================================================================
--- branches/faster/libexec/execute-default.k	2013-01-29 21:07:17 UTC (rev 6179)
+++ branches/faster/libexec/execute-default.k	2013-01-29 21:31:49 UTC (rev 6180)
@@ -1,75 +0,0 @@
-element([tr, optional(arguments, stdin, stdout, stderr, attributes, deperror, mdeperror), channel(stagein), channel(stageout), channel(restartout)]
-
-	vdl:initprogressstate()
-
-	done := isDone(restartout)
-	derr := try(deperror, false)
-	merr := try(mdeperror, false)
-
-	if(
-		derr == false then(
-			if(
-				sys:not(done) try(
-					throttled(
-						log(LOG:INFO, "START thread={#thread} tr={tr}")
-						vdl:setprogress("Selecting site")
-						restartOnError(".*", vdl:configProperty("execution.retries"),
-							replicationChannel := channel()
-							discard(append(replicationChannel, true)) //trigger the first job
-							replicationGroup := uid()
-							parallelFor(i, replicationChannel
-								ignoreErrors(match = "^Abort$"
-									execute2(
-										tr, maybe(arguments=unwrapClosedList(arguments)),
-										maybe(stdin=stdin), maybe(stdout=stdout), maybe(stderr=stderr),
-                    maybe(attributes=attributes),
-										stagein, stageout, restartout, replicationGroup, replicationChannel
-									)
-								)
-							)
-						)
-						mark(restartout, err=false, mapping=false)
-						log(LOG:INFO, "END_SUCCESS thread={#thread} tr={tr}")
-						vdl:setprogress("Finished successfully")
-					)
-					catch(".*"
-						log(LOG:INFO, "END_FAILURE thread={#thread} tr={tr}")
-						vdl:setprogress("Failed")
-						if(
-							vdl:configProperty("lazy.errors") == "false" then(
-								throw(exception)
-							)
-							else (
-								to(errors, exception)
-								log(LOG:INFO, exception)
-								echo(exception)
-								mark(restartout, err=true, mapping=false)
-								graphStuff(tr, stagein, stageout, err=true, maybe(args=arguments))
-							)
-						)
-					)
-				)
-				else (
-					vdl:setprogress("Finished in previous run")
-				)
-			)
-		)
-		else (
-			if(
-				merr == true then(
-					exception := exception(concat("VDL2: Application ", str:quote(tr),
-						" not executed due to errors in mapping dependencies"))
-					to(errors, exception)
-					log(LOG:INFO, exception)
-				)
-				derr == true then(
-					exception := exception("VDL2: Application {tr} not executed due to errors in dependencies")
-					to(errors, exception)
-					log(LOG:INFO, exception)
-				)
-			)
-			mark(restartout, err=true, mapping=merr)
-			graphStuff(tr, stagein, stageout, err=true, maybe(args=arguments))
-		)
-	)
-)

Deleted: branches/faster/libexec/execute-dryrun.k
===================================================================
--- branches/faster/libexec/execute-dryrun.k	2013-01-29 21:07:17 UTC (rev 6179)
+++ branches/faster/libexec/execute-dryrun.k	2013-01-29 21:31:49 UTC (rev 6180)
@@ -1,12 +0,0 @@
-element([tr, optional(arguments, stdin, stdout, stderr, deperror), channel(stagein), channel(stageout), channel(restartout)]
-
-	done := isDone(stageout)
-				
-	if(
-		sys:not(done) sequential(
-			mark(stageout, err=false)
-			graphStuff(tr, stagein, stageout, err=false, maybe(args=arguments))
-		)
-	)
-)
-

Deleted: branches/faster/libexec/execute-typecheck.k
===================================================================
--- branches/faster/libexec/execute-typecheck.k	2013-01-29 21:07:17 UTC (rev 6179)
+++ branches/faster/libexec/execute-typecheck.k	2013-01-29 21:31:49 UTC (rev 6180)
@@ -1,3 +0,0 @@
-element([tr, optional(arguments, stdin, stdout, stderr), channel(stagein), channel(stageout), channel(restartout)]
-	mark(stageout, err=false)
-)




More information about the Swift-commit mailing list