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