(self)
| 713 | print('%s: %s' % (log_type, message)) |
| 714 | |
| 715 | def handle_read_event(self): |
| 716 | if self.accepting: |
| 717 | # accepting sockets are never connected, they "spawn" new |
| 718 | # sockets that are connected |
| 719 | self.handle_accept() |
| 720 | elif not self.connected: |
| 721 | if self.connecting: |
| 722 | self.handle_connect_event() |
| 723 | self.handle_read() |
| 724 | else: |
| 725 | self.handle_read() |
| 726 | |
| 727 | def handle_connect_event(self): |
| 728 | err = self.socket.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR) |
no test coverage detected