Lines Matching full:event

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')