X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=resources%2Flibraries%2Fpython%2FQemuUtils.py;h=037d0de58c24ecbb9b1cbb399620c91d0faad521;hb=4b84a3d0620c827aa9bc9c36776af50a88a180f4;hp=a61a11d37a4ed9ebfd64c459db1f34ab35ec2d78;hpb=090fc8fdab1ad817fdcd2c2d82361b64fdf1a7b7;p=csit.git diff --git a/resources/libraries/python/QemuUtils.py b/resources/libraries/python/QemuUtils.py index a61a11d37a..037d0de58c 100644 --- a/resources/libraries/python/QemuUtils.py +++ b/resources/libraries/python/QemuUtils.py @@ -1,4 +1,4 @@ -# Copyright (c) 2018 Cisco and/or its affiliates. +# Copyright (c) 2019 Cisco and/or its affiliates. # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at: @@ -213,7 +213,10 @@ class QemuUtils(object): self._ssh = SSH() self._ssh.connect(node) self._vm_info['host'] = node['host'] - + if node['port'] != 22: + self._vm_info['host_port'] = node['port'] + self._vm_info['host_username'] = node['username'] + self._vm_info['host_password'] = node['password'] arch = Topology.get_node_arch(node) self._qemu_opt['qemu_bin'] = 'qemu-system-{arch}'.format(arch=arch) @@ -251,17 +254,20 @@ class QemuUtils(object): format(qemu_id=self._qemu_id, vhost_id=self._vhost_id))\ if mac is None else mac - queue_size = (',rx_queue_size={queue_size},tx_queue_size={queue_size}'. + queue_size = ('rx_queue_size={queue_size},tx_queue_size={queue_size}'. format(queue_size=self._qemu_opt.get('queue_size')))\ if self._qemu_opt.get('queue_size') else '' + vector_size = ('vectors={vectors}'. + format(vectors=2*self._qemu_opt.get('queue_count')+2))\ + if self._qemu_opt.get('queue_count') else '' # Create Virtio network device. device = (' -device virtio-net-pci,netdev=vhost{vhost_id},mac={mac},' - 'mq=on,csum=off,gso=off,guest_tso4=off,guest_tso6=off,' - 'guest_ecn=off,mrg_rxbuf={mbuf}{queue_size}'. + 'mq=on,{vector_size},csum=off,gso=off,guest_tso4=off,' + 'guest_tso6=off,guest_ecn=off,mrg_rxbuf={mbuf},{queue_size}'. format(vhost_id=self._vhost_id, mac=mac, mbuf='on,host_mtu=9200' if jumbo_frames else 'off', - queue_size=queue_size)) + queue_size=queue_size, vector_size=vector_size)) self._qemu_opt['options'] += device # Add interface MAC and socket to the node dict if_data = {'mac_address': mac, 'socket': socket}