Differential D15057 Diff 40365 common/storage/entitystore.cpp

Changeset View

Standalone View

View Options

common/storage/entitystore.cpp

Context not available.
318 flatbuffers::FlatBufferBuilder fbb; 318​ flatbuffers::FlatBufferBuilder fbb;
319 d->resourceContext.adaptorFactory(type).createBuffer(newEntity, fbb, metadataFbb.GetBufferPointer(), metadataFbb.GetSize()); 319​ d->resourceContext.adaptorFactory(type).createBuffer(newEntity, fbb, metadataFbb.GetBufferPointer(), metadataFbb.GetSize());
320 320​
321 const auto key = Key(identifier, newRevision); ​
322 ​
323 DataStore::mainDatabase(d->transaction, type) 321​ DataStore::mainDatabase(d->transaction, type)
324 .write(newRevision, BufferUtils::extractBuffer(fbb), 322​ .write(newRevision, BufferUtils::extractBuffer(fbb),
325 [&](const DataStore::Error &error) { SinkWarningCtx(d->logCtx) << "Failed to write entity" << newEntity.identifier() << newRevision; }); 323​ [&](const DataStore::Error &error) { SinkWarningCtx(d->logCtx) << "Failed to write entity" << newEntity.identifier() << newRevision; });
Context not available.
356 flatbuffers::FlatBufferBuilder fbb; 354​ flatbuffers::FlatBufferBuilder fbb;
357 EntityBuffer::assembleEntityBuffer(fbb, metadataFbb.GetBufferPointer(), metadataFbb.GetSize(), 0, 0, 0, 0); 355​ EntityBuffer::assembleEntityBuffer(fbb, metadataFbb.GetBufferPointer(), metadataFbb.GetSize(), 0, 0, 0, 0);
358 356​
359 const auto key = Key(identifier, newRevision); ​
360 ​
361 DataStore::mainDatabase(d->transaction, type) 357​ DataStore::mainDatabase(d->transaction, type)
362 .write(newRevision, BufferUtils::extractBuffer(fbb), 358​ .write(newRevision, BufferUtils::extractBuffer(fbb),
363 [&](const DataStore::Error &error) { SinkWarningCtx(d->logCtx) << "Failed to write entity" << uid << newRevision; }); 359​ [&](const DataStore::Error &error) { SinkWarningCtx(d->logCtx) << "Failed to write entity" << uid << newRevision; });
Context not available.
397 } 393​ }
398 394​
399 const auto metadata = flatbuffers::GetRoot<Metadata>(buffer.metadataBuffer()); 395​ const auto metadata = flatbuffers::GetRoot<Metadata>(buffer.metadataBuffer());
400 const qint64 rev = metadata->revision(); ​
401 if (metadata->operation() == Operation_Removal) { 396​ if (metadata->operation() == Operation_Removal) {
402 DataStore::removeRevision(d->transaction, revision); 397​ DataStore::removeRevision(d->transaction, revision);
403 DataStore::mainDatabase(d->transaction, bufferType).remove(revision); 398​ DataStore::mainDatabase(d->transaction, bufferType).remove(revision);
Context not available.
666 return true; 661​ return true;
667} 662​}
668 663​
669void EntityStore::readRevisions(const QByteArray &type, const QByteArray &uid, qint64 startingRevision, 664​void EntityStore::readRevisions(const QByteArray &type, const QByteArray &uid, size_t startingRevision,
670 const std::function<void(const QByteArray &uid, qint64 revision, const EntityBuffer &entity)> callback) 665​ const std::function<void(const QByteArray &uid, qint64 revision, const EntityBuffer &entity)> callback)
671{ 666​{
672 Q_ASSERT(d); 667​ Q_ASSERT(d);
Context not available.