c84eb9306a521ddcefe8ca805ac633408e5b312a,perfkitbenchmarker/benchmarks/iperf_benchmark.py,,_RunIperf,#Any#Any#Any#Any#,64

Before Change

               (receiving_ip_address, IPERF_PORT))
  stdout, _ = sending_vm.RemoteCommand(iperf_cmd, should_log=True)

  iperf_pattern = re.compile(r"(\d+\.\d+|\d+) Mbits/sec")
  value = regex_util.ExtractFloat(iperf_pattern, stdout)

  metadata = {
      // TODO(voellm): The server and client terminology is being

After Change

  // [SUM]  0.0-60.0 sec  14010 MBytes  1957 Mbits/sec

  thread_values = re.findall("\[.*\d\].*\d.Mbits/sec", stdout)
  if len(thread_values) != FLAGS.sending_thread_count:
        raise ValueError("Only %s out of %s iperf threads repoted a"
                         " throughput value." % (len(thread_values),
                                                 FLAGS.sending_thread_count))

Instances