From 925e974c6380a2cf4e8aee6f0b3868121f52092c Mon Sep 17 00:00:00 2001 From: Fabio Erculiani Date: Sat, 1 Aug 2009 18:50:03 +0200 Subject: [PATCH] [entropy.services.interfaces] add future-proof SSL socket polling handler --- libraries/entropy/services/interfaces.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/libraries/entropy/services/interfaces.py b/libraries/entropy/services/interfaces.py index 5bcf30a0b..b63eed30e 100644 --- a/libraries/entropy/services/interfaces.py +++ b/libraries/entropy/services/interfaces.py @@ -400,6 +400,13 @@ class SocketHost: client_address, server) self.__data_counter = None + def _ssl_poll(self, filter_type, caller_name): + poller = self.select.poll() + poller.register(self.request, filter_type) + res = poller.poll(self.request.gettimeout() * 1000) + if len(res) != 1: + raise TimeoutError("Connection timed out on %s" % caller_name) + def data_receiver(self): if self.timed_out: