(self)
| 281 | _global_loop.maybe_start() |
| 282 | |
| 283 | def close(self): |
| 284 | with self.lock: |
| 285 | if self.is_closed: |
| 286 | return |
| 287 | self.is_closed = True |
| 288 | |
| 289 | log.debug("Closing connection (%s) to %s", id(self), self.endpoint) |
| 290 | |
| 291 | _global_loop.connection_destroyed(self) |
| 292 | self._socket.close() |
| 293 | log.debug("Closed socket to %s", self.endpoint) |
| 294 | |
| 295 | # don't leave in-progress operations hanging |
| 296 | if not self.is_defunct: |
| 297 | self.error_all_requests( |
| 298 | ConnectionShutdown("Connection to %s was closed" % self.endpoint)) |
| 299 | |
| 300 | def handle_write(self, watcher, revents, errno=None): |
| 301 | if revents & libev.EV_ERROR: |
no test coverage detected