third-party-mirrors/zfs_autobackup
1
0
Fork 1
mirror of https://github.com/psy0rz/zfs_autobackup.git synced 2025-06-09 01:52:07 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

check exit codes when piping

Browse Source
This commit is contained in:
Edwin Eefting 2020-05-12 17:29:35 +02:00
parent 0813a8cef6
commit 6f6a2ceee2
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
bin/test_executenode.py
View File

@ -69,8 +69,27 @@ class TestExecuteNode(unittest.TestCase):
def pipe(self, nodea, nodeb): def pipe(self, nodea, nodeb):
output=nodea.run(["dd", "if=/dev/zero", "count=1000"], pipe=True) output=nodea.run(["dd", "if=/dev/zero", "count=1000"], pipe=True)
self.assertEqual(nodeb.run(["md5sum"], input=output), ["816df6f64deba63b029ca19d880ee10a -"]) self.assertEqual(nodeb.run(["md5sum"], input=output), ["816df6f64deba63b029ca19d880ee10a -"])
#both ok
output=nodea.run(["true"], pipe=True)
nodeb.run(["true"], input=output)
#TODO: pipe stderr and exitcodes #remote error
with self.assertRaises(subprocess.CalledProcessError):
output=nodea.run(["false"], pipe=True)
nodeb.run(["true"], input=output)
#local error
with self.assertRaises(subprocess.CalledProcessError):
output=nodea.run(["true"], pipe=True)
nodeb.run(["false"], input=output)
#both error
with self.assertRaises(subprocess.CalledProcessError):
output=nodea.run(["true"], pipe=True)
nodeb.run(["false"], input=output)
def test_pipe_local_local(self): def test_pipe_local_local(self):
nodea=ExecuteNode(debug_output=True) nodea=ExecuteNode(debug_output=True)