diff --git a/lib/rpc_defs.py b/lib/rpc_defs.py index 13cb0948d63acc6a630e70f4e41617f9765ab55a..f4b0c46a4c2c020a6886cb3dd5586cc86e5d4441 100644 --- a/lib/rpc_defs.py +++ b/lib/rpc_defs.py @@ -105,6 +105,17 @@ def _BlockdevGetMirrorStatusPostProc(result): return result +def _BlockdevGetMirrorStatusMultiPreProc(node, args): + """Prepares the appropriate node values for blockdev_getmirrorstatus_multi. + + """ + # there should be only one argument to this RPC, already holding a + # node->disks dictionary, we just need to extract the value for the + # current node + assert len(args) == 1 + return [args[0][node]] + + def _BlockdevGetMirrorStatusMultiPostProc(result): """Post-processor for L{rpc.RpcRunner.call_blockdev_getmirrorstatus_multi}. @@ -396,7 +407,8 @@ _BLOCKDEV_CALLS = [ "Request status of a (mirroring) device"), ("blockdev_getmirrorstatus_multi", MULTI, TMO_NORMAL, [ ("node_disks", ED_NODE_TO_DISK_DICT, None), - ], None, _BlockdevGetMirrorStatusMultiPostProc, + ], _BlockdevGetMirrorStatusMultiPreProc, + _BlockdevGetMirrorStatusMultiPostProc, "Request status of (mirroring) devices from multiple nodes"), ] diff --git a/lib/server/noded.py b/lib/server/noded.py index b8f848cba14d7a6a034467dad0dfe9e802c6eb9d..22091d7c129d71a0eae8ab041b5f2c0a0bf54d35 100644 --- a/lib/server/noded.py +++ b/lib/server/noded.py @@ -288,10 +288,7 @@ class NodeHttpServer(http.server.HttpServer): """ (node_disks, ) = params - node_name = netutils.Hostname.GetSysName() - - disks = [objects.Disk.FromDict(dsk_s) - for dsk_s in node_disks.get(node_name, [])] + disks = [objects.Disk.FromDict(dsk_s) for dsk_s in node_disks] result = []