(self)
| 372 | ) |
| 373 | |
| 374 | def test_send_all(self): |
| 375 | nodes = [Mock(name='n1'), Mock(name='n2')] |
| 376 | self.cluster.getpids = Mock(name='getpids') |
| 377 | self.cluster.getpids.return_value = nodes |
| 378 | self.cluster.send_all(15) |
| 379 | self.cluster.on_node_signal.assert_has_calls( |
| 380 | call(node, 'TERM') for node in nodes |
| 381 | ) |
| 382 | for node in nodes: |
| 383 | node.send.assert_called_with(15, self.cluster.on_node_signal_dead) |
| 384 | |
| 385 | @t.skip.if_win32 |
| 386 | def test_kill(self): |