(self, buffer_size)
| 372 | raise |
| 373 | |
| 374 | def recv(self, buffer_size): |
| 375 | try: |
| 376 | data = self.socket.recv(buffer_size) |
| 377 | if not data: |
| 378 | # a closed connection is indicated by signaling |
| 379 | # a read condition, and having recv() return 0. |
| 380 | self.handle_close() |
| 381 | return b'' |
| 382 | else: |
| 383 | return data |
| 384 | except OSError as why: |
| 385 | # winsock sometimes raises ENOTCONN |
| 386 | if why.errno in _DISCONNECTED: |
| 387 | self.handle_close() |
| 388 | return b'' |
| 389 | else: |
| 390 | raise |
| 391 | |
| 392 | def close(self): |
| 393 | self.connected = False |
nothing calls this directly
no test coverage detected