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

scripts/nvmf_perf: enable BW monitoring by default

Browse Source 
bwm-ng interface bandwidth monitoring is now enabled
by default. Samples are captured  every second during
fio run_time duration.

Change-Id: I868f01d23e648e855161e6711236a68dcff8ff5a
Signed-off-by: Karol Latecki <karol.latecki@intel.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/15340
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Tomasz Zawadzki <tomasz.zawadzki@intel.com>
Reviewed-by: Konrad Sztyber <konrad.sztyber@intel.com>
Reviewed-by: Michal Berger <michal.berger@intel.com>
This commit is contained in:
Karol Latecki 2022-11-08 14:09:22 +01:00 committed by Tomasz Zawadzki
parent 90b95e2813
commit b9403ae58b
2 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
scripts/perf/nvmf/README.md
View File

@ -28,6 +28,7 @@ To run the scripts in your environment please follow steps below.
If custom directory is to be used, then it must be set using irq_scripts_dir
option in Target and Initiator configuration sections.
- `sysstat` package must be installed for SAR CPU utilization measurements.
- `bwm-ng` package must be installed for NIC bandwidth utilization measurements.
### Optional
@ -125,9 +126,8 @@ Optional, common:
"y" - time interval between measurements.
"z" - number of measurement samples.
Default: disabled.
- enable_bandwidth - [bool, int]. Wait a given number of seconds and run
bwm-ng until the end of test to measure bandwidth utilization on network
interfaces. Default: disabled.
- enable_bandwidth - bool. Measure bandwidth utilization on network
interfaces. Default: enabled.
- tuned_profile - tunedadm profile to apply on the system before starting
the test.
- irq_scripts_dir - path to scripts directory of Mellanox mlnx-tools package;

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

@ -390,8 +390,7 @@ class Target(Server):
self.pcm_delay = 0
self.pcm_interval = 0
self.pcm_count = 0
self.enable_bandwidth = 0
self.bandwidth_count = 0
self.enable_bw = True
self.enable_dpdk_memory = False
self.dpdk_wait_time = 0
@ -419,7 +418,7 @@ class Target(Server):
self.enable_pcm = True
self.pcm_dir, self.pcm_delay, self.pcm_interval, self.pcm_count = target_config["pcm_settings"]
if "enable_bandwidth" in target_config:
self.enable_bandwidth, self.bandwidth_count = target_config["enable_bandwidth"]
self.enable_bw = target_config["enable_bandwidth"]
if "enable_dpdk_memory" in target_config:
self.enable_dpdk_memory, self.dpdk_wait_time = target_config["enable_dpdk_memory"]
@ -556,10 +555,15 @@ class Target(Server):
with open(os.path.join(results_dir, pcm_power_file_name), "w") as fh:
fh.write(out)
def measure_network_bandwidth(self, results_dir, bandwidth_file_name):
def measure_network_bandwidth(self, results_dir, bandwidth_file_name, ramp_time, run_time):
self.log.info("Waiting %d seconds for ramp-up to finish before measuring bandwidth stats" % ramp_time)
time.sleep(ramp_time)
self.log.info("INFO: starting network bandwidth measure")
self.exec_cmd(["bwm-ng", "-o", "csv", "-F", "%s/%s" % (results_dir, bandwidth_file_name),
"-a", "1", "-t", "1000", "-c", str(self.bandwidth_count)])
"-a", "1", "-t", "1000", "-c", "%s" % run_time])
# TODO: Above command results in a .csv file containing measurements for all gathered samples.
# Improve this so that additional file containing measurements average is generated too.
# TODO: Monitor only these interfaces which are currently used to run the workload.
def measure_dpdk_memory(self, results_dir):
self.log.info("INFO: waiting to generate DPDK memory usage")
@ -1573,10 +1577,11 @@ if __name__ == "__main__":
threads.append(pcm_mem_t)
threads.append(pcm_pow_t)
if target_obj.enable_bandwidth:
bandwidth_file_name = "_".join(["bandwidth", str(block_size), str(rw), str(io_depth)])
if target_obj.enable_bw:
bandwidth_file_name = "_".join([str(block_size), str(rw), str(io_depth), "bandwidth"])
bandwidth_file_name = ".".join([bandwidth_file_name, "csv"])
t = threading.Thread(target=target_obj.measure_network_bandwidth, args=(args.results, bandwidth_file_name))
t = threading.Thread(target=target_obj.measure_network_bandwidth,
args=(args.results, bandwidth_file_name, fio_ramp_time, fio_run_time))
threads.append(t)
if target_obj.enable_dpdk_memory: