X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=sidebyside;f=src%2Fnepi%2Fresources%2Flinux%2Fapplication.py;h=86cf9c980c96b62630c33dd8671a5560ce3d6d7e;hb=2f73c5b427909b016a438b372d17fb15d2d51ede;hp=4a90392c6a405e334583dbdc0759dc37d290175d;hpb=6b78e1443aca048bea0848855e81b5690e63c011;p=nepi.git diff --git a/src/nepi/resources/linux/application.py b/src/nepi/resources/linux/application.py index 4a90392c..86cf9c98 100644 --- a/src/nepi/resources/linux/application.py +++ b/src/nepi/resources/linux/application.py @@ -107,19 +107,19 @@ class LinuxApplication(ResourceManager): "cleanHome is set to True (This will delete all sources). ", flags = Flags.Design) files = Attribute("files", - "Space-separated list of regular miscellaneous files to be uploaded " + "semi-colon separated list of regular miscellaneous files to be uploaded " "to ${SHARE} directory. " "Files are globally available for all experiments unless " "cleanHome is set to True (This will delete all files). ", flags = Flags.Design) libs = Attribute("libs", - "Space-separated list of libraries (e.g. .so files) to be uploaded " + "semi-colon separated list of libraries (e.g. .so files) to be uploaded " "to ${LIB} directory. " "Libraries are globally available for all experiments unless " "cleanHome is set to True (This will delete all files). ", flags = Flags.Design) bins = Attribute("bins", - "Space-separated list of binary files to be uploaded " + "semi-colon separated list of binary files to be uploaded " "to ${BIN} directory. " "Binaries are globally available for all experiments unless " "cleanHome is set to True (This will delete all files). ", @@ -282,10 +282,11 @@ class LinuxApplication(ResourceManager): procs = dict() ps_aux = "ps aux |awk '{print $2,$11}'" (out, err), proc = self.node.execute(ps_aux) - for line in out.strip().split("\n"): - parts = line.strip().split(" ") - procs[parts[0]] = parts[1] - pickle.dump(procs, open("/tmp/save.proc", "wb")) + if len(out) != 0: + for line in out.strip().split("\n"): + parts = line.strip().split(" ") + procs[parts[0]] = parts[1] + pickle.dump(procs, open("/tmp/save.proc", "wb")) # create run dir for application self.node.mkdir(self.run_home) @@ -359,6 +360,13 @@ class LinuxApplication(ResourceManager): def execute_deploy_command(self, command, prefix="deploy"): if command: + # replace application specific paths in the command + command = self.replace_paths(command) + + # replace application specific paths in the environment + env = self.get("env") + env = env and self.replace_paths(env) + # Upload the command to a bash script and run it # in background ( but wait until the command has # finished to continue ) @@ -637,11 +645,15 @@ class LinuxApplication(ResourceManager): def do_release(self): self.info("Releasing resource") + self.do_stop() + tear_down = self.get("tearDown") if tear_down: self.node.execute(tear_down) - self.do_stop() + hard_release = self.get("hardRelease") + if hard_release: + self.node.rmdir(self.app_home) super(LinuxApplication, self).do_release()