(self)
| 135 | ) |
| 136 | |
| 137 | async def _close(self): |
| 138 | log.debug("Closing connection (%s) to %s" % (id(self), self.endpoint)) |
| 139 | if self._write_watcher: |
| 140 | self._write_watcher.cancel() |
| 141 | if self._read_watcher: |
| 142 | self._read_watcher.cancel() |
| 143 | if self._socket: |
| 144 | self._loop.remove_writer(self._socket.fileno()) |
| 145 | self._loop.remove_reader(self._socket.fileno()) |
| 146 | self._socket.close() |
| 147 | |
| 148 | log.debug("Closed socket to %s" % (self.endpoint,)) |
| 149 | |
| 150 | if not self.is_defunct: |
| 151 | self.error_all_requests( |
| 152 | ConnectionShutdown("Connection to %s was closed" % self.endpoint)) |
| 153 | # don't leave in-progress operations hanging |
| 154 | self.connected_event.set() |
| 155 | |
| 156 | def push(self, data): |
| 157 | buff_size = self.out_buffer_size |
no test coverage detected