aboutsummaryrefslogtreecommitdiffstats
path: root/searchlib/src/tests/transactionlogstress/translogstress.cpp
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-03-09 13:35:46 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2017-03-09 13:35:46 +0100
commit27821c298d6f61b025e400812cdd71871c1e3982 (patch)
tree377a8ae20b41f46631db2098c1b8eb41f477bce9 /searchlib/src/tests/transactionlogstress/translogstress.cpp
parent7f3e8265707321bf3156e2fe4d4f6e56d17ed557 (diff)
Deinline destructorsi and use -Winline gcc option.
Diffstat (limited to 'searchlib/src/tests/transactionlogstress/translogstress.cpp')
-rw-r--r--searchlib/src/tests/transactionlogstress/translogstress.cpp45
1 files changed, 28 insertions, 17 deletions
diff --git a/searchlib/src/tests/transactionlogstress/translogstress.cpp b/searchlib/src/tests/transactionlogstress/translogstress.cpp
index 1e569f8791a..c11aa62cd21 100644
--- a/searchlib/src/tests/transactionlogstress/translogstress.cpp
+++ b/searchlib/src/tests/transactionlogstress/translogstress.cpp
@@ -206,13 +206,19 @@ private:
public:
FeederThread(const std::string & tlsSpec, const std::string & domain,
- const EntryGenerator & generator, uint32_t feedRate, size_t packetSize) :
- _tlsSpec(tlsSpec), _domain(domain), _client(tlsSpec), _session(),
- _generator(generator), _feedRate(feedRate), _packet(packetSize), _current(1), _lastCommited(1), _timer() {}
+ const EntryGenerator & generator, uint32_t feedRate, size_t packetSize);
+ ~FeederThread();
virtual void doRun();
SerialNumRange getRange() const { return SerialNumRange(1, _lastCommited); }
};
+FeederThread::FeederThread(const std::string & tlsSpec, const std::string & domain,
+ const EntryGenerator & generator, uint32_t feedRate, size_t packetSize)
+ : _tlsSpec(tlsSpec), _domain(domain), _client(tlsSpec), _session(),
+ _generator(generator), _feedRate(feedRate), _packet(packetSize), _current(1), _lastCommited(1), _timer()
+{}
+FeederThread::~FeederThread() {}
+
void
FeederThread::commitPacket()
{
@@ -543,20 +549,8 @@ private:
public:
ControllerThread(const std::string & tlsSpec, const std::string & domain,
const EntryGenerator & generator, uint32_t numSubscribers, uint32_t numVisitors,
- uint64_t visitorInterval, uint64_t pruneInterval) :
- _tlsSpec(tlsSpec), _domain(domain), _client(tlsSpec.c_str()), _session(),
- _generator(generator), _subscribers(), _visitors(), _rndVisitors(), _visitorInterval(visitorInterval),
- _pruneInterval(pruneInterval), _pruneTimer(), _begin(0), _end(0), _count(0)
- {
- for (uint32_t i = 0; i < numSubscribers; ++i) {
- _subscribers.push_back(std::shared_ptr<SubscriberAgent>
- (new SubscriberAgent(tlsSpec, domain, generator, 0, i, true)));
- }
-
- for (uint32_t i = 0; i < numVisitors; ++i) {
- _visitors.push_back(std::shared_ptr<VisitorAgent>(new VisitorAgent(tlsSpec, domain, generator, i, true)));
- }
- }
+ uint64_t visitorInterval, uint64_t pruneInterval);
+ ~ControllerThread();
void startSubscribers();
uint32_t runningVisitors();
std::vector<std::shared_ptr<SubscriberAgent> > & getSubscribers() { return _subscribers; }
@@ -565,6 +559,23 @@ public:
};
+ControllerThread::ControllerThread(const std::string & tlsSpec, const std::string & domain,
+ const EntryGenerator & generator, uint32_t numSubscribers, uint32_t numVisitors,
+ uint64_t visitorInterval, uint64_t pruneInterval)
+ : _tlsSpec(tlsSpec), _domain(domain), _client(tlsSpec.c_str()), _session(),
+ _generator(generator), _subscribers(), _visitors(), _rndVisitors(), _visitorInterval(visitorInterval),
+ _pruneInterval(pruneInterval), _pruneTimer(), _begin(0), _end(0), _count(0)
+{
+ for (uint32_t i = 0; i < numSubscribers; ++i) {
+ _subscribers.push_back(std::make_shared<SubscriberAgent>(tlsSpec, domain, generator, 0, i, true));
+ }
+
+ for (uint32_t i = 0; i < numVisitors; ++i) {
+ _visitors.push_back(std::make_shared<VisitorAgent>(tlsSpec, domain, generator, i, true));
+ }
+}
+ControllerThread::~ControllerThread() {}
+
void
ControllerThread::getStatus()
{