| 175 | self.__asyncIOService.registerAsyncSocketForWrite(self) |
| 176 | |
| 177 | def close(self): |
| 178 | if self.__closed: |
| 179 | return |
| 180 | |
| 181 | self.__asyncIOService.removeAsyncSocket(self) |
| 182 | self.__socket.close() |
| 183 | self.__closed = True |
| 184 | |
| 185 | if self.__acceptCallback: |
| 186 | self.__asyncIOService.invokeLater( |
| 187 | functools.partial(self.__acceptCallback, sock = None, err = errno.EBADF)) |
| 188 | self.__acceptCallback = None |
| 189 | |
| 190 | if self.__connectCallback: |
| 191 | self.__asyncIOService.invokeLater( |
| 192 | functools.partial(self.__connectCallback, err = errno.EBADF)) |
| 193 | self.__connectCallback = None |
| 194 | |
| 195 | if self.__readCallback: |
| 196 | self.__asyncIOService.invokeLater( |
| 197 | functools.partial(self.__readCallback, data = None, err = errno.EBADF)) |
| 198 | self.__readCallback = None |
| 199 | |
| 200 | if self.__writeAllCallback: |
| 201 | self.__asyncIOService.invokeLater( |
| 202 | functools.partial(self.__writeAllCallback, err = errno.EBADF)) |
| 203 | self.__writeAllCallback = None |
| 204 | |
| 205 | def handleError(self): |
| 206 | err = self.__socket.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR) |