diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-03-09 13:35:46 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-03-09 13:35:46 +0100 |
commit | 27821c298d6f61b025e400812cdd71871c1e3982 (patch) | |
tree | 377a8ae20b41f46631db2098c1b8eb41f477bce9 /searchlib/src/tests/transactionlogstress/translogstress.cpp | |
parent | 7f3e8265707321bf3156e2fe4d4f6e56d17ed557 (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.cpp | 45 |
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() { |