Signed-off-by: Iustin Pop <iustin@google.com>
Reviewed-by: Guido Trotter <ultrotter@google.com>
raise errors.OpExecError("Error during master delay test")
if self.op.on_nodes:
result = self.rpc.call_test_delay(self.op.on_nodes, self.op.duration)
raise errors.OpExecError("Error during master delay test")
if self.op.on_nodes:
result = self.rpc.call_test_delay(self.op.on_nodes, self.op.duration)
- if not result:
- raise errors.OpExecError("Complete failure from rpc call")
for node, node_result in result.items():
for node, node_result in result.items():
- node_result.Raise()
- if not node_result.data:
- raise errors.OpExecError("Failure during rpc call to node %s,"
- " result: %s" % (node, node_result.data))
+ msg = node_result.RemoteFailMsg()
+ if msg:
+ raise errors.OpExecError("Failure during rpc call to node %s: %s"
+ % (node, msg))
class IAllocator(object):
class IAllocator(object):
+ return False, "Invalid sleep duration"
def _CloseFDNoErr(fd, retries=5):
def _CloseFDNoErr(fd, retries=5):