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()
  except KeyboardInterrupt:

After Change

  server_address = ("", int(sys.argv[1]))
  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()
  timing_queue = multiprocessing_manager.Queue()

  // Start the worker to move results from queue to file first.
  process_pool.apply_async(WriteResultsToFile,
                           args=(results_file_path, timing_queue,))
  if use_listening_server:
    ActAsServer(process_pool, timing_queue, clients_port, hostname,
                server_address)

  // The start the server to listen and put results on queue.
  else:
    ActAsClient(process_pool, timing_queue, clients_port,
                vms_name_constructor, num_vms)

Instances