summaryrefslogtreecommitdiffstats
path: root/vespalib/src/tests/dual_merge_director/dual_merge_director_test.cpp
diff options
context:
space:
mode:
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.cpp24
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);