diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2018-01-14 17:52:55 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-01-14 17:52:55 +0100 |
commit | 63966afece7d250b4ba4c03ad1f43ee7457b1dec (patch) | |
tree | fbdc3cdf92e3ed3bb2c0b657586d9885010323a7 /searchlib/src/tests/transactionlogstress/translogstress.cpp | |
parent | f909e2e5f34357af78e28dd4d948134a0fee50aa (diff) |
Revert "Revert "Revert "Balder/group multiple commits rebased 1"""
Diffstat (limited to 'searchlib/src/tests/transactionlogstress/translogstress.cpp')
-rw-r--r-- | searchlib/src/tests/transactionlogstress/translogstress.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/searchlib/src/tests/transactionlogstress/translogstress.cpp b/searchlib/src/tests/transactionlogstress/translogstress.cpp index 6f2581d3799..abba84b75b6 100644 --- a/searchlib/src/tests/transactionlogstress/translogstress.cpp +++ b/searchlib/src/tests/transactionlogstress/translogstress.cpp @@ -8,6 +8,7 @@ #include <vespa/searchlib/index/dummyfileheadercontext.h> #include <vespa/fastos/app.h> #include <iostream> +#include <stdexcept> #include <sstream> #include <vespa/log/log.h> @@ -220,6 +221,7 @@ FeederThread::~FeederThread() {} void FeederThread::commitPacket() { + _packet.close(); const vespalib::nbostream& stream = _packet.getHandle(); if (!_session->commit(ConstBufferRef(stream.c_str(), stream.size()))) { throw std::runtime_error(vespalib::make_string @@ -234,9 +236,8 @@ FeederThread::commitPacket() bool FeederThread::addEntry(const Packet::Entry & e) { - if (_packet.sizeBytes() > 0xf000) return false; - _packet.add(e); - return true; + //LOG(info, "FeederThread: add %s", EntryPrinter::toStr(e).c_str()); + return _packet.add(e); } void @@ -698,7 +699,7 @@ TransLogStress::Main() // start transaction log server DummyFileHeaderContext fileHeaderContext; - TransLogServer tls("server", 17897, ".", fileHeaderContext, DomainConfig().setPartSizeLimit(_cfg.domainPartSize)); + TransLogServer tls("server", 17897, ".", fileHeaderContext, _cfg.domainPartSize); TransLogClient client(tlsSpec); client.create(domain); |