diff --git a/ci-scripts/epc.py b/ci-scripts/epc.py index e025c514d9..a3b8d72ea1 100644 --- a/ci-scripts/epc.py +++ b/ci-scripts/epc.py @@ -347,96 +347,6 @@ class EPCManagement(): mySSH.open(self.IPAddress, self.UserName, self.Password) response=mySSH.command3('oc pods ls -f name=oai-amf', 10) - def CheckHSSProcess(self, status_queue): - try: - mySSH = SSH.SSHConnection() - mySSH.open(self.IPAddress, self.UserName, self.Password) - if re.match('OAI-Rel14-Docker', self.Type, re.IGNORECASE): - mySSH.command('docker top ' + self.containerPrefix + '-oai-hss', '\$', 5) - else: - mySSH.command('stdbuf -o0 ps -aux | grep --color=never hss | grep -v grep', '\$', 5) - if re.match('OAI-Rel14-CUPS', self.Type, re.IGNORECASE) or re.match('OAI-Rel14-Docker', self.Type, re.IGNORECASE): - result = re.search('oai_hss -j', mySSH.getBefore()) - elif re.match('OAI', self.Type, re.IGNORECASE): - result = re.search('\/bin\/bash .\/run_', mySSH.getBefore()) - elif re.match('ltebox', self.Type, re.IGNORECASE): - result = re.search('hss_sim s6as diam_hss', mySSH.getBefore()) - else: - logging.error('This should not happen!') - if result is None: - logging.debug('\u001B[1;37;41m HSS Process Not Found! \u001B[0m') - status_queue.put(CONST.HSS_PROCESS_FAILED) - else: - status_queue.put(CONST.HSS_PROCESS_OK) - mySSH.close() - except: - os.kill(os.getppid(),signal.SIGUSR1) - - def CheckMMEProcess(self, status_queue): - try: - mySSH = SSH.SSHConnection() - mySSH.open(self.IPAddress, self.UserName, self.Password) - if re.match('OAI-Rel14-Docker', self.Type, re.IGNORECASE): - self.isMagmaUsed = False - mySSH.command('docker ps -a', '\$', 5) - result = re.search('magma', mySSH.getBefore()) - if result is not None: - self.isMagmaUsed = True - if self.isMagmaUsed: - mySSH.command('docker top ' + self.containerPrefix + '-magma-mme', '\$', 5) - else: - mySSH.command('docker top ' + self.containerPrefix + '-oai-mme', '\$', 5) - else: - mySSH.command('stdbuf -o0 ps -aux | grep --color=never mme | grep -v grep', '\$', 5) - if re.match('OAI-Rel14-Docker', self.Type, re.IGNORECASE): - result = re.search('oai_mme -c ', mySSH.getBefore()) - elif re.match('OAI-Rel14-CUPS', self.Type, re.IGNORECASE): - result = re.search('mme -c', mySSH.getBefore()) - elif re.match('OAI', self.Type, re.IGNORECASE): - result = re.search('\/bin\/bash .\/run_', mySSH.getBefore()) - elif re.match('ltebox', self.Type, re.IGNORECASE): - result = re.search('mme|amf', mySSH.getBefore()) - else: - logging.error('This should not happen!') - if result is None: - logging.debug('\u001B[1;37;41m MME|AMF Process Not Found! \u001B[0m') - status_queue.put(CONST.MME_PROCESS_FAILED) - else: - status_queue.put(CONST.MME_PROCESS_OK) - mySSH.close() - except: - os.kill(os.getppid(),signal.SIGUSR1) - - def CheckSPGWProcess(self, status_queue): - try: - mySSH = SSH.SSHConnection() - mySSH.open(self.IPAddress, self.UserName, self.Password) - if re.match('OAI-Rel14-Docker', self.Type, re.IGNORECASE): - mySSH.command('docker top ' + self.containerPrefix + '-oai-spgwc', '\$', 5) - result = re.search('oai_spgwc -', mySSH.getBefore()) - if result is not None: - mySSH.command('docker top ' + self.containerPrefix + '-oai-spgwu-tiny', '\$', 5) - result = re.search('oai_spgwu -', mySSH.getBefore()) - elif re.match('OAI-Rel14-CUPS', self.Type, re.IGNORECASE): - mySSH.command('stdbuf -o0 ps -aux | grep --color=never spgw | grep -v grep', '\$', 5) - result = re.search('spgwu -c ', mySSH.getBefore()) - elif re.match('OAI', self.Type, re.IGNORECASE): - mySSH.command('stdbuf -o0 ps -aux | grep --color=never spgw | grep -v grep', '\$', 5) - result = re.search('\/bin\/bash .\/run_', mySSH.getBefore()) - elif re.match('ltebox', self.Type, re.IGNORECASE): - mySSH.command('stdbuf -o0 ps -aux | grep --color=never xGw | grep -v grep', '\$', 5) - result = re.search('xGw|upf', mySSH.getBefore()) - else: - logging.error('This should not happen!') - if result is None: - logging.debug('\u001B[1;37;41m SPGW|UPF Process Not Found! \u001B[0m') - status_queue.put(CONST.SPGW_PROCESS_FAILED) - else: - status_queue.put(CONST.SPGW_PROCESS_OK) - mySSH.close() - except: - os.kill(os.getppid(),signal.SIGUSR1) - def TerminateHSS(self, HTML): mySSH = SSH.SSHConnection() mySSH.open(self.IPAddress, self.UserName, self.Password)