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

Just do whole thing in one thread job

Browse Source
This commit is contained in:
Itamar Turner-Trauring 2023-10-19 11:09:54 -04:00
parent 7f53f40d76
commit 5d896e8035
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/allmydata/mutable/publish.py
View File

@ -729,18 +729,17 @@ class Publish(object):
assert len(data) == segsize, len(data) assert len(data) == segsize, len(data)
salt = os.urandom(16)
key = await defer_to_thread(hashutil.ssk_readkey_data_hash, salt, self.readkey)
self._status.set_status("Encrypting") self._status.set_status("Encrypting")
def encrypt(): def encrypt(readkey):
salt = os.urandom(16)
key = hashutil.ssk_readkey_data_hash(salt, readkey)
encryptor = aes.create_encryptor(key) encryptor = aes.create_encryptor(key)
crypttext = aes.encrypt_data(encryptor, data) crypttext = aes.encrypt_data(encryptor, data)
assert len(crypttext) == len(data) assert len(crypttext) == len(data)
return crypttext return salt, crypttext
crypttext = await defer_to_thread(encrypt) salt, crypttext = await defer_to_thread(encrypt, self.readkey)
now = time.time() now = time.time()
self._status.accumulate_encrypt_time(now - started) self._status.accumulate_encrypt_time(now - started)