@@ -335,7 +335,7 @@ def open(cls, address, *, auth=None, timeout=None, routing_context=None, **pool_
335
335
from neo4j .io ._bolt4 import Bolt4x3
336
336
connection = Bolt4x3 (address , s , pool_config .max_connection_lifetime , auth = auth , user_agent = pool_config .user_agent , routing_context = routing_context )
337
337
else :
338
- log .debug ("[#%04X] S: <CLOSE>" , s .getpeername ()[1 ])
338
+ log .debug ("[#%04X] S: <CLOSE>" , s .getsockname ()[1 ])
339
339
_close_socket (s )
340
340
341
341
supported_versions = Bolt .protocol_handlers ().keys ()
@@ -540,7 +540,7 @@ def _set_defunct(self, message, error=None, silent=False):
540
540
direct_driver = isinstance (self .pool , BoltPool )
541
541
542
542
if error :
543
- log .error ( str ( error ) )
543
+ log .debug ( "[#%04X] %s" , self . socket . getsockname ()[ 1 ], error )
544
544
log .error (message )
545
545
# We were attempting to receive data but the connection
546
546
# has unexpectedly terminated. So, we need to close the
@@ -703,7 +703,9 @@ def release(self, *connections):
703
703
"""
704
704
with self .lock :
705
705
for connection in connections :
706
- if not connection .is_reset :
706
+ if not (connection .is_reset
707
+ or connection .defunct ()
708
+ or connection .closed ()):
707
709
try :
708
710
connection .reset ()
709
711
except (Neo4jError , DriverError , BoltError ) as e :
0 commit comments