equal
deleted
inserted
replaced
310 setvreg=False) #cnxprops=cnxprops) |
310 setvreg=False) #cnxprops=cnxprops) |
311 |
311 |
312 def get_connection(self): |
312 def get_connection(self): |
313 try: |
313 try: |
314 return self._get_connection() |
314 return self._get_connection() |
315 except (ConnectionError, PyroError): |
315 except (ConnectionError, PyroError), ex: |
316 self.critical("can't get connection to source %s", self.uri, |
316 self.critical("can't get connection to source %s: %s", self.uri, ex) |
317 exc_info=1) |
|
318 return ConnectionWrapper() |
317 return ConnectionWrapper() |
319 |
318 |
320 def check_connection(self, cnx): |
319 def check_connection(self, cnx): |
321 """check connection validity, return None if the connection is still valid |
320 """check connection validity, return None if the connection is still valid |
322 else a new connection |
321 else a new connection |