mirror of
https://github.com/frappe/gunicorn.git
synced 2026-01-14 11:09:11 +08:00
parent
1dad259ba4
commit
011ae33c0a
@ -78,7 +78,6 @@ class AsyncWorker(base.Worker):
|
|||||||
respiter.close()
|
respiter.close()
|
||||||
if req.should_close():
|
if req.should_close():
|
||||||
raise StopIteration()
|
raise StopIteration()
|
||||||
self.cfg.post_request(self, req)
|
|
||||||
except StopIteration:
|
except StopIteration:
|
||||||
raise
|
raise
|
||||||
except Exception, e:
|
except Exception, e:
|
||||||
@ -87,4 +86,9 @@ class AsyncWorker(base.Worker):
|
|||||||
raise
|
raise
|
||||||
util.write_error(sock, traceback.format_exc())
|
util.write_error(sock, traceback.format_exc())
|
||||||
return False
|
return False
|
||||||
|
finally:
|
||||||
|
try:
|
||||||
|
self.cfg.post_request(self, req)
|
||||||
|
except:
|
||||||
|
pass
|
||||||
return True
|
return True
|
||||||
|
|||||||
@ -104,7 +104,6 @@ class SyncWorker(base.Worker):
|
|||||||
resp.close()
|
resp.close()
|
||||||
if hasattr(respiter, "close"):
|
if hasattr(respiter, "close"):
|
||||||
respiter.close()
|
respiter.close()
|
||||||
self.cfg.post_request(self, req)
|
|
||||||
except socket.error:
|
except socket.error:
|
||||||
raise
|
raise
|
||||||
except Exception, e:
|
except Exception, e:
|
||||||
@ -113,3 +112,9 @@ class SyncWorker(base.Worker):
|
|||||||
raise
|
raise
|
||||||
util.write_error(client, traceback.format_exc())
|
util.write_error(client, traceback.format_exc())
|
||||||
return
|
return
|
||||||
|
finally:
|
||||||
|
try:
|
||||||
|
self.cfg.post_request(self, req)
|
||||||
|
except:
|
||||||
|
pass
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user