[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