diff --git a/ci-scripts/conf_files/enb.band7.tm1.25PRB.usrpb210.conf b/ci-scripts/conf_files/enb.band7.tm1.25PRB.usrpb210.conf
index 808a01fc5401c99253b304815fcd2568e014884e..f7ca1ef0b60abd943d250952cc14948ca28f2420 100644
--- a/ci-scripts/conf_files/enb.band7.tm1.25PRB.usrpb210.conf
+++ b/ci-scripts/conf_files/enb.band7.tm1.25PRB.usrpb210.conf
@@ -243,9 +243,9 @@ THREAD_STRUCT = (
NETWORK_CONTROLLER :
{
- FLEXRAN_ENABLED = "no";
- FLEXRAN_INTERFACE_NAME = "lo";
- FLEXRAN_IPV4_ADDRESS = "127.0.0.1";
+ FLEXRAN_ENABLED = "yes";
+ FLEXRAN_INTERFACE_NAME = "eth0";
+ FLEXRAN_IPV4_ADDRESS = "CI_MME_IP_ADDR";
FLEXRAN_PORT = 2210;
FLEXRAN_CACHE = "/mnt/oai_agent_cache";
FLEXRAN_AWAIT_RECONF = "no";
diff --git a/ci-scripts/main.py b/ci-scripts/main.py
index 5177e3f57c1f199288f843e4effd6209ec2be87e..79991dd2d110096374249692addb176f6a1ab359 100644
--- a/ci-scripts/main.py
+++ b/ci-scripts/main.py
@@ -129,6 +129,9 @@ class SSHConnection():
self.eNBCpuNb = ''
self.eNBCpuModel = ''
self.eNBCpuMHz = ''
+ self.flexranCtrlInstalled = False
+ self.flexranCtrlStarted = False
+ self.expectedNbOfConnectedUEs = 0
def open(self, ipaddress, username, password):
count = 0
@@ -388,6 +391,37 @@ class SSHConnection():
self.close()
self.CreateHtmlTestRow(self.EPCType, 'OK', ALL_PROCESSES_OK)
+ def CheckFlexranCtrlInstallation(self):
+ if self.EPCIPAddress == '' or self.EPCUserName == '' or self.EPCPassword == '':
+ return
+ self.open(self.EPCIPAddress, self.EPCUserName, self.EPCPassword)
+ self.command('ls -ls /opt/flexran_rtc/*/rt_controller', '\$', 5)
+ result = re.search('/opt/flexran_rtc/build/rt_controller', str(self.ssh.before))
+ if result is not None:
+ self.flexranCtrlInstalled = True
+ logging.debug('Flexran Controller is installed')
+ self.close()
+
+ def InitializeFlexranCtrl(self):
+ if self.flexranCtrlInstalled == False:
+ return
+ if self.EPCIPAddress == '' or self.EPCUserName == '' or self.EPCPassword == '':
+ Usage()
+ sys.exit('Insufficient Parameter')
+ self.open(self.EPCIPAddress, self.EPCUserName, self.EPCPassword)
+ self.command('cd /opt/flexran_rtc', '\$', 5)
+ self.command('echo ' + self.EPCPassword + ' | sudo -S rm -f log/*.log', '\$', 5)
+ self.command('echo ' + self.EPCPassword + ' | sudo -S echo "build/rt_controller -c log_config/basic_log" > ./my-flexran-ctl.sh', '\$', 5)
+ self.command('echo ' + self.EPCPassword + ' | sudo -S chmod 755 ./my-flexran-ctl.sh', '\$', 5)
+ self.command('echo ' + self.EPCPassword + ' | sudo -S daemon --unsafe --name=flexran_rtc_daemon --chdir=/opt/flexran_rtc -o /opt/flexran_rtc/log/flexranctl_' + self.testCase_id + '.log ././my-flexran-ctl.sh', '\$', 5)
+ self.command('ps -aux | grep --color=never rt_controller', '\$', 5)
+ result = re.search('rt_controller -c ', str(self.ssh.before))
+ if result is not None:
+ logging.debug('\u001B[1m Initialize FlexRan Controller Completed\u001B[0m')
+ self.flexranCtrlStarted = True
+ self.close()
+ self.CreateHtmlTestRow('N/A', 'OK', ALL_PROCESSES_OK)
+
def InitializeeNB(self):
if self.eNBIPAddress == '' or self.eNBUserName == '' or self.eNBPassword == '' or self.eNBSourceCodePath == '':
Usage()
@@ -449,6 +483,8 @@ class SSHConnection():
self.command('cp ' + full_config_file + ' ' + ci_full_config_file, '\$', 5)
self.command('sed -i -e \'s/CI_MME_IP_ADDR/' + self.EPCIPAddress + '/\' ' + ci_full_config_file, '\$', 2);
self.command('sed -i -e \'s/CI_ENB_IP_ADDR/' + self.eNBIPAddress + '/\' ' + ci_full_config_file, '\$', 2);
+ if self.flexranCtrlInstalled == False or self.flexranCtrlStarted == False:
+ self.command('sed -i -e \'s/FLEXRAN_ENABLED.*;/FLEXRAN_ENABLED = "no";/\' ' + ci_full_config_file, '\$', 2);
# Launch eNB with the modified config file
self.command('source oaienv', '\$', 5)
self.command('cd cmake_targets', '\$', 5)
@@ -1077,9 +1113,28 @@ class SSHConnection():
multi_jobs.append(p)
for job in multi_jobs:
job.join()
+ if self.flexranCtrlInstalled and self.flexranCtrlStarted:
+ self.open(self.EPCIPAddress, self.EPCUserName, self.EPCPassword)
+ self.command('cd /opt/flexran_rtc', '\$', 5)
+ self.command('curl http://localhost:9999/stats | jq \'.\' > log/check_status_' + self.testCase_id + '.log 2>&1', '\$', 5)
+ self.command('cat log/check_status_' + self.testCase_id + '.log | jq \'.eNB_config[0].UE\' | grep -c rnti | sed -e "s#^#Nb Connected UE = #"', '\$', 5)
+ result = re.search('Nb Connected UE = (?P<nb_ues>[0-9]+)', str(self.ssh.before))
+ passStatus = True
+ if result is not None:
+ nb_ues = int(result.group('nb_ues'))
+ htmlOptions = 'Nb Connected UE(s) to eNB = ' + str(nb_ues)
+ logging.debug(htmlOptions)
+ if self.expectedNbOfConnectedUEs > -1:
+ if nb_ues != self.expectedNbOfConnectedUEs:
+ passStatus = False
+ else:
+ htmlOptions = 'N/A'
+ self.close()
+ else:
+ htmlOptions = 'N/A'
if (status_queue.empty()):
- self.CreateHtmlTestRow('N/A', 'KO', ALL_PROCESSES_OK)
+ self.CreateHtmlTestRow(htmlOptions, 'KO', ALL_PROCESSES_OK)
self.AutoTerminateUEandeNB()
self.CreateHtmlTabFooter(False)
sys.exit(1)
@@ -1094,10 +1149,10 @@ class SSHConnection():
message = status_queue.get()
html_cell = '<pre style="background-color:white">UE (' + device_id + ')\n' + message + '</pre>'
html_queue.put(html_cell)
- if (check_status):
- self.CreateHtmlTestRowQueue('N/A', 'OK', len(self.UEDevices), html_queue)
+ if check_status and passStatus:
+ self.CreateHtmlTestRowQueue(htmlOptions, 'OK', len(self.UEDevices), html_queue)
else:
- self.CreateHtmlTestRowQueue('N/A', 'KO', len(self.UEDevices), html_queue)
+ self.CreateHtmlTestRowQueue(htmlOptions, 'KO', len(self.UEDevices), html_queue)
self.AutoTerminateUEandeNB()
self.CreateHtmlTabFooter(False)
sys.exit(1)
@@ -1785,6 +1840,8 @@ class SSHConnection():
logStatus = self.AnalyzeLogFile_eNB(self.eNBLogFile)
if logStatus < 0:
result = logStatus
+ if self.flexranCtrlInstalled and self.flexranCtrlStarted:
+ self.TerminateFlexranCtrl()
return result
def CheckeNBProcess(self, status_queue):
@@ -2079,7 +2136,6 @@ class SSHConnection():
else:
self.command('cd ' + self.EPCSourceCodePath, '\$', 5)
self.command('cd scripts', '\$', 5)
- self.command('rm -f ./kill_hss.sh', '\$', 5)
self.command('echo ' + self.EPCPassword + ' | sudo -S daemon --name=simulated_hss --stop', '\$', 5)
time.sleep(1)
self.command('echo ' + self.EPCPassword + ' | sudo -S killall --signal SIGKILL hss_sim', '\$', 5)
@@ -2116,6 +2172,21 @@ class SSHConnection():
self.close()
self.CreateHtmlTestRow('N/A', 'OK', ALL_PROCESSES_OK)
+ def TerminateFlexranCtrl(self):
+ if self.flexranCtrlInstalled == False or self.flexranCtrlStarted == False:
+ return
+ if self.EPCIPAddress == '' or self.EPCUserName == '' or self.EPCPassword == '':
+ Usage()
+ sys.exit('Insufficient Parameter')
+ self.open(self.EPCIPAddress, self.EPCUserName, self.EPCPassword)
+ self.command('echo ' + self.EPCPassword + ' | sudo -S daemon --name=flexran_rtc_daemon --stop', '\$', 5)
+ time.sleep(1)
+ self.command('echo ' + self.EPCPassword + ' | sudo -S killall --signal SIGKILL rt_controller', '\$', 5)
+ time.sleep(1)
+ self.close()
+ self.flexranCtrlStarted = False
+ self.CreateHtmlTestRow('N/A', 'OK', ALL_PROCESSES_OK)
+
def TerminateUE_common(self, device_id):
try:
self.open(self.ADBIPAddress, self.ADBUserName, self.ADBPassword)
@@ -2607,7 +2678,7 @@ def Usage():
print('------------------------------------------------------------')
def CheckClassValidity(action,id):
- if action != 'Build_eNB' and action != 'Initialize_eNB' and action != 'Terminate_eNB' and action != 'Initialize_UE' and action != 'Terminate_UE' and action != 'Attach_UE' and action != 'Detach_UE' and action != 'DataDisable_UE' and action != 'DataEnable_UE' and action != 'CheckStatusUE' and action != 'Ping' and action != 'Iperf' and action != 'Reboot_UE' and action != 'Initialize_HSS' and action != 'Terminate_HSS' and action != 'Initialize_MME' and action != 'Terminate_MME' and action != 'Initialize_SPGW' and action != 'Terminate_SPGW' and action != 'Initialize_CatM_module' and action != 'Terminate_CatM_module' and action != 'Attach_CatM_module' and action != 'Detach_CatM_module' and action != 'Ping_CatM_module' and action != 'IdleSleep':
+ if action != 'Build_eNB' and action != 'Initialize_eNB' and action != 'Terminate_eNB' and action != 'Initialize_UE' and action != 'Terminate_UE' and action != 'Attach_UE' and action != 'Detach_UE' and action != 'DataDisable_UE' and action != 'DataEnable_UE' and action != 'CheckStatusUE' and action != 'Ping' and action != 'Iperf' and action != 'Reboot_UE' and action != 'Initialize_FlexranCtrl' and action != 'Terminate_FlexranCtrl' and action != 'Initialize_HSS' and action != 'Terminate_HSS' and action != 'Initialize_MME' and action != 'Terminate_MME' and action != 'Initialize_SPGW' and action != 'Terminate_SPGW' and action != 'Initialize_CatM_module' and action != 'Terminate_CatM_module' and action != 'Attach_CatM_module' and action != 'Detach_CatM_module' and action != 'Ping_CatM_module' and action != 'IdleSleep':
logging.debug('ERROR: test-case ' + id + ' has wrong class ' + action)
return False
return True
@@ -2634,6 +2705,13 @@ def GetParametersFromXML(action):
else:
SSH.nbMaxUEtoAttach = int(nbMaxUEtoAttach)
+ if action == 'CheckStatusUE':
+ expectedNBUE = test.findtext('expectedNbOfConnectedUEs')
+ if (expectedNBUE is None):
+ SSH.expectedNbOfConnectedUEs = -1
+ else:
+ SSH.expectedNbOfConnectedUEs = int(expectedNBUE)
+
if action == 'Ping' or action == 'Ping_CatM_module':
SSH.ping_args = test.findtext('ping_args')
SSH.ping_packetloss_threshold = test.findtext('ping_packetloss_threshold')
@@ -2881,6 +2959,7 @@ elif re.match('^TesteNB$', mode, re.IGNORECASE):
else:
logging.debug('ERROR: requested test is invalidly formatted: ' + test)
sys.exit(1)
+ SSH.CheckFlexranCtrlInstallation()
#get the list of tests to be done
todo_tests=[]
@@ -2958,6 +3037,10 @@ elif re.match('^TesteNB$', mode, re.IGNORECASE):
SSH.InitializeSPGW()
elif action == 'Terminate_SPGW':
SSH.TerminateSPGW()
+ elif action == 'Initialize_FlexranCtrl':
+ SSH.InitializeFlexranCtrl()
+ elif action == 'Terminate_FlexranCtrl':
+ SSH.TerminateFlexranCtrl()
elif action == 'IdleSleep':
SSH.IdleSleep()
else:
diff --git a/ci-scripts/xml_files/enb_usrp210_band7_test_05mhz_tm1.xml b/ci-scripts/xml_files/enb_usrp210_band7_test_05mhz_tm1.xml
index 017b39454e5e58effef16f12a63d79860ff8d1cd..bbdc56be4b360553aebbfe82a0a37bd5a4f0c7f3 100644
--- a/ci-scripts/xml_files/enb_usrp210_band7_test_05mhz_tm1.xml
+++ b/ci-scripts/xml_files/enb_usrp210_band7_test_05mhz_tm1.xml
@@ -26,7 +26,10 @@
<htmlTabIcon>tasks</htmlTabIcon>
<TestCaseRequestedList>
040101
- 030101 040301 040501 000010 040302 000001 000011 040303 000002 040502 040603 040604 040605 040606 040607 040641 040642 040643 040644 040401 040201 030201
+ 030101 040301 040501 040603 040604 040605 040606 040607 040641 040642 040643 040644 040401 040201 030201
+ 050102
+ 030102 040301 040502 000010 040302 000001 000011 040303 000002 000012 040503 040401 040201 030201
+ 050202
</TestCaseRequestedList>
<TestCaseExclusionList></TestCaseExclusionList>
@@ -45,11 +48,29 @@
<testCase id="000010">
<class>CheckStatusUE</class>
<desc>Check UE(s) status before data disabling</desc>
+ <expectedNbOfConnectedUEs>2</expectedNbOfConnectedUEs>
</testCase>
<testCase id="000011">
<class>CheckStatusUE</class>
<desc>Check UE(s) status after data disabling</desc>
+ <expectedNbOfConnectedUEs>0</expectedNbOfConnectedUEs>
+ </testCase>
+
+ <testCase id="000012">
+ <class>CheckStatusUE</class>
+ <desc>Check UE(s) status after data re-enabling</desc>
+ <expectedNbOfConnectedUEs>2</expectedNbOfConnectedUEs>
+ </testCase>
+
+ <testCase id="050102">
+ <class>Initialize_FlexranCtrl</class>
+ <desc>Starting Flexran Controller</desc>
+ </testCase>
+
+ <testCase id="050202">
+ <class>Terminate_FlexranCtrl</class>
+ <desc>Stopping Flexran Controller</desc>
</testCase>
<testCase id="030101">
@@ -58,6 +79,12 @@
<Initialize_eNB_args>-O ci-scripts/conf_files/enb.band7.tm1.25PRB.usrpb210.conf</Initialize_eNB_args>
</testCase>
+ <testCase id="030102">
+ <class>Initialize_eNB</class>
+ <desc>Initialize eNB (FDD/Band7/5MHz)</desc>
+ <Initialize_eNB_args>-O ci-scripts/conf_files/enb.band7.tm1.25PRB.usrpb210.conf</Initialize_eNB_args>
+ </testCase>
+
<testCase id="030201">
<class>Terminate_eNB</class>
<desc>Terminate eNB</desc>
@@ -107,6 +134,13 @@
<ping_packetloss_threshold>5</ping_packetloss_threshold>
</testCase>
+ <testCase id="040503">
+ <class>Ping</class>
+ <desc>ping (5MHz - 20 sec)</desc>
+ <ping_args>-c 20</ping_args>
+ <ping_packetloss_threshold>5</ping_packetloss_threshold>
+ </testCase>
+
<testCase id="040603">
<class>Iperf</class>
<desc>iperf (5MHz - DL/15Mbps/UDP)(30 sec)(balanced profile)</desc>