Use ServiceUnavailable in BufferingSocket

Author: technige

neo4j/v1/bolt.py

@@ -84,6 +84,7 @@
 class BufferingSocket(object):
 
     def __init__(self, socket):
+        self.address = socket.getpeername()
         self.socket = socket
         self.buffer = bytearray()
 
@@ -96,7 +97,7 @@ def fill(self):
             self.buffer[len(self.buffer):] = received
         else:
             if ready_to_read is not None:
-                raise ProtocolError("Server closed connection")
+                raise ServiceUnavailable("Failed to read from connection %r" % (self.address,))
 
     def read_message(self):
         message_data = bytearray()