diff options
| author | drebs <drebs@leap.se> | 2016-12-22 17:36:15 -0200 | 
|---|---|---|
| committer | drebs <drebs@leap.se> | 2016-12-22 17:36:15 -0200 | 
| commit | 8a463796bbaba3979234b0699d140947581421e7 (patch) | |
| tree | d1e2ea96ed91ac66c7e52a30d16246a498ae9ed6 /testing/tests/perf/test_encdecpool.py | |
| parent | f072f18f317ea31e66c7890d672b5d2fd9f3ef14 (diff) | |
| parent | e360a3a75999503cf45bfbbad69970a452cf3d32 (diff) | |
Merge tag '0.9.2'
Tag version 0.9.2
# gpg: Signature made Thu 22 Dec 2016 05:33:30 PM BRST
# gpg:                using RSA key 0x6071E70DCACC60B2
# gpg: Good signature from "drebs (work key) <db@leap.se>" [ultimate]
# gpg:                 aka "drebs (work key) <drebs@leap.se>" [ultimate]
# Impressão da chave primária: 9F73 295B 6306 E06F 3151  99AE 6071 E70D CACC 60B2
Diffstat (limited to 'testing/tests/perf/test_encdecpool.py')
| -rw-r--r-- | testing/tests/perf/test_encdecpool.py | 78 | 
1 files changed, 0 insertions, 78 deletions
| diff --git a/testing/tests/perf/test_encdecpool.py b/testing/tests/perf/test_encdecpool.py deleted file mode 100644 index 77091a41..00000000 --- a/testing/tests/perf/test_encdecpool.py +++ /dev/null @@ -1,78 +0,0 @@ -import pytest -import json -from uuid import uuid4 -from twisted.internet.defer import gatherResults -from leap.soledad.client.encdecpool import SyncEncrypterPool -from leap.soledad.client.encdecpool import SyncDecrypterPool -from leap.soledad.common.document import SoledadDocument -# FIXME: test load is low due issue #7370, higher values will get out of memory - - -def create_encrypt(amount, size): -    @pytest.mark.benchmark(group="test_pool_encrypt") -    @pytest.inlineCallbacks -    def test(soledad_client, txbenchmark_with_setup, request, payload): -        DOC_CONTENT = {'payload': payload(size)} - -        def setup(): -            client = soledad_client() -            pool = SyncEncrypterPool(client._crypto, client._sync_db) -            pool.start() -            request.addfinalizer(pool.stop) -            docs = [ -                SoledadDocument(doc_id=uuid4().hex, rev='rev', -                                json=json.dumps(DOC_CONTENT)) -                for _ in xrange(amount) -            ] -            return pool, docs - -        @pytest.inlineCallbacks -        def put_and_wait(pool, docs): -            yield gatherResults([pool.encrypt_doc(doc) for doc in docs]) - -        yield txbenchmark_with_setup(setup, put_and_wait) -    return test - -test_encdecpool_encrypt_100_10k = create_encrypt(100, 10*1000) -test_encdecpool_encrypt_100_100k = create_encrypt(100, 100*1000) -test_encdecpool_encrypt_100_500k = create_encrypt(100, 500*1000) - - -def create_decrypt(amount, size): -    @pytest.mark.benchmark(group="test_pool_decrypt") -    @pytest.inlineCallbacks -    def test(soledad_client, txbenchmark_with_setup, request, payload): -        DOC_CONTENT = {'payload': payload(size)} -        client = soledad_client() - -        def setup(): -            pool = SyncDecrypterPool( -                client._crypto, -                client._sync_db, -                source_replica_uid=client._dbpool.replica_uid, -                insert_doc_cb=lambda x, y, z: False)  # ignored -            pool.start(amount) -            request.addfinalizer(pool.stop) -            crypto = client._crypto -            docs = [] -            for _ in xrange(amount): -                doc = SoledadDocument( -                    doc_id=uuid4().hex, rev='rev', -                    json=json.dumps(DOC_CONTENT)) -                encrypted_content = json.loads(crypto.encrypt_doc(doc)) -                docs.append((doc.doc_id, encrypted_content)) -            return pool, docs - -        def put_and_wait(pool, docs): -            deferreds = []  # fires on completion -            for idx, (doc_id, content) in enumerate(docs, 1): -                deferreds.append(pool.insert_encrypted_received_doc( -                    doc_id, 'rev', content, idx, "trans_id", idx)) -            return gatherResults(deferreds) - -        yield txbenchmark_with_setup(setup, put_and_wait) -    return test - -test_encdecpool_decrypt_100_10k = create_decrypt(100, 10*1000) -test_encdecpool_decrypt_100_100k = create_decrypt(100, 100*1000) -test_encdecpool_decrypt_100_500k = create_decrypt(100, 500*1000) | 
