This buildstep will copy the devices configuration from the
worker and read it, in order to get daft ip an ssh port, to
use later in RunSanityTests
[YOCTO #10604]
Signed-off-by: Aníbal Limón <anibal.li...@linux.intel.com>
Signed-off-by: Edwin Plauchu <edwin.plauchu.cama...@intel.com>
---
config/autobuilder.conf.example | 3 +
.../autobuilder/buildsteps/DaftGetDevices.py | 44 ++++++++
lib/python2.7/site-packages/autobuilder/config.py | 1 +
.../site-packages/autobuilder/lib/daft.py | 118 +++++++++++++++++++++
4 files changed, 166 insertions(+)
create mode 100644
lib/python2.7/site-packages/autobuilder/buildsteps/DaftGetDevices.py
create mode 100644 lib/python2.7/site-packages/autobuilder/lib/daft.py
diff --git a/config/autobuilder.conf.example b/config/autobuilder.conf.example
index 9e2fa8934e6..565a1a31b30 100644
--- a/config/autobuilder.conf.example
+++ b/config/autobuilder.conf.example
@@ -96,3 +96,6 @@ PERFORMANCE_MAIL_TO = "root@localhost otherperson@localhost"
PERFORMANCE_MAIL_CC = "buildcc@localhost"
PERFORMANCE_MAIL_BCC = "buildbcc@localhost"
PERFORMANCE_MAIL_SIG = "Multiline\nSig\nLine"
+
+[Daft]
+DAFT_WORKER_DEVICES_CFG = "/etc/daft/devices.cfg"
diff --git
a/lib/python2.7/site-packages/autobuilder/buildsteps/DaftGetDevices.py
b/lib/python2.7/site-packages/autobuilder/buildsteps/DaftGetDevices.py
new file mode 100644
index 00000000000..a6e87e7f9e2
--- /dev/null
+++ b/lib/python2.7/site-packages/autobuilder/buildsteps/DaftGetDevices.py
@@ -0,0 +1,44 @@
+import os
+from buildbot.steps.transfer import FileUpload
+from buildbot.process.buildstep import BuildStep
+
+from lib.daft import DeployScanner
+from autobuilder.config import DAFT_WORKER_DEVICES_CFG
+
+class DaftGetDevices(FileUpload):
+ haltOnFailure = True
+
+ name = "DaftGetDevices"
+
+ def __init__(self, factory, argdict=None, **kwargs):
+ self.tests = None
+ self.factory = factory
+ for k, v in argdict.iteritems():
+ setattr(self, k, v)
+ self.description = "Getting devices configuration"
+ self.timeout = 100000
+ kwargs['timeout']=self.timeout
+
+ super(DaftGetDevices, self).__init__(DAFT_WORKER_DEVICES_CFG,
+ os.path.join('/tmp', 'devices.cfg'))
+
+ def finished(self, result):
+ if self.cmd:
+ ds = DeployScanner(devsconf_file = self.masterdest)
+ devices = ds.getDevices()
+
+ found = False
+ dut_label = self.getProperty('custom_dut')
+ for d in devices:
+ if d['dut_label'] == dut_label:
+ self.setProperty('dut_name', d['dut_label'],
'DaftGetDevices')
+ self.setProperty('server_ip', d['server_address'],
'DaftGetDevices')
+ target_ip = "%s:%s" % (d['ctrl_address'], d['dut_sshport'])
+ self.setProperty('target_ip', target_ip, 'DaftGetDevices')
+
+ found = True
+
+ if not found:
+ return BuildStep.finished(self, FAILURE)
+
+ return super(DaftGetDevices, self).finished(result)
diff --git a/lib/python2.7/site-packages/autobuilder/config.py
b/lib/python2.7/site-packages/autobuilder/config.py
index 9d945b17525..5bcf6c6ff9d 100644
--- a/lib/python2.7/site-packages/autobuilder/config.py
+++ b/lib/python2.7/site-packages/autobuilder/config.py
@@ -23,3 +23,4 @@ RPM_PUBLISH_DIR = os.environ.get("RPM_PUBLISH_DIR")
IPK_PUBLISH_DIR = os.environ.get("IPK_PUBLISH_DIR")
DEB_PUBLISH_DIR = os.environ.get("DEB_PUBLISH_DIR")
PERFORMANCE_PUBLISH_DIR = os.environ.get("PERFORMANCE_PUBLISH_DIR")
+DAFT_WORKER_DEVICES_CFG = os.environ.get("DAFT_WORKER_DEVICES_CFG")
diff --git a/lib/python2.7/site-packages/autobuilder/lib/daft.py
b/lib/python2.7/site-packages/autobuilder/lib/daft.py
new file mode 100644
index 00000000000..925efa7e369
--- /dev/null
+++ b/lib/python2.7/site-packages/autobuilder/lib/daft.py
@@ -0,0 +1,118 @@
+import os
+import ConfigParser as configparser
+
+class DeployScanner(object):
+ '''
+ In charge of scanning deployed daft bbb devices
+ '''
+
+ __MAGIC_SERVER_ADDRESS = '192.168.30.1' # DAFT uses this address for this
internal network
+ __MAGIC_SSH_PORT = 2233 # it is hardcoded as per DAFT implementation manual
+
+ def __init__(self, *args, **kwargs):
+ self.devsconf_fp = kwargs.get('devsconf_file', None)
+ if not self.devsconf_fp:
+ raise Exception('not fed devsconf file')
+ self.ign_leases = kwargs.get('ign_leases', True)
+ if not self.ign_leases:
+ self.leases_file_path = kwargs.get('leases_file', None)
+ if not self.leases_file_path:
+ raise Exception('not fed leases file')
+
+ def getDevices(self):
+ '''
+ Creates relation of deployed devices
+ Returns:
+ List of dictionaries containing info about devices deployed.
+ '''
+
+ def _map_config(conf, leases=None):
+ """
+ Creates a list with dictionaries for DUT config
+ information, if DHCP leases isn't none also validate
+ if the DUT IP is active.
+ """
+
+ mapped_config = []
+
+ for entry in conf:
+ append = False
+ if leases:
+ for active in leases:
+ if conf['bb_ip'] == active['ip']:
+ append = True
+ break
+ else:
+ append = True
+
+ if append:
+ mapped_config.append({
+ 'dut_label': entry['device'],
+ 'dut_family': entry['device_type'],
+ 'dut_sshport': str(self.__MAGIC_SSH_PORT),
+ 'ctrl_address': entry['bb_ip'],
+ 'server_address': self.__MAGIC_SERVER_ADDRESS
+ })
+
+ return mapped_config
+
+ conf = self.__fetch_confs()
+ if not conf:
+ raise Exception('There are no configurations as per BBB devices')
+
+ leases = None
+ if not self.ign_leases:
+ leases = self.__active_leases()
+ if not leases:
+ raise Exception('DHCP server has not registered any host yet')
+
+ return _map_config(conf, leases)
+
+ def __fetch_confs(self):
+ '''
+ Read and parse BBB configuration file and return result as dictionary
+ '''
+ config = configparser.SafeConfigParser()
+ config.read(self.devsconf_fp)
+ configurations = []
+ for device in config.sections():
+ device_config = dict(config.items(device))
+ device_config["device"] = device
+ device_config["device_type"] = device.rstrip('1234567890_')
+ configurations.append(device_config)
+ return configurations
+
+ def __active_leases(self):
+ """
+ Read the active leases from dnsmasq leases file and return a list of
+ active leases as dictionaries.
+ Args:
+ file_name (str): Path to leases file, e.g.
/path/to/file/dnsmasq.leases
+ Returns:
+ List of dictionaries containing the active leases.
+ The dictionaries have the following format:
+ {
+ "mac": "device_mac_address",
+ "ip": "device_ip_address",
+ "hostname": "device_host_name",
+ "client_id": "client_id_or_*_if_unset"
+ }
+ """
+ with open(self.leases_file_path) as lease_file:
+ leases = lease_file.readlines()
+
+ leases_list = []
+
+ # dnsmasq.leases contains rows with the following format:
+ # <lease_expiry_time_as_epoch_format> <mac> <ip> <hostname> <domain>
+ # See:
+
#http://lists.thekelleys.org.uk/pipermail/dnsmasq-discuss/2005q1/000143.html
+ for lease in leases:
+ lease = lease.split()
+ leases_list.append({
+ "mac": lease[1],
+ "ip": lease[2],
+ "hostname": lease[3],
+ "client_id": lease[4],
+ })
+ return leases_list
--
2.11.0
--
_______________________________________________
yocto mailing list
yocto@yoctoproject.org
https://lists.yoctoproject.org/listinfo/yocto
