Revision c6a9dffa lib/rpc.py
b/lib/rpc.py | ||
---|---|---|
1057 | 1057 |
[dict((name, [dsk.ToDict() for dsk in disks]) |
1058 | 1058 |
for name, disks in node_disks.items())]) |
1059 | 1059 |
for nres in result.values(): |
1060 |
if not nres.fail_msg: |
|
1061 |
nres.payload = [objects.BlockDevStatus.FromDict(i) |
|
1062 |
for i in nres.payload] |
|
1060 |
if nres.fail_msg: |
|
1061 |
continue |
|
1062 |
|
|
1063 |
for idx, (success, status) in enumerate(nres.payload): |
|
1064 |
if success: |
|
1065 |
nres.payload[idx] = (success, objects.BlockDevStatus.FromDict(status)) |
|
1066 |
|
|
1063 | 1067 |
return result |
1064 | 1068 |
|
1065 | 1069 |
@_RpcTimeout(_TMO_NORMAL) |
Also available in: Unified diff