diff options
author | Andreas Rumpf <rumpf_a@web.de> | 2014-11-03 02:02:20 +0100 |
---|---|---|
committer | Andreas Rumpf <rumpf_a@web.de> | 2014-11-03 02:02:20 +0100 |
commit | 01b262d8d1dbeb6847f8d60ff03b57eedd142eb4 (patch) | |
tree | 096889606acfdb02496e70ee6df7de84d268ae84 /lib/pure | |
parent | 65c64fd83a0c360ef2a1125ca7dcca62d4d411c0 (diff) | |
parent | c3a4cc87ca8aac8138da2aa083ac3a68dda98b14 (diff) | |
download | Nim-01b262d8d1dbeb6847f8d60ff03b57eedd142eb4.tar.gz |
Merge pull request #1569 from idlewan/prettyCC
Prettify compiler output for verbosity=1
Diffstat (limited to 'lib/pure')
-rw-r--r-- | lib/pure/osproc.nim | 16 |
1 files changed, 13 insertions, 3 deletions
diff --git a/lib/pure/osproc.nim b/lib/pure/osproc.nim index 0557b26f7..500ec7fb7 100644 --- a/lib/pure/osproc.nim +++ b/lib/pure/osproc.nim @@ -235,11 +235,13 @@ proc countProcessors*(): int {.rtl, extern: "nosp$1".} = proc execProcesses*(cmds: openArray[string], options = {poStdErrToStdOut, poParentStreams}, - n = countProcessors()): int {.rtl, extern: "nosp$1", - tags: [ExecIOEffect, TimeEffect, ReadEnvEffect]} = + n = countProcessors(), + beforeRunEvent: proc(idx: int) = nil): int + {.rtl, extern: "nosp$1", + tags: [ExecIOEffect, TimeEffect, ReadEnvEffect, RootEffect]} = ## executes the commands `cmds` in parallel. Creates `n` processes ## that execute in parallel. The highest return value of all processes - ## is returned. + ## is returned. Runs `beforeRunEvent` before running each command. when defined(posix): # poParentStreams causes problems on Posix, so we simply disable it: var options = options - {poParentStreams} @@ -250,6 +252,8 @@ proc execProcesses*(cmds: openArray[string], newSeq(q, n) var m = min(n, cmds.len) for i in 0..m-1: + if beforeRunEvent != nil: + beforeRunEvent(i) q[i] = startCmd(cmds[i], options=options) when defined(noBusyWaiting): var r = 0 @@ -263,6 +267,8 @@ proc execProcesses*(cmds: openArray[string], echo(err) result = max(waitForExit(q[r]), result) if q[r] != nil: close(q[r]) + if beforeRunEvent != nil: + beforeRunEvent(i) q[r] = startCmd(cmds[i], options=options) r = (r + 1) mod n else: @@ -274,6 +280,8 @@ proc execProcesses*(cmds: openArray[string], #echo(outputStream(q[r]).readLine()) result = max(waitForExit(q[r]), result) if q[r] != nil: close(q[r]) + if beforeRunEvent != nil: + beforeRunEvent(i) q[r] = startCmd(cmds[i], options=options) inc(i) if i > high(cmds): break @@ -282,6 +290,8 @@ proc execProcesses*(cmds: openArray[string], if q[j] != nil: close(q[j]) else: for i in 0..high(cmds): + if beforeRunEvent != nil: + beforeRunEvent(i) var p = startCmd(cmds[i], options=options) result = max(waitForExit(p), result) close(p) |