summaryrefslogtreecommitdiffstats
path: root/common/remoteidmap.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/remoteidmap.cpp')
-rw-r--r--common/remoteidmap.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/common/remoteidmap.cpp b/common/remoteidmap.cpp
index 2c3e5c7..da57cf6 100644
--- a/common/remoteidmap.cpp
+++ b/common/remoteidmap.cpp
@@ -27,7 +27,7 @@ using namespace Sink;
27 27
28SINK_DEBUG_AREA("remoteidmap") 28SINK_DEBUG_AREA("remoteidmap")
29 29
30RemoteIdMap::RemoteIdMap(Sink::Storage::Transaction &transaction) 30RemoteIdMap::RemoteIdMap(Sink::Storage::DataStore::Transaction &transaction)
31 : mTransaction(transaction) 31 : mTransaction(transaction)
32{ 32{
33 33
@@ -58,7 +58,7 @@ QByteArray RemoteIdMap::resolveRemoteId(const QByteArray &bufferType, const QByt
58 Index index("rid.mapping." + bufferType, mTransaction); 58 Index index("rid.mapping." + bufferType, mTransaction);
59 QByteArray sinkId = index.lookup(remoteId); 59 QByteArray sinkId = index.lookup(remoteId);
60 if (sinkId.isEmpty()) { 60 if (sinkId.isEmpty()) {
61 sinkId = Sink::Storage::generateUid(); 61 sinkId = Sink::Storage::DataStore::generateUid();
62 index.add(remoteId, sinkId); 62 index.add(remoteId, sinkId);
63 Index("localid.mapping." + bufferType, mTransaction).add(sinkId, remoteId); 63 Index("localid.mapping." + bufferType, mTransaction).add(sinkId, remoteId);
64 } 64 }
@@ -81,7 +81,7 @@ QByteArray RemoteIdMap::readValue(const QByteArray &key)
81 mTransaction.openDatabase("values").scan(key, [&value](const QByteArray &, const QByteArray &v) { 81 mTransaction.openDatabase("values").scan(key, [&value](const QByteArray &, const QByteArray &v) {
82 value = v; 82 value = v;
83 return false; 83 return false;
84 }, [](const Sink::Storage::Error &) { 84 }, [](const Sink::Storage::DataStore::Error &) {
85 //Ignore errors because we may not find the value 85 //Ignore errors because we may not find the value
86 }); 86 });
87 return value; 87 return value;