This commit is contained in:
		
							
								
								
									
										6
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										6
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							@@ -128,4 +128,8 @@ dmypy.json
 | 
			
		||||
 | 
			
		||||
# Pyre type checker
 | 
			
		||||
.pyre/
 | 
			
		||||
.idea/
 | 
			
		||||
.idea/
 | 
			
		||||
*.csv
 | 
			
		||||
*.png
 | 
			
		||||
*-latency*.txt
 | 
			
		||||
*-rps*.txt
 | 
			
		||||
@@ -268,11 +268,6 @@ class ChartCreator:
 | 
			
		||||
            directory +
 | 
			
		||||
            "-latency.png")
 | 
			
		||||
        pplot.clf()
 | 
			
		||||
        print("latency min, max, avg")
 | 
			
		||||
        print(min(csvfile.latencypersec))
 | 
			
		||||
        print(max(csvfile.latencypersec))
 | 
			
		||||
        print(average(csvfile.latencypersec))
 | 
			
		||||
        print("Charted " + directory)
 | 
			
		||||
 | 
			
		||||
    @staticmethod
 | 
			
		||||
    def analyze_hey(abs_directory, directory):
 | 
			
		||||
@@ -319,25 +314,15 @@ class ChartCreator:
 | 
			
		||||
        :return:
 | 
			
		||||
        """
 | 
			
		||||
        dirs = next(os.walk(os.getenv('SEARCHDIR', default='.')))[1]
 | 
			
		||||
        jobs = []
 | 
			
		||||
        for directory in dirs:
 | 
			
		||||
            abs_directory = os.getenv(
 | 
			
		||||
                'SEARCHDIR', default='.') + '/' + directory
 | 
			
		||||
            print(abs_directory)
 | 
			
		||||
            if 'HEY' not in abs_directory.upper():
 | 
			
		||||
                process = multiprocessing.Process(
 | 
			
		||||
                    target=ChartCreator.analyze_hey, args=(
 | 
			
		||||
                        abs_directory, directory,))
 | 
			
		||||
                jobs.append(process)
 | 
			
		||||
            if 'HEY' in abs_directory.upper():
 | 
			
		||||
                ChartCreator.analyze_hey(abs_directory,directory)
 | 
			
		||||
            else:
 | 
			
		||||
                process_birb = multiprocessing.Process(
 | 
			
		||||
                    target=ChartCreator.analyze_birb, args=(
 | 
			
		||||
                        abs_directory, directory,))
 | 
			
		||||
                process_input = multiprocessing.Process(
 | 
			
		||||
                    target=ChartCreator.analyze_input, args=(
 | 
			
		||||
                        abs_directory, directory,))
 | 
			
		||||
                jobs.append(process_birb)
 | 
			
		||||
                jobs.append(process_input)
 | 
			
		||||
                ChartCreator.analyze_birb(abs_directory,directory)
 | 
			
		||||
                ChartCreator.analyze_input(abs_directory,directory)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
if __name__ == "__main__":
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user