ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-04-19 00:06:57 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Run in thread

Browse Source
This commit is contained in:
Itamar Turner-Trauring 2023-10-16 11:41:07 -04:00
parent 6e93b12cb5
commit 07a1288ab9
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/allmydata/mutable/retrieve.py
View File

@ -895,8 +895,8 @@ class Retrieve(object):
d.addCallback(_process)
return d
def _decrypt_segment(self, segment_and_salt):
@deferredutil.async_to_deferred
async def _decrypt_segment(self, segment_and_salt):
"""
I take a single segment and its salt, and decrypt it. I return
the plaintext of the segment that is in my argument.
@ -905,9 +905,14 @@ class Retrieve(object):
self._set_current_status("decrypting")
self.log("decrypting segment %d" % self._current_segment)
started = time.time()
key = hashutil.ssk_readkey_data_hash(salt, self._node.get_readkey())
decryptor = aes.create_decryptor(key)
plaintext = aes.decrypt_data(decryptor, segment)
readkey = self._node.get_readkey()
def decrypt():
key = hashutil.ssk_readkey_data_hash(salt, readkey)
decryptor = aes.create_decryptor(key)
return aes.decrypt_data(decryptor, segment)
plaintext = await defer_to_thread(decrypt)
self._status.accumulate_decrypt_time(time.time() - started)
return plaintext