Lines Matching full:stream

59         self.vm.cmd('block-stream', device='drive0')
79 self.vm.cmd('block-stream', device='mid', job_id='stream-mid')
81 self.wait_until_completed(drive='stream-mid')
95 self.vm.cmd('block-stream', device='drive0')
128 self.vm.cmd('block-stream', device='drive0', base=mid_img)
142 self.vm.cmd('block-stream', device='drive0', base=backing_img)
155 result = self.vm.qmp('block-stream', device='nonexistent')
160 result = self.vm.qmp('block-stream', device='mid')
180 result = self.vm.qmp('block-stream', job_id='stream',
188 num_ops = 4 # Number of parallel block-stream operations
230 # Test that it's possible to run several block-stream operations
247 job_id = 'stream-%s' % node_name
249 self.vm.cmd('block-stream', device=node_name,
284 # Test that it's not possible to perform two block-stream
290 self.vm.cmd('block-stream', device='node4',
291 job_id='stream-node4', base=self.imgs[1],
292 filter_node_name='stream-filter', speed=1024*1024)
294 … result = self.vm.qmp('block-stream', device='node5', job_id='stream-node5', base=self.imgs[2])
296 "Node 'stream-filter' is busy: block device is in use by block job: stream")
298 … result = self.vm.qmp('block-stream', device='node3', job_id='stream-node3', base=self.imgs[2])
300 "Node 'node3' is busy: block device is in use by block job: stream")
302 result = self.vm.qmp('block-stream', device='node4', job_id='stream-node4-v2')
304 "Node 'node4' is busy: block device is in use by block job: stream")
306 # block-commit should also fail if it touches nodes used by the stream job
309 "Node 'stream-filter' is busy: block device is in use by block job: stream")
313 "Node 'node3' is busy: block device is in use by block job: stream")
318 "Node 'node2' is busy: block device is in use by block job: stream")
320 self.vm.cmd('block-job-set-speed', device='stream-node4', speed=0)
322 self.wait_until_completed(drive='stream-node4')
334 result = self.vm.qmp('block-stream', device='node3', job_id='stream-node3')
338 … result = self.vm.qmp('block-stream', device='node6', base=self.imgs[2], job_id='stream-node6')
342 … result = self.vm.qmp('block-stream', device='node4', base=self.imgs[2], job_id='stream-node4')
346 … result = self.vm.qmp('block-stream', device='node6', base=self.imgs[4], job_id='stream-node6-v2')
351 … result = self.vm.qmp('block-stream', device='drive0', base=self.imgs[5], job_id='stream-drive0')
368 … result = self.vm.qmp('block-stream', device='node5', base=self.imgs[3], job_id='stream-node6')
383 # In this case the base node of the stream job is the same as the
385 # node being part of the stream chain, this is not allowed.
394 # Stream from node2 into node4
395 result = self.vm.qmp('block-stream', device='node4', base_node='node2', job_id='node4')
404 # In this case the base node of the stream job is the commit job's
405 # filter node. stream does not have a real dependency on its base
416 # Stream from node2 into node4
417 self.vm.cmd('block-stream', device='node4',
431 # Test a block-stream and a block-commit job in parallel
432 # Here the stream job is supposed to finish quickly in order to reproduce
438 # Stream from node0 into node2
439 self.vm.cmd('block-stream', device='node2', base_node='node0', job_id='node2')
468 # Stream from node0 into node4
469 … self.vm.cmd('block-stream', device='node4', base_node='node0', job_id='node4', speed=1024*1024)
505 result = self.vm.qmp('block-stream', device='node4', base_node='none', job_id='stream')
510 result = self.vm.qmp('block-stream', device='node4', base_node='node6', job_id='stream')
515 result = self.vm.qmp('block-stream', device='node4', base_node='node4', job_id='stream')
520 …result = self.vm.qmp('block-stream', device='node4', base=self.imgs[2], base_node='node2', job_id=…
525 self.vm.cmd('block-stream', device='node4', base_node='node2', job_id='stream')
527 self.wait_until_completed(drive='stream')
581 self.vm.cmd('block-stream', device='node0', job_id='stream-node0')
583 self.wait_until_completed(drive='stream-node0')
610 self.vm.cmd('block-stream', device='drive0')
620 # this should match STREAM_BUFFER_SIZE/512 in block/stream.c
667 self.vm.cmd('block-stream', device='drive0')
679 self.assert_qmp(event, 'data/type', 'stream')
694 self.vm.cmd('block-stream', device='drive0', on_error='ignore')
712 self.assert_qmp(event, 'data/type', 'stream')
727 self.vm.cmd('block-stream', device='drive0', on_error='stop')
760 self.assert_qmp(event, 'data/type', 'stream')
775 self.vm.cmd('block-stream', device='drive0', on_error='enospc')
787 self.assert_qmp(event, 'data/type', 'stream')
820 self.vm.cmd('block-stream', device='drive0', on_error='enospc')
853 self.assert_qmp(event, 'data/type', 'stream')
887 self.vm.cmd('block-stream', device='drive0')
920 self.vm.cmd('block-stream', device='drive0')
932 self.vm.cmd('block-stream', device='drive0')
949 # Check setting speed in block-stream works
950 self.vm.cmd('block-stream', device='drive0', speed=4 * 1024 * 1024)
961 result = self.vm.qmp('block-stream', device='drive0', speed=-1)
967 self.vm.cmd('block-stream', device='drive0')