From 9eb3a77a2b9d62ff5db5e10fd646badbbe73d701 Mon Sep 17 00:00:00 2001
From: Henning Baldersheim <balder@yahoo-inc.com>
Date: Fri, 12 Jan 2018 10:03:27 +0100
Subject: Revert "Revert "Balder/group multiple commits rebased 1""

---
 searchlib/src/tests/transactionlogstress/translogstress.cpp | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

(limited to 'searchlib/src/tests/transactionlogstress/translogstress.cpp')

diff --git a/searchlib/src/tests/transactionlogstress/translogstress.cpp b/searchlib/src/tests/transactionlogstress/translogstress.cpp
index abba84b75b6..6f2581d3799 100644
--- a/searchlib/src/tests/transactionlogstress/translogstress.cpp
+++ b/searchlib/src/tests/transactionlogstress/translogstress.cpp
@@ -8,7 +8,6 @@
 #include <vespa/searchlib/index/dummyfileheadercontext.h>
 #include <vespa/fastos/app.h>
 #include <iostream>
-#include <stdexcept>
 #include <sstream>
 
 #include <vespa/log/log.h>
@@ -221,7 +220,6 @@ 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
@@ -236,8 +234,9 @@ FeederThread::commitPacket()
 bool
 FeederThread::addEntry(const Packet::Entry & e)
 {
-    //LOG(info, "FeederThread: add %s", EntryPrinter::toStr(e).c_str());
-    return _packet.add(e);
+    if (_packet.sizeBytes() > 0xf000) return false;
+    _packet.add(e);
+    return true;
 }
 
 void
@@ -699,7 +698,7 @@ TransLogStress::Main()
 
     // start transaction log server
     DummyFileHeaderContext fileHeaderContext;
-    TransLogServer tls("server", 17897, ".", fileHeaderContext, _cfg.domainPartSize);
+    TransLogServer tls("server", 17897, ".", fileHeaderContext, DomainConfig().setPartSizeLimit(_cfg.domainPartSize));
     TransLogClient client(tlsSpec);
     client.create(domain);
 
-- 
cgit v1.2.3