def _error(self, e):
self.close()
self.factory.error_buffer.record(e)
if self.factory.deferred:
try:
self.factory.deferred.errback(utils.format_error(e))
except defer.AlreadyCalledError:
pass