diff options
Diffstat (limited to 'vespalib/src/tests/dual_merge_director/dual_merge_director_test.cpp')
-rw-r--r-- | vespalib/src/tests/dual_merge_director/dual_merge_director_test.cpp | 24 |
1 files changed, 14 insertions, 10 deletions
diff --git a/vespalib/src/tests/dual_merge_director/dual_merge_director_test.cpp b/vespalib/src/tests/dual_merge_director/dual_merge_director_test.cpp index 72fd17e76d5..b6621a75b84 100644 --- a/vespalib/src/tests/dual_merge_director/dual_merge_director_test.cpp +++ b/vespalib/src/tests/dual_merge_director/dual_merge_director_test.cpp @@ -10,16 +10,8 @@ struct MySource : public DualMergeDirector::Source { std::string data; std::string diff; - MySource(bool a, size_t num_sources, size_t source_id) - : typeA(a), - data(num_sources, '0'), - diff(num_sources, '5') - { - if (source_id < num_sources) { - data[source_id] = '1'; - diff[source_id] = '6'; - } - } + MySource(bool a, size_t num_sources, size_t source_id); + ~MySource(); virtual void merge(Source &mt) { MySource &rhs = static_cast<MySource&>(mt); ASSERT_EQUAL(typeA, rhs.typeA); @@ -40,6 +32,18 @@ struct MySource : public DualMergeDirector::Source { } }; +MySource::MySource(bool a, size_t num_sources, size_t source_id) + : typeA(a), + data(num_sources, '0'), + diff(num_sources, '5') +{ + if (source_id < num_sources) { + data[source_id] = '1'; + diff[source_id] = '6'; + } +} +MySource::~MySource() {} + TEST_MT_F("require that merging works", 64, std::unique_ptr<DualMergeDirector>()) { for (size_t use_threads = 1; use_threads <= num_threads; ++use_threads) { MySource sourceA(true, use_threads, thread_id); |