SLIDER-86: slider.py non-blocking streaming on all platforms; debugging
Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/f7906fa3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/f7906fa3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/f7906fa3 Branch: refs/heads/feature/SLIDER-86-windows Commit: f7906fa3a6a5fe04113832b747cbe378e5949219 Parents: d51ce5a Author: Steve Loughran <ste...@apache.org> Authored: Wed Sep 10 12:25:41 2014 +0100 Committer: Steve Loughran <ste...@apache.org> Committed: Wed Sep 10 12:25:41 2014 +0100 ---------------------------------------------------------------------- slider-assembly/src/main/scripts/slider.py | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/f7906fa3/slider-assembly/src/main/scripts/slider.py ---------------------------------------------------------------------- diff --git a/slider-assembly/src/main/scripts/slider.py b/slider-assembly/src/main/scripts/slider.py index 4b078e7..735e09b 100644 --- a/slider-assembly/src/main/scripts/slider.py +++ b/slider-assembly/src/main/scripts/slider.py @@ -135,6 +135,7 @@ def runProcess(commandline): :param commandline: command line :return:the return code """ + global finished debug ("Executing : %s" % commandline) exe = subprocess.Popen(commandline, stdin=None, @@ -156,6 +157,7 @@ def runProcess(commandline): # process is running; grab output and echo every line time.sleep(1) debug("completed with exit code : %d" % exe.returncode) + finished = True return exe.returncode
