diff --git a/tests/Performance/ESJobMonitoring/config.cfg b/tests/Performance/ESJobMonitoring/config.cfg deleted file mode 100644 index 81ac54b9968..00000000000 --- a/tests/Performance/ESJobMonitoring/config.cfg +++ /dev/null @@ -1,15 +0,0 @@ -[global] -run_time = 30 -rampup = 0 -results_ts_interval = 10 -progress_bar = on -console_logging = on -xml_report = off - -[user_group-1] -threads = 50 -script = query.py - -[user_group-2] -threads = 10 -script = update.py diff --git a/tests/Performance/ESJobMonitoring/test_scripts/query.py b/tests/Performance/ESJobMonitoring/test_scripts/query.py deleted file mode 100644 index 34d544dbd14..00000000000 --- a/tests/Performance/ESJobMonitoring/test_scripts/query.py +++ /dev/null @@ -1,32 +0,0 @@ -""" -Performance test created using multi-mechnize to analyze time -for query processing with ElasticSearch. -""" - -import random -import time - -from DIRAC.WorkloadManagementSystem.DB.JobParametersDB import JobParametersDB - - -class Transaction: - def __init__(self): - self.elasticJobParametersDB = JobParametersDB() - self.custom_timers = {} - - def run(self): - start_time = time.time() - - for i in range(0, random.randint(1000, 3000)): - jobID = random.randint(1, 1000) - self.elasticJobParametersDB.getJobParameters(jobID) - - end_time = time.time() - - self.custom_timers["Execution_Time"] = end_time - start_time - - -if __name__ == "__main__": - trans = Transaction() - trans.run() - print(trans.custom_timers) diff --git a/tests/Performance/ESJobMonitoring/test_scripts/update.py b/tests/Performance/ESJobMonitoring/test_scripts/update.py deleted file mode 100644 index 588f22d7a8a..00000000000 --- a/tests/Performance/ESJobMonitoring/test_scripts/update.py +++ /dev/null @@ -1,38 +0,0 @@ -""" -Performance test created using multi-mechnize to analyze time -for update processing with ElasticSearch. -""" - -import random -import string -import time - -from DIRAC.WorkloadManagementSystem.DB.JobParametersDB import JobParametersDB - - -def random_generator(size=6, chars=string.ascii_letters): - return "".join(random.choice(chars) for x in range(size)) - - -class Transaction: - def __init__(self): - self.elasticJobParametersDB = JobParametersDB() - self.custom_timers = {} - - def run(self): - start_time = time.time() - - for i in range(0, random.randint(1000, 3000)): - key = random_generator() - value = random_generator(size=12) - self.elasticJobParametersDB.setJobParameter(2, key, value) - - end_time = time.time() - - self.custom_timers["Execution_Time"] = end_time - start_time - - -if __name__ == "__main__": - trans = Transaction() - trans.run() - print(trans.custom_timers) diff --git a/tests/Performance/MySQLJobMonitoring/config.cfg b/tests/Performance/MySQLJobMonitoring/config.cfg deleted file mode 100644 index 81ac54b9968..00000000000 --- a/tests/Performance/MySQLJobMonitoring/config.cfg +++ /dev/null @@ -1,15 +0,0 @@ -[global] -run_time = 30 -rampup = 0 -results_ts_interval = 10 -progress_bar = on -console_logging = on -xml_report = off - -[user_group-1] -threads = 50 -script = query.py - -[user_group-2] -threads = 10 -script = update.py diff --git a/tests/Performance/MySQLJobMonitoring/test_scripts/query.py b/tests/Performance/MySQLJobMonitoring/test_scripts/query.py deleted file mode 100644 index 8145e3cb4e2..00000000000 --- a/tests/Performance/MySQLJobMonitoring/test_scripts/query.py +++ /dev/null @@ -1,32 +0,0 @@ -""" -Performance test created using multi-mechnize to analyze time -for query processing with MySQL. -""" - -import random -import time - -from DIRAC.WorkloadManagementSystem.DB.JobDB import JobDB - - -class Transaction: - def __init__(self): - self.JobDB = JobDB() - self.custom_timers = {} - - def run(self): - start_time = time.time() - - for i in range(0, random.randint(1000, 3000)): - jobID = random.randint(1, 1000) - self.JobDB.getJobParameters(jobID) - - end_time = time.time() - - self.custom_timers["Execution_Time"] = end_time - start_time - - -if __name__ == "__main__": - trans = Transaction() - trans.run() - print(trans.custom_timers) diff --git a/tests/Performance/MySQLJobMonitoring/test_scripts/update.py b/tests/Performance/MySQLJobMonitoring/test_scripts/update.py deleted file mode 100644 index 4b2962f0d2d..00000000000 --- a/tests/Performance/MySQLJobMonitoring/test_scripts/update.py +++ /dev/null @@ -1,38 +0,0 @@ -""" -Performance test created using multi-mechnize to analyze time -for update processing with MySQL. -""" - -import random -import string -import time - -from DIRAC.WorkloadManagementSystem.DB.JobDB import JobDB - - -def random_generator(size=6, chars=string.ascii_letters): - return "".join(random.choice(chars) for x in range(size)) - - -class Transaction: - def __init__(self): - self.JobDB = JobDB() - self.custom_timers = {} - - def run(self): - start_time = time.time() - - for i in range(0, random.randint(1000, 3000)): - key = random_generator() - value = random_generator(size=12) - self.JobDB.setJobParameter(2, key, value) - - end_time = time.time() - - self.custom_timers["Execution_Time"] = end_time - start_time - - -if __name__ == "__main__": - trans = Transaction() - trans.run() - print(trans.custom_timers) diff --git a/tests/Performance/Service/config.cfg b/tests/Performance/Service/config.cfg deleted file mode 100644 index 046dd2eb179..00000000000 --- a/tests/Performance/Service/config.cfg +++ /dev/null @@ -1,12 +0,0 @@ -[global] -run_time = 7200 -rampup = 36 -results_ts_interval = 10 -progress_bar = on -console_logging = off -xml_report = off - - -[user_group-1] -threads = 50 -script = service.py diff --git a/tests/Performance/Service/test_scripts/service.py b/tests/Performance/Service/test_scripts/service.py deleted file mode 100644 index f073c6c9aa7..00000000000 --- a/tests/Performance/Service/test_scripts/service.py +++ /dev/null @@ -1,32 +0,0 @@ -""" -This is a very simple service performance test. It calls the service with a message. The service -return the same message. -""" -import time - -from DIRAC.Core.Base.Client import Client -import DIRAC - -DIRAC.initialize() # Initialize configuration - -cl = Client(url="Framework/SystemAdministrator") - - -class Transaction: - def __init__(self): - self.custom_timers = {} - - def run(self): - start_time = time.time() - retVal = cl.echo("simple test") - if not retVal["OK"]: - print("ERROR", retVal["Message"]) - end_time = time.time() - self.custom_timers["Service_ResponseTime"] = end_time - start_time - self.custom_timers["Service_Echo"] = end_time - start_time - - -if __name__ == "__main__": - trans = Transaction() - trans.run() - print(trans.custom_timers) diff --git a/tests/Performance/webserver/config.cfg b/tests/Performance/webserver/config.cfg deleted file mode 100644 index cb49dc8bdbe..00000000000 --- a/tests/Performance/webserver/config.cfg +++ /dev/null @@ -1,12 +0,0 @@ -global] -run_time = 7200 -rampup = 36 -results_ts_interval = 10 -progress_bar = on -console_logging = off -xml_report = off - - -[user_group-1] -threads = 50 -script = web.py diff --git a/tests/Performance/webserver/test_scripts/web.py b/tests/Performance/webserver/test_scripts/web.py deleted file mode 100644 index 0c0285a5938..00000000000 --- a/tests/Performance/webserver/test_scripts/web.py +++ /dev/null @@ -1,34 +0,0 @@ -#!/usr/bin/env python -""" -It is used to test the tornado web framework. This can be used: --change of an underlying library such as ThreadPool --change of the Tornado configuration (running more Tornado processes) --Tornado scalability of a certain machine -""" - -import time -import httplib - - -class Transaction: - def __init__(self): - self.custom_timers = {} - self.url = "/DIRAC/s:DIRAC-Certification/g:dteam_user/ExampleApp/getSelectionData" - self.conn = httplib.HTTPConnection("lhcb-cert-dirac.cern.ch") - - def run(self): - # print len(datasets) - start_time = time.time() - self.conn.request("GET", self.url) - r1 = self.conn.getresponse() - if r1.status != 200: - print(r1.status, r1.reason) - _ = r1.read() - end_time = time.time() - self.custom_timers["Tornado_ResponseTime"] = end_time - start_time - - -if __name__ == "__main__": - trans = Transaction() - trans.run() - print(trans.custom_timers)