diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-21 19:07:55 +0000 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-21 19:44:41 +0000 |
| commit | 6eab511ac74f9c60427d3510a55003e4c7d380ac (patch) | |
| tree | f6fa98bf4bb10e729f1bc4cc1c69c53ea0ea6358 /searchlib/src/tests/transactionlog | |
| parent | 31b179d62e3dec85d9af5058857ed16fa81a4002 (diff) | |
Add startCommit method
Diffstat (limited to 'searchlib/src/tests/transactionlog')
| -rw-r--r-- | searchlib/src/tests/transactionlog/translogclient_test.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/searchlib/src/tests/transactionlog/translogclient_test.cpp b/searchlib/src/tests/transactionlog/translogclient_test.cpp index 9e5021b4778..478bc594368 100644 --- a/searchlib/src/tests/transactionlog/translogclient_test.cpp +++ b/searchlib/src/tests/transactionlog/translogclient_test.cpp @@ -329,11 +329,12 @@ fillDomainTest(TransLogServer & s1, const vespalib::string & domain, size_t numP Packet::Entry e(value+1, j+1, vespalib::ConstBufferRef((const char *)&value, sizeof(value))); p->add(e); if ( p->sizeBytes() > DEFAULT_PACKET_SIZE ) { - domainWriter->commit(*p, std::make_shared<CountDone>(inFlight)); + domainWriter->append(*p, std::make_shared<CountDone>(inFlight)); p = std::make_unique<Packet>(DEFAULT_PACKET_SIZE); } } - domainWriter->commit(*p, std::make_shared<CountDone>(inFlight)); + domainWriter->append(*p, std::make_shared<CountDone>(inFlight)); + domainWriter->startCommit(Writer::DoneCallback()); LOG(info, "Inflight %ld", inFlight.load()); } while (inFlight.load() != 0) { |