030 - OpenGrok cross reference for /qemu/tests/qemu-iotests/030

267             for event in self.vm.get_qmp_events(wait=True):
268                 if event['event'] == 'BLOCK_JOB_COMPLETED':
269                     job_id = self.dictpath(event, 'data/device')
271                     self.assert_qmp_absent(event, 'data/error')
374         event = self.vm.event_wait(name='BLOCK_JOB_READY')
375         self.assert_qmp(event, 'data/device', 'commit-drive0')
376         self.assert_qmp(event, 'data/type', 'commit')
377         self.assert_qmp_absent(event, 'data/error')
447             for event in self.vm.get_qmp_events(wait=True):
448                 if event['event'] == 'BLOCK_JOB_COMPLETED':
449                     node_name = self.dictpath(event, 'data/device')
451                     self.assert_qmp_absent(event, 'data/error')
453                 if event['event'] == 'BLOCK_JOB_READY':
454                     self.assert_qmp(event, 'data/device', 'drive0')
455                     self.assert_qmp(event, 'data/type', 'commit')
456                     self.assert_qmp_absent(event, 'data/error')
480             for event in self.vm.get_qmp_events(wait=True):
481                 if event['event'] == 'BLOCK_JOB_COMPLETED':
482                     node_name = self.dictpath(event, 'data/device')
484                     self.assert_qmp_absent(event, 'data/error')
486                 if event['event'] == 'BLOCK_JOB_READY':
487                     self.assert_qmp(event, 'data/device', 'drive0')
488                     self.assert_qmp(event, 'data/type', 'commit')
489                     self.assert_qmp_absent(event, 'data/error')
623     def create_blkdebug_file(self, name, event, errno):  argument
628 event = "%s"
636 event = "%s"
641 event = "%s"
643 ''' % (event, errno, self.STREAM_BUFFER_SIZE // 512, event, event))
672             for event in self.vm.get_qmp_events(wait=True):
673                 if event['event'] == 'BLOCK_JOB_ERROR':
674                     self.assert_qmp(event, 'data/device', 'drive0')
675                     self.assert_qmp(event, 'data/operation', 'read')
677                 elif event['event'] == 'BLOCK_JOB_COMPLETED':
679                     self.assert_qmp(event, 'data/type', 'stream')
680                     self.assert_qmp(event, 'data/device', 'drive0')
681                     self.assert_qmp(event, 'data/error', 'Input/output error')
682                     self.assert_qmp(event, 'data/offset', self.STREAM_BUFFER_SIZE)
683                     self.assert_qmp(event, 'data/len', self.image_len)
685                 elif event['event'] == 'JOB_STATUS_CHANGE':
686                     self.assert_qmp(event, 'data/id', 'drive0')
699             for event in self.vm.get_qmp_events(wait=True):
700                 if event['event'] == 'BLOCK_JOB_ERROR':
702                     self.assert_qmp(event, 'data/device', 'drive0')
703                     self.assert_qmp(event, 'data/operation', 'read')
710                 elif event['event'] == 'BLOCK_JOB_COMPLETED':
712                     self.assert_qmp(event, 'data/type', 'stream')
713                     self.assert_qmp(event, 'data/device', 'drive0')
714                     self.assert_qmp(event, 'data/error', 'Input/output error')
715                     self.assert_qmp(event, 'data/offset', self.image_len)
716                     self.assert_qmp(event, 'data/len', self.image_len)
718                 elif event['event'] == 'JOB_STATUS_CHANGE':
719                     self.assert_qmp(event, 'data/id', 'drive0')
732             for event in self.vm.get_qmp_events(wait=True):
733                 if event['event'] == 'BLOCK_JOB_ERROR':
735                     self.assert_qmp(event, 'data/device', 'drive0')
736                     self.assert_qmp(event, 'data/operation', 'read')
758                 elif event['event'] == 'BLOCK_JOB_COMPLETED':
760                     self.assert_qmp(event, 'data/type', 'stream')
761                     self.assert_qmp(event, 'data/device', 'drive0')
762                     self.assert_qmp_absent(event, 'data/error')
763                     self.assert_qmp(event, 'data/offset', self.image_len)
764                     self.assert_qmp(event, 'data/len', self.image_len)
766                 elif event['event'] == 'JOB_STATUS_CHANGE':
767                     self.assert_qmp(event, 'data/id', 'drive0')
780             for event in self.vm.get_qmp_events(wait=True):
781                 if event['event'] == 'BLOCK_JOB_ERROR':
782                     self.assert_qmp(event, 'data/device', 'drive0')
783                     self.assert_qmp(event, 'data/operation', 'read')
785                 elif event['event'] == 'BLOCK_JOB_COMPLETED':
787                     self.assert_qmp(event, 'data/type', 'stream')
788                     self.assert_qmp(event, 'data/device', 'drive0')
789                     self.assert_qmp(event, 'data/error', 'Input/output error')
790                     self.assert_qmp(event, 'data/offset', self.STREAM_BUFFER_SIZE)
791                     self.assert_qmp(event, 'data/len', self.image_len)
793                 elif event['event'] == 'JOB_STATUS_CHANGE':
794                     self.assert_qmp(event, 'data/id', 'drive0')
825             for event in self.vm.get_qmp_events(wait=True):
826                 if event['event'] == 'BLOCK_JOB_ERROR':
827                     self.assert_qmp(event, 'data/device', 'drive0')
828                     self.assert_qmp(event, 'data/operation', 'read')
851                 elif event['event'] == 'BLOCK_JOB_COMPLETED':
853                     self.assert_qmp(event, 'data/type', 'stream')
854                     self.assert_qmp(event, 'data/device', 'drive0')
855                     self.assert_qmp_absent(event, 'data/error')
856                     self.assert_qmp(event, 'data/offset', self.image_len)
857                     self.assert_qmp(event, 'data/len', self.image_len)
859                 elif event['event'] == 'JOB_STATUS_CHANGE':
860                     self.assert_qmp(event, 'data/id', 'drive0')
892             self.assert_qmp(e, 'event', 'JOB_STATUS_CHANGE')