Revision 09b72783 test/ganeti.utils.process_unittest.py
| b/test/ganeti.utils.process_unittest.py | ||
|---|---|---|
| 155 | 155 |
|
| 156 | 156 |
|
| 157 | 157 |
class _PostforkProcessReadyHelper: |
| 158 |
"""A helper to use with _postfork_fn in RunCmd.
|
|
| 158 |
"""A helper to use with C{postfork_fn} in RunCmd.
|
|
| 159 | 159 |
|
| 160 | 160 |
It makes sure a process has reached a certain state by reading from a fifo. |
| 161 | 161 |
|
| ... | ... | |
| 264 | 264 |
(self.proc_ready_helper.write_fd, self.fifo_file)) |
| 265 | 265 |
result = utils.RunCmd(["/bin/sh", "-c", cmd], timeout=0.2, |
| 266 | 266 |
noclose_fds=[self.proc_ready_helper.write_fd], |
| 267 |
_postfork_fn=self.proc_ready_helper.Ready)
|
|
| 267 |
postfork_fn=self.proc_ready_helper.Ready) |
|
| 268 | 268 |
self.assertEqual(result.exit_code, 0) |
| 269 | 269 |
|
| 270 | 270 |
def testTimeoutKill(self): |
| ... | ... | |
| 276 | 276 |
timeout, [self.proc_ready_helper.write_fd], |
| 277 | 277 |
None, |
| 278 | 278 |
_linger_timeout=0.2, |
| 279 |
_postfork_fn=self.proc_ready_helper.Ready)
|
|
| 279 |
postfork_fn=self.proc_ready_helper.Ready) |
|
| 280 | 280 |
self.assert_(status < 0) |
| 281 | 281 |
self.assertEqual(-status, signal.SIGKILL) |
| 282 | 282 |
|
| ... | ... | |
| 285 | 285 |
(self.proc_ready_helper.write_fd, self.fifo_file)) |
| 286 | 286 |
result = utils.RunCmd(["/bin/sh", "-c", cmd], timeout=0.2, |
| 287 | 287 |
noclose_fds=[self.proc_ready_helper.write_fd], |
| 288 |
_postfork_fn=self.proc_ready_helper.Ready)
|
|
| 288 |
postfork_fn=self.proc_ready_helper.Ready) |
|
| 289 | 289 |
self.assert_(result.failed) |
| 290 | 290 |
self.assertEqual(result.stdout, "sigtermed\n") |
| 291 | 291 |
|
Also available in: Unified diff