def Before(self, unused_sender, benchmark_spec):
    logging.info('Installing collectd')
    vms = benchmark_spec.vms
    vm_util.RunThreaded(lambda vm: vm.Install('collectd'), vms)
Verify the correct sums are received
dataset/ETHPy150Open GoogleCloudPlatform/PerfKitBenchmarker/perfkitbenchmarker/traces/collectd.py/_CollectdCollector.Before--crossover with--dataset/ETHPy150Open linkedin/Zopkio/examples/server_client/test_suites/base_tests.py/validate_correctness