diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-12-06 11:17:33 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-12-06 11:17:33 +0000 |
commit | a204a7f1938031e0e44114e744c76f2e5bdeca0e (patch) | |
tree | e1bd0056faf01788af3261d61bb4bd49d5ccf12c /searchlib | |
parent | ae09069f544a086af4ae02a092ec66788a3cae9e (diff) |
We already have the serialnum in the range.
Diffstat (limited to 'searchlib')
-rw-r--r-- | searchlib/src/vespa/searchlib/transactionlog/domain.cpp | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/searchlib/src/vespa/searchlib/transactionlog/domain.cpp b/searchlib/src/vespa/searchlib/transactionlog/domain.cpp index aa49a2d2954..24943b53e6d 100644 --- a/searchlib/src/vespa/searchlib/transactionlog/domain.cpp +++ b/searchlib/src/vespa/searchlib/transactionlog/domain.cpp @@ -403,13 +403,10 @@ void Domain::doCommit(std::unique_ptr<CommitChunk> chunk) { const Packet & packet = chunk->getPacket(); if (packet.empty()) return; - - vespalib::nbostream_longlivedbuf is(packet.getHandle().data(), packet.getHandle().size()); - Packet::Entry entry; - entry.deserialize(is); - assert(entry.serial() == packet.range().from()); - DomainPart::SP dp = optionallyRotateFile(entry.serial()); - dp->commit(entry.serial(), packet); + + SerialNum firstSerial = packet.range().from(); + DomainPart::SP dp = optionallyRotateFile(firstSerial); + dp->commit(firstSerial, packet); if (_config.getFSyncOnCommit()) { dp->sync(); } |