0b686a33355044ffd8957f28a856674c9f00116e,perfkitbenchmarker/data/large_scale_boot/listener_server.py,,,#,134

Before Change

                           args=(results_file_path, timing_queue,))

  // The start the server to listen and put results on queue.
  handler = functools.partial(
      RequestHandler, process_pool, hostname, timing_queue, clients_port)
  listener = server.HTTPServer(server_address, handler)
  logging.info("Starting httpserver...\n")
  try:
    listener.serve_forever()

After Change

  results_file_path = sys.argv[2]
  clients_port = sys.argv[3]
  use_listening_server = sys.argv[4] == "True"
  vms_name_constructor = functools.partial(sys.argv[5].replace, "VM_ID")
  num_vms = int(sys.argv[6])
  hostname = socket.gethostname()
  process_pool = multiprocessing.Pool()
  multiprocessing_manager = multiprocessing.Manager()

Instances