diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-15 18:29:54 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-15 18:29:54 +0000 |
commit | fbc9f364526587b0f312ef186e619a1f53c00617 (patch) | |
tree | 140d6237d7de933da0b5ea4011742b2276dea58b /searchlib/src/tests/transactionlog | |
parent | 7ecd25a81bb636174954da2caa8255cc1f7b3515 (diff) |
Avoid a lookup and copying a shared_ptr by looking up and using the domain directly.
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 3ee5b73102e..80142f705c1 100644 --- a/searchlib/src/tests/transactionlog/translogclient_test.cpp +++ b/searchlib/src/tests/transactionlog/translogclient_test.cpp @@ -322,17 +322,18 @@ fillDomainTest(TransLogServer & s1, const vespalib::string & domain, size_t numP { size_t value(0); Counter inFlight(0); + auto domainWriter = s1.getWriter(domain); for(size_t i=0; i < numPackets; i++) { std::unique_ptr<Packet> p(new Packet(DEFAULT_PACKET_SIZE)); for(size_t j=0; j < numEntries; j++, value++) { Packet::Entry e(value+1, j+1, vespalib::ConstBufferRef((const char *)&value, sizeof(value))); p->add(e); if ( p->sizeBytes() > DEFAULT_PACKET_SIZE ) { - s1.commit(domain, *p, std::make_shared<CountDone>(inFlight)); + domainWriter->commit(*p, std::make_shared<CountDone>(inFlight)); p = std::make_unique<Packet>(DEFAULT_PACKET_SIZE); } } - s1.commit(domain, *p, std::make_shared<CountDone>(inFlight)); + domainWriter->commit(*p, std::make_shared<CountDone>(inFlight)); LOG(info, "Inflight %ld", inFlight.load()); } while (inFlight.load() != 0) { |