summaryrefslogtreecommitdiffstats
path: root/tests/wirs_tests.cpp
diff options
context:
space:
mode:
authorDouglas Rumbaugh <dbr4@psu.edu>2023-05-29 14:30:08 -0400
committerDouglas Rumbaugh <dbr4@psu.edu>2023-05-29 14:30:08 -0400
commite920fa57cf9c503e560055864e4de37912b239e1 (patch)
treed0daba733c7af2b0b22f29d39de8f824ffa83472 /tests/wirs_tests.cpp
parentb00682429988f17152e7573ffeffa1cecfdd3d3a (diff)
downloaddynamic-extension-e920fa57cf9c503e560055864e4de37912b239e1.tar.gz
Adjusted the way that Wrapping records works to clean up interfaces
Diffstat (limited to 'tests/wirs_tests.cpp')
-rw-r--r--tests/wirs_tests.cpp30
1 files changed, 15 insertions, 15 deletions
diff --git a/tests/wirs_tests.cpp b/tests/wirs_tests.cpp
index 3a80a9e..ba4b754 100644
--- a/tests/wirs_tests.cpp
+++ b/tests/wirs_tests.cpp
@@ -17,39 +17,39 @@
using namespace de;
-typedef WIRS<WrappedWRec> Shard;
+typedef WIRS<WRec> Shard;
START_TEST(t_mbuffer_init)
{
- auto mem_table = new MutableBuffer<WrappedWRec>(1024, true, 1024);
+ auto buffer = new MutableBuffer<WRec>(1024, true, 1024);
for (uint64_t i = 512; i > 0; i--) {
uint32_t v = i;
- mem_table->append({i,v, 1});
+ buffer->append({i,v, 1});
}
for (uint64_t i = 1; i <= 256; ++i) {
uint32_t v = i;
- mem_table->append({i, v, 1, 1});
+ buffer->append({i, v, 1}, true);
}
for (uint64_t i = 257; i <= 512; ++i) {
uint32_t v = i + 1;
- mem_table->append({i, v, 1});
+ buffer->append({i, v, 1});
}
- Shard* shard = new Shard(mem_table);
+ Shard* shard = new Shard(buffer);
ck_assert_uint_eq(shard->get_record_count(), 512);
- delete mem_table;
+ delete buffer;
delete shard;
}
START_TEST(t_wirs_init)
{
size_t n = 512;
- auto mbuffer1 = create_test_mbuffer<WrappedWRec>(n);
- auto mbuffer2 = create_test_mbuffer<WrappedWRec>(n);
- auto mbuffer3 = create_test_mbuffer<WrappedWRec>(n);
+ auto mbuffer1 = create_test_mbuffer<WRec>(n);
+ auto mbuffer2 = create_test_mbuffer<WRec>(n);
+ auto mbuffer3 = create_test_mbuffer<WRec>(n);
auto shard1 = new Shard(mbuffer1);
auto shard2 = new Shard(mbuffer2);
@@ -73,11 +73,11 @@ START_TEST(t_wirs_init)
auto cur_rec = shard4->get_record_at(i);
- if (shard1_idx < n && *cur_rec == *rec1) {
+ if (shard1_idx < n && cur_rec->rec == rec1->rec) {
++shard1_idx;
- } else if (shard2_idx < n && *cur_rec == *rec2) {
+ } else if (shard2_idx < n && cur_rec->rec == rec2->rec) {
++shard2_idx;
- } else if (shard3_idx < n && *cur_rec == *rec3) {
+ } else if (shard3_idx < n && cur_rec->rec == rec3->rec) {
++shard3_idx;
} else {
assert(false);
@@ -123,8 +123,8 @@ START_TEST(t_get_lower_bound_index)
START_TEST(t_full_cancelation)
{
size_t n = 100;
- auto buffer = create_double_seq_mbuffer<WrappedWRec>(n, false);
- auto buffer_ts = create_double_seq_mbuffer<WrappedWRec>(n, true);
+ auto buffer = create_double_seq_mbuffer<WRec>(n, false);
+ auto buffer_ts = create_double_seq_mbuffer<WRec>(n, true);
Shard* shard = new Shard(buffer);
Shard* shard_ts = new Shard(buffer_ts);