Revision 063613aa test/py/cmdlib/instance_unittest.py
| b/test/py/cmdlib/instance_unittest.py | ||
|---|---|---|
| 1492 | 1492 |
self.rpc.call_blockdev_assemble.return_value = \ |
| 1493 | 1493 |
self.RpcResultsBuilder() \ |
| 1494 | 1494 |
.CreateSuccessfulNodeResult(self.node, "/dev/mocked_path") |
| 1495 |
self.rpc.call_blockdev_export.return_value = \ |
|
| 1496 |
self.RpcResultsBuilder() \ |
|
| 1497 |
.CreateSuccessfulNodeResult(self.master, "") |
|
| 1498 | 1495 |
self.rpc.call_blockdev_remove.return_value = \ |
| 1499 | 1496 |
self.RpcResultsBuilder() \ |
| 1500 | 1497 |
.CreateSuccessfulNodeResult(self.master, "") |
| 1501 | 1498 |
|
| 1499 |
def ImportStart(node_uuid, opt, inst, component, args): |
|
| 1500 |
return self.RpcResultsBuilder() \ |
|
| 1501 |
.CreateSuccessfulNodeResult(node_uuid, |
|
| 1502 |
"deamon_on_%s" % node_uuid) |
|
| 1503 |
self.rpc.call_import_start.side_effect = ImportStart |
|
| 1504 |
|
|
| 1505 |
def ImpExpStatus(node_uuid, name): |
|
| 1506 |
return self.RpcResultsBuilder() \ |
|
| 1507 |
.CreateSuccessfulNodeResult(node_uuid, |
|
| 1508 |
[objects.ImportExportStatus( |
|
| 1509 |
exit_status=0 |
|
| 1510 |
)]) |
|
| 1511 |
self.rpc.call_impexp_status.side_effect = ImpExpStatus |
|
| 1512 |
|
|
| 1513 |
def ImpExpCleanup(node_uuid, name): |
|
| 1514 |
return self.RpcResultsBuilder() \ |
|
| 1515 |
.CreateSuccessfulNodeResult(node_uuid) |
|
| 1516 |
self.rpc.call_impexp_cleanup.side_effect = ImpExpCleanup |
|
| 1517 |
|
|
| 1502 | 1518 |
def testMissingInstance(self): |
| 1503 | 1519 |
op = opcodes.OpInstanceMove(instance_name="missing.inst", |
| 1504 | 1520 |
target_node=self.node.name) |
| ... | ... | |
| 1540 | 1556 |
target_node=self.node.name) |
| 1541 | 1557 |
self.ExecOpCode(op) |
| 1542 | 1558 |
|
| 1543 |
def testMoveFailingStart(self): |
|
| 1559 |
def testMoveFailingStartInstance(self):
|
|
| 1544 | 1560 |
self.rpc.call_node_info.return_value = \ |
| 1545 | 1561 |
self.RpcResultsBuilder() \ |
| 1546 | 1562 |
.AddSuccessfulNode(self.node, |
| ... | ... | |
| 1557 | 1573 |
self.ExecOpCodeExpectOpExecError( |
| 1558 | 1574 |
op, "Could not start instance .* on node .*") |
| 1559 | 1575 |
|
| 1560 |
def testMoveFailingBlockdevAssemble(self):
|
|
| 1576 |
def testMoveFailingImpExpDaemonExitCode(self):
|
|
| 1561 | 1577 |
inst = self.cfg.AddNewInstance() |
| 1562 |
self.rpc.call_blockdev_assemble.return_value = \ |
|
| 1578 |
self.rpc.call_impexp_status.side_effect = None |
|
| 1579 |
self.rpc.call_impexp_status.return_value = \ |
|
| 1563 | 1580 |
self.RpcResultsBuilder() \ |
| 1564 |
.CreateFailedNodeResult(self.node) |
|
| 1581 |
.CreateSuccessfulNodeResult(self.node, |
|
| 1582 |
[objects.ImportExportStatus( |
|
| 1583 |
exit_status=1, |
|
| 1584 |
recent_output=["mock output"] |
|
| 1585 |
)]) |
|
| 1565 | 1586 |
op = opcodes.OpInstanceMove(instance_name=inst.name, |
| 1566 | 1587 |
target_node=self.node.name) |
| 1567 | 1588 |
self.ExecOpCodeExpectOpExecError(op, "Errors during disk copy") |
| 1568 | 1589 |
|
| 1569 |
def testMoveFailingBlockdevExport(self):
|
|
| 1590 |
def testMoveFailingStartImpExpDaemon(self):
|
|
| 1570 | 1591 |
inst = self.cfg.AddNewInstance() |
| 1571 |
self.rpc.call_blockdev_export.return_value = \ |
|
| 1592 |
self.rpc.call_import_start.side_effect = None |
|
| 1593 |
self.rpc.call_import_start.return_value = \ |
|
| 1572 | 1594 |
self.RpcResultsBuilder() \ |
| 1573 | 1595 |
.CreateFailedNodeResult(self.node) |
| 1574 | 1596 |
op = opcodes.OpInstanceMove(instance_name=inst.name, |
Also available in: Unified diff