iotests: change qmp_log filters to expect QMP objects only
As laid out in the previous commit's message: ``` Several places in iotests deal with serializing objects into JSON strings, but to add pretty-printing it seems desirable to localize all of those cases. log() seems like a good candidate for that centralized behavior. log() can already serialize json objects, but when it does so, it assumes filters=[] operates on QMP objects, not strings. qmp_log currently operates by dumping outgoing and incoming QMP objects into strings and filtering them assuming that filters=[] are string filters. ``` Therefore: Change qmp_log to treat filters as if they're always qmp object filters, then change the logging call to rely on log()'s ability to serialize QMP objects, so we're not duplicating that effort. Add a qmp version of filter_testfiles and adjust the only caller using it for qmp_log to use the qmp version. Signed-off-by: John Snow <jsnow@redhat.com> Message-Id: <20181221093529.23855-10-jsnow@redhat.com> Reviewed-by: Vladimir Sementsov-Ogievskiy <vsementsov@virtuozzo.com> Signed-off-by: Eric Blake <eblake@redhat.com>
This commit is contained in:
parent
f8ca8609d8
commit
08fcd6111e
@ -27,7 +27,7 @@ iotests.verify_image_format(supported_fmts=['qcow2'])
|
|||||||
|
|
||||||
def blockdev_create(vm, options):
|
def blockdev_create(vm, options):
|
||||||
result = vm.qmp_log('blockdev-create',
|
result = vm.qmp_log('blockdev-create',
|
||||||
filters=[iotests.filter_testfiles],
|
filters=[iotests.filter_qmp_testfiles],
|
||||||
job_id='job0', options=options)
|
job_id='job0', options=options)
|
||||||
|
|
||||||
if 'return' in result:
|
if 'return' in result:
|
||||||
@ -55,7 +55,7 @@ with iotests.FilePath('t.qcow2') as disk_path, \
|
|||||||
'size': 0 })
|
'size': 0 })
|
||||||
|
|
||||||
vm.qmp_log('blockdev-add',
|
vm.qmp_log('blockdev-add',
|
||||||
filters=[iotests.filter_testfiles],
|
filters=[iotests.filter_qmp_testfiles],
|
||||||
driver='file', filename=disk_path,
|
driver='file', filename=disk_path,
|
||||||
node_name='imgfile')
|
node_name='imgfile')
|
||||||
|
|
||||||
|
@ -246,10 +246,33 @@ def filter_qmp_event(event):
|
|||||||
event['timestamp']['microseconds'] = 'USECS'
|
event['timestamp']['microseconds'] = 'USECS'
|
||||||
return event
|
return event
|
||||||
|
|
||||||
|
def filter_qmp(qmsg, filter_fn):
|
||||||
|
'''Given a string filter, filter a QMP object's values.
|
||||||
|
filter_fn takes a (key, value) pair.'''
|
||||||
|
# Iterate through either lists or dicts;
|
||||||
|
if isinstance(qmsg, list):
|
||||||
|
items = enumerate(qmsg)
|
||||||
|
else:
|
||||||
|
items = qmsg.items()
|
||||||
|
|
||||||
|
for k, v in items:
|
||||||
|
if isinstance(v, list) or isinstance(v, dict):
|
||||||
|
qmsg[k] = filter_qmp(v, filter_fn)
|
||||||
|
else:
|
||||||
|
qmsg[k] = filter_fn(k, v)
|
||||||
|
return qmsg
|
||||||
|
|
||||||
def filter_testfiles(msg):
|
def filter_testfiles(msg):
|
||||||
prefix = os.path.join(test_dir, "%s-" % (os.getpid()))
|
prefix = os.path.join(test_dir, "%s-" % (os.getpid()))
|
||||||
return msg.replace(prefix, 'TEST_DIR/PID-')
|
return msg.replace(prefix, 'TEST_DIR/PID-')
|
||||||
|
|
||||||
|
def filter_qmp_testfiles(qmsg):
|
||||||
|
def _filter(key, value):
|
||||||
|
if key == 'filename' or key == 'backing-file':
|
||||||
|
return filter_testfiles(value)
|
||||||
|
return value
|
||||||
|
return filter_qmp(qmsg, _filter)
|
||||||
|
|
||||||
def filter_generated_node_ids(msg):
|
def filter_generated_node_ids(msg):
|
||||||
return re.sub("#block[0-9]+", "NODE_NAME", msg)
|
return re.sub("#block[0-9]+", "NODE_NAME", msg)
|
||||||
|
|
||||||
@ -465,10 +488,9 @@ class VM(qtest.QEMUQtestMachine):
|
|||||||
("execute", cmd),
|
("execute", cmd),
|
||||||
("arguments", ordered_kwargs(kwargs))
|
("arguments", ordered_kwargs(kwargs))
|
||||||
))
|
))
|
||||||
logmsg = json.dumps(full_cmd)
|
log(full_cmd, filters)
|
||||||
log(logmsg, filters)
|
|
||||||
result = self.qmp(cmd, **kwargs)
|
result = self.qmp(cmd, **kwargs)
|
||||||
log(json.dumps(result, sort_keys=True), filters)
|
log(result, filters)
|
||||||
return result
|
return result
|
||||||
|
|
||||||
def run_job(self, job, auto_finalize=True, auto_dismiss=False):
|
def run_job(self, job, auto_finalize=True, auto_dismiss=False):
|
||||||
|
Loading…
Reference in New Issue
Block a user