ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

scripts/nvmf: Distribute all disk between all NICs

Browse Source 
Signed-off-by: Maciej Wawryk <maciejx.wawryk@intel.com>
Change-Id: I72fc8cb42f57d3272a08a6cefc58b2fa5eb26419
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/11094
Reviewed-by: Konrad Sztyber <konrad.sztyber@intel.com>
Reviewed-by: Karol Latecki <karol.latecki@intel.com>
Reviewed-by: Tomasz Zawadzki <tomasz.zawadzki@intel.com>
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Community-CI: Broadcom CI <spdk-ci.pdl@broadcom.com>
This commit is contained in:
Maciej Wawryk 2022-01-14 13:00:03 +01:00 committed by Tomasz Zawadzki
parent 95d710dddc
commit 9cf27937df
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
scripts/perf/nvmf/run_nvmf.py
View File

@ -969,6 +969,10 @@ class KernelTarget(Target):
disks_per_ip = int(len(nvme_list) / len(address_list)) disks_per_ip = int(len(nvme_list) / len(address_list))
disk_chunks = [nvme_list[i * disks_per_ip:disks_per_ip + disks_per_ip * i] for i in range(0, len(address_list))] disk_chunks = [nvme_list[i * disks_per_ip:disks_per_ip + disks_per_ip * i] for i in range(0, len(address_list))]
# Add remaining drives
for i, disk in enumerate(nvme_list[disks_per_ip * len(address_list):]):
disks_chunks[i].append(disk)
subsys_no = 1 subsys_no = 1
port_no = 0 port_no = 0
for ip, chunk in zip(address_list, disk_chunks): for ip, chunk in zip(address_list, disk_chunks):
@ -1143,7 +1147,11 @@ class SPDKTarget(Target):
disks_per_ip = 1 disks_per_ip = 1
else: else:
disks_per_ip = int(len(num_disks) / len(ips)) disks_per_ip = int(len(num_disks) / len(ips))
disk_chunks = [num_disks[i * disks_per_ip:disks_per_ip + disks_per_ip * i] for i in range(0, len(ips))] disk_chunks = [[*num_disks[i * disks_per_ip:disks_per_ip + disks_per_ip * i]] for i in range(0, len(ips))]
# Add remaining drives
for i, disk in enumerate(num_disks[disks_per_ip * len(ips):]):
disk_chunks[i].append(disk)
# Create subsystems, add bdevs to namespaces, add listeners # Create subsystems, add bdevs to namespaces, add listeners
for ip, chunk in zip(ips, disk_chunks): for ip, chunk in zip(ips, disk_chunks):