ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-02-02 01:08:20 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Actually have a working run-in-thread code path

Browse Source
This commit is contained in:
Itamar Turner-Trauring 2023-01-31 15:53:16 -05:00
parent a092d78653
commit b477c59e15
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/allmydata/storage/http_server.py
View File

@ -545,11 +545,11 @@ class HTTPServer(object):
raise _HTTPError(http.UNSUPPORTED_MEDIA_TYPE) raise _HTTPError(http.UNSUPPORTED_MEDIA_TYPE)
# Make sure it's not too large: # Make sure it's not too large:
request.content.seek(SEEK_END, 0) request.content.seek(0, SEEK_END)
size = request.content.tell() size = request.content.tell()
if size > max_size: if size > max_size:
raise _HTTPError(http.REQUEST_ENTITY_TOO_LARGE) raise _HTTPError(http.REQUEST_ENTITY_TOO_LARGE)
request.content.seek(SEEK_SET, 0) request.content.seek(0, SEEK_SET)
# We don't want to load the whole message into memory, cause it might # We don't want to load the whole message into memory, cause it might
# be quite large. The CDDL validator takes a read-only bytes-like # be quite large. The CDDL validator takes a read-only bytes-like
@ -570,7 +570,7 @@ class HTTPServer(object):
# Pycddl will release the GIL when validating larger documents, so # Pycddl will release the GIL when validating larger documents, so
# let's take advantage of multiple CPUs: # let's take advantage of multiple CPUs:
if size > 10_000: if size > 10_000:
await deferToThread(reactor, schema.validate_cbor(message)) await deferToThread(schema.validate_cbor, message)
else: else:
schema.validate_cbor(message) schema.validate_cbor(message)