benchmark.py 文件源码

def start_benchmark(self, seconds):
        self.iperf = subprocess.Popen('iperf -s -xS -yC'.split(), 
                            stdout=subprocess.PIPE, stderr=subprocess.PIPE)
        reactor.addSystemEventTrigger('before', 'shutdown', self.stop_benchmark)
        for client in self.clients:
            handle = self.clients[client][0]
            d = self.execute(handle, 'start_benchmark %d' % seconds)
            d.addCallback(lambda r, h=client : self.store_pid(h, r))