summaryrefslogtreecommitdiffstats
path: root/tests/pipelinetest.cpp
diff options
context:
space:
mode:
authorMinijackson <minijackson@riseup.net>2018-08-21 14:40:47 +0200
committerMinijackson <minijackson@riseup.net>2018-08-21 14:40:47 +0200
commit61348ed0b9e4c127169deb73e651c7a8f5ac8384 (patch)
treee82e966548b76c98f63a67273c53ff9e07aaa5e7 /tests/pipelinetest.cpp
parent258fb05e00e1fc03a227630d8e4def6d691158de (diff)
downloadsink-61348ed0b9e4c127169deb73e651c7a8f5ac8384.tar.gz
sink-61348ed0b9e4c127169deb73e651c7a8f5ac8384.zip
Fix pipelinetest
Diffstat (limited to 'tests/pipelinetest.cpp')
-rw-r--r--tests/pipelinetest.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/tests/pipelinetest.cpp b/tests/pipelinetest.cpp
index 34ee3a5..801a9e0 100644
--- a/tests/pipelinetest.cpp
+++ b/tests/pipelinetest.cpp
@@ -32,10 +32,10 @@ static QList<Sink::Storage::Key> getKeys(const QByteArray &dbEnv, const QByteArr
32{ 32{
33 Sink::Storage::DataStore store(Sink::storageLocation(), dbEnv, Sink::Storage::DataStore::ReadOnly); 33 Sink::Storage::DataStore store(Sink::storageLocation(), dbEnv, Sink::Storage::DataStore::ReadOnly);
34 auto transaction = store.createTransaction(Sink::Storage::DataStore::ReadOnly); 34 auto transaction = store.createTransaction(Sink::Storage::DataStore::ReadOnly);
35 auto db = transaction.openDatabase(name, nullptr, false); 35 auto db = transaction.openDatabase(name, nullptr, Sink::Storage::IntegerKeys);
36 QList<Sink::Storage::Key> result; 36 QList<Sink::Storage::Key> result;
37 db.scan("", [&](const QByteArray &key, const QByteArray &value) { 37 db.scan("", [&](const QByteArray &key, const QByteArray &value) {
38 size_t revision = Sink::byteArrayToSizeT(value); 38 size_t revision = Sink::byteArrayToSizeT(key);
39 result << Sink::Storage::Key(Sink::Storage::Identifier::fromDisplayByteArray( 39 result << Sink::Storage::Key(Sink::Storage::Identifier::fromDisplayByteArray(
40 Sink::Storage::DataStore::getUidFromRevision(transaction, revision)), 40 Sink::Storage::DataStore::getUidFromRevision(transaction, revision)),
41 revision); 41 revision);
@@ -48,7 +48,7 @@ static QByteArray getEntity(const QByteArray &dbEnv, const QByteArray &name, con
48{ 48{
49 Sink::Storage::DataStore store(Sink::storageLocation(), dbEnv, Sink::Storage::DataStore::ReadOnly); 49 Sink::Storage::DataStore store(Sink::storageLocation(), dbEnv, Sink::Storage::DataStore::ReadOnly);
50 auto transaction = store.createTransaction(Sink::Storage::DataStore::ReadOnly); 50 auto transaction = store.createTransaction(Sink::Storage::DataStore::ReadOnly);
51 auto db = transaction.openDatabase(name, nullptr, false); 51 auto db = transaction.openDatabase(name, nullptr, Sink::Storage::IntegerKeys);
52 QByteArray result; 52 QByteArray result;
53 db.scan(key.revision().toSizeT(), [&](size_t rev, const QByteArray &value) { 53 db.scan(key.revision().toSizeT(), [&](size_t rev, const QByteArray &value) {
54 result = value; 54 result = value;