aboutsummaryrefslogtreecommitdiffstats
path: root/searchlib/src/tests/transactionlog
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-09-15 18:29:54 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-09-15 18:29:54 +0000
commitfbc9f364526587b0f312ef186e619a1f53c00617 (patch)
tree140d6237d7de933da0b5ea4011742b2276dea58b /searchlib/src/tests/transactionlog
parent7ecd25a81bb636174954da2caa8255cc1f7b3515 (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.cpp5
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) {