From: Michal Cmarada Date: Tue, 15 Jan 2019 10:08:34 +0000 (+0100) Subject: fix failing tests after namespace updates in HC X-Git-Url: https://gerrit.fd.io/r/gitweb?p=csit.git;a=commitdiff_plain;h=ae7e4fc1d7766027cf9cc7fcd3b5a3ad29af964e;hp=3c88007b0cb32905af6e133663f4cd1ad44c13de;ds=sidebyside fix failing tests after namespace updates in HC Change-Id: Idf7cbcf285ff130f771eb3878065e6daa869ac71 Signed-off-by: Michal Cmarada --- diff --git a/resources/libraries/python/honeycomb/Netconf.py b/resources/libraries/python/honeycomb/Netconf.py index 742948c6e7..303361034e 100644 --- a/resources/libraries/python/honeycomb/Netconf.py +++ b/resources/libraries/python/honeycomb/Netconf.py @@ -19,7 +19,6 @@ from time import time import paramiko from robot.api import logger -from interruptingcow import timeout from resources.libraries.python.honeycomb.HoneycombUtil import HoneycombError @@ -82,7 +81,6 @@ class Netconf(object): # read OpenDaylight's hello message and capability list self.get_response( size=131072, - time_out=time_out, err="Timeout on getting hello message." ) @@ -90,16 +88,14 @@ class Netconf(object): if not self.channel.active: raise HoneycombError("Channel closed on capabilities exchange.") - def get_response(self, size=4096, time_out=10, err="Unspecified Error."): + def get_response(self, size=4096, err="Unspecified Error."): """Iteratively read data from the receive buffer and catenate together until message ends with the message delimiter, or until timeout is reached. :param size: Maximum number of bytes to read in one iteration. - :param time_out: Timeout value for getting the complete response. :param err: Error message to provide when timeout is reached. :type size: int - :type time_out: int :type err: str :returns: Content of response. :rtype: str @@ -109,20 +105,19 @@ class Netconf(object): reply = '' try: - with timeout(time_out, exception=RuntimeError): - while not reply.endswith(self.delimiter) or \ - self.channel.recv_ready(): - try: - chunk = self.channel.recv(size) - if not chunk: - break - reply += chunk - if self.channel.exit_status_ready(): - logger.debug('Channel exit status ready.') - break - except socket.timeout: - raise HoneycombError("Socket timeout.", - enable_logging=False) + while not reply.endswith(self.delimiter) or \ + self.channel.recv_ready(): + try: + chunk = self.channel.recv(size) + if not chunk: + break + reply += chunk + if self.channel.exit_status_ready(): + logger.debug('Channel exit status ready.') + break + except socket.timeout: + raise HoneycombError("Socket timeout.", + enable_logging=False) except RuntimeError: raise HoneycombError(err + " Content of buffer: {0}".format(reply), @@ -148,7 +143,7 @@ class Netconf(object): while True: try: - response += self.get_response(size, time_out, err) + response += self.get_response(size, err) except HoneycombError: break diff --git a/resources/libraries/python/honeycomb/Notifications.py b/resources/libraries/python/honeycomb/Notifications.py index 58d835eca0..7bba00a2d2 100644 --- a/resources/libraries/python/honeycomb/Notifications.py +++ b/resources/libraries/python/honeycomb/Notifications.py @@ -42,7 +42,6 @@ class Notifications(Netconf): self.send(subscription) reply = self.get_response( - time_out=time_out, err="Timeout on notifications subscription." ) @@ -65,7 +64,6 @@ class Notifications(Netconf): .format(time_out)) reply = self.get_response( - time_out=time_out, err="Timeout on getting notification." ) diff --git a/resources/test_data/honeycomb/netconf/triggers.py b/resources/test_data/honeycomb/netconf/triggers.py index 899c258c06..8cdfcd9380 100644 --- a/resources/test_data/honeycomb/netconf/triggers.py +++ b/resources/test_data/honeycomb/netconf/triggers.py @@ -54,11 +54,11 @@ a:operation="replace"> 4fe335c8-6fdc-4654-b12c-d256e9b39229 neutron port enabled - + client /tmp/socket_4fe335c8-6fdc-4654-b12c-d256e9b39229 -x:vhost-user +x:vhost-user true @@ -144,11 +144,11 @@ a:operation="replace"> 4fe335c8-6fdc-4654-b12c-d256e9b39229 neutron port enabled - + client /tmp/socket_4fe335c8-6fdc-4654-b12c-d256e9b39229 -x:vhost-user +x:vhost-user true @@ -193,11 +193,11 @@ a:operation="replace"> d7611278-88ff-40e1-81e2-602e94e96fc7 neutron port enabled - + client /tmp/socket_d7611278-88ff-40e1-81e2-602e94e96fc7 -x:vhost-user +x:vhost-user true @@ -242,11 +242,11 @@ a:operation="replace"> 1f96a665-4351-4984-b1a8-dc6f54683123 neutron port enabled - + client /tmp/socket_1f96a665-4351-4984-b1a8-dc6f54683123 -x:vhost-user +x:vhost-user true @@ -285,7 +285,7 @@ a:operation="replace"> none - e86740a2-042c-4e64-a43b-cc224e0d5240 @@ -345,10 +345,10 @@ trigger_revert1 = u""" vxlan3 - + v3po:vxlan-tunnel true - + 192.168.1.6 192.168.1.7 9 @@ -370,10 +370,10 @@ trigger_revert1 = u""" vxlan4 - + v3po:vxlan-tunnel true - + 192.168.1.6 192.168.1.7 9 @@ -404,9 +404,9 @@ trigger_revert2 = u""" tap -v3po:tap +v3po:tap true - + tap @@ -425,9 +425,9 @@ trigger_revert2 = u""" tap2 -v3po:tap +v3po:tap true - + tap @@ -455,7 +455,7 @@ trigger_vlan = u""" {interface} - + @@ -472,7 +472,7 @@ trigger_vlan = u""" {interface} - + 2420 @@ -494,7 +494,7 @@ trigger_vlan = u""" {interface} - + 2420 diff --git a/resources/traffic_scripts/honeycomb/read_vpp_version.py b/resources/traffic_scripts/honeycomb/read_vpp_version.py index 70ba733ca1..6a275e7c0f 100755 --- a/resources/traffic_scripts/honeycomb/read_vpp_version.py +++ b/resources/traffic_scripts/honeycomb/read_vpp_version.py @@ -74,7 +74,7 @@ class ConfigBlaster(object): - +