Introduce RFemu stdin implementation for srsENB
Change-Id: I5487dec3691cbf424306369f94f337ed34a10c70
diff --git a/src/osmo_gsm_tester/obj/enb_srs.py b/src/osmo_gsm_tester/obj/enb_srs.py
index 63e5d7c..9d7eca3 100644
--- a/src/osmo_gsm_tester/obj/enb_srs.py
+++ b/src/osmo_gsm_tester/obj/enb_srs.py
@@ -259,6 +259,10 @@
rfemu_cfg = cell_list[cell].get('dl_rfemu', None)
if rfemu_cfg is None:
raise log.Error('rfemu attribute not found in cell_list item!')
+ if rfemu_cfg['type'] == 'srsenb_stdin':
+ # These fields are required so the rfemu class can interact with us:
+ config.overlay(rfemu_cfg, dict(enb=self,
+ cell_id=cell_list[cell]['cell_id']))
rfemu_obj = rfemu.get_instance_by_type(rfemu_cfg['type'], rfemu_cfg)
return rfemu_obj
diff --git a/src/osmo_gsm_tester/obj/rfemu.py b/src/osmo_gsm_tester/obj/rfemu.py
index ac34ee1..ec8ed68 100644
--- a/src/osmo_gsm_tester/obj/rfemu.py
+++ b/src/osmo_gsm_tester/obj/rfemu.py
@@ -52,6 +52,9 @@
elif rfemu_type == 'minicircuits':
from .rfemu_minicircuits import RFemulationMinicircuitsHTTP
obj = RFemulationMinicircuitsHTTP
+ elif rfemu_type == 'srsenb_stdin':
+ from .rfemu_srsenb_stdin import RFemulationSrsStdin
+ obj = RFemulationSrsStdin
else:
raise log.Error('RFemulation type not supported:', rfemu_type)
diff --git a/src/osmo_gsm_tester/obj/rfemu_srsenb_stdin.py b/src/osmo_gsm_tester/obj/rfemu_srsenb_stdin.py
new file mode 100644
index 0000000..ca23020
--- /dev/null
+++ b/src/osmo_gsm_tester/obj/rfemu_srsenb_stdin.py
@@ -0,0 +1,52 @@
+# osmo_gsm_tester: class defining a RF emulation object implemented using SRS ENB stdin interface
+#
+# Copyright (C) 2020 by sysmocom - s.f.m.c. GmbH
+#
+# Author: Pau Espin Pedrol <pespin@sysmocom.de>
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as
+# published by the Free Software Foundation, either version 3 of the
+# License, or (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program. If not, see <http://www.gnu.org/licenses/>.
+
+import json
+
+from ..core import log
+from .rfemu import RFemulation
+
+class RFemulationSrsStdin(RFemulation):
+##############
+# PROTECTED
+##############
+ def __init__(self, conf):
+ super().__init__(conf, 'srsenb_stdin')
+ self.cell_id = int(conf.get('cell_id'))
+ if self.cell_id is None:
+ raise log.Error('No "cell_id" attribute provided in rfemu conf!')
+ self.enb = conf.get('enb')
+ if self.enb is None:
+ raise log.Error('No "srsenb" attribute provided in rfemu conf!')
+
+ def __del__(self):
+ self.enb = None
+
+#############################
+# PUBLIC (test API included)
+#############################
+ def set_attenuation(self, db):
+ msg_str = 'cell_gain %d %f' % (self.cell_id, db)
+ self.dbg('sending stdin msg: "%s"' % msg_str)
+ self.enb.process.stdin_write(msg_str + '\n')
+
+ def get_max_attenuation(self):
+ return 200 # maximum cell_gain value in srs. Is this correct value?
+
+# vim: expandtab tabstop=4 shiftwidth=4