Fixed a few concurrency bugs

1 files changed, 4 insertions, 4 deletions

diff --git a/tests/include/rangecount.h b/tests/include/rangecount.h
index b77c77d..2640e84 100644
--- a/tests/include/rangecount.h
+++ b/tests/include/rangecount.h
@@ -38,7 +38,7 @@
 START_TEST(t_range_count)
 {
     auto buffer = create_sequential_mbuffer<R>(100, 1000);
-    auto shard = Shard(buffer->get_buffer_view());
+    auto shard = Shard(buffer->get_buffer_view(buffer->debug_get_head()));
 
     rc::Query<Shard>::Parameters parms = {300, 500};
 
@@ -61,7 +61,7 @@ START_TEST(t_buffer_range_count)
     rc::Query<Shard>::Parameters parms = {300, 500};
 
     {
-        auto view = buffer->get_buffer_view();
+        auto view = buffer->get_buffer_view(buffer->debug_get_head());
         auto query = rc::Query<Shard>::local_preproc_buffer(&view, &parms);
         auto result = rc::Query<Shard>::local_query_buffer(query); 
         delete query;
@@ -79,8 +79,8 @@ START_TEST(t_range_count_merge)
     auto buffer1 = create_sequential_mbuffer<R>(100, 200);
     auto buffer2 = create_sequential_mbuffer<R>(400, 1000);
 
-    auto shard1 = Shard(buffer1->get_buffer_view());
-    auto shard2 = Shard(buffer2->get_buffer_view());
+    auto shard1 = Shard(buffer1->get_buffer_view(buffer1->debug_get_head()));
+    auto shard2 = Shard(buffer2->get_buffer_view(buffer2->debug_get_head()));
 
     rc::Query<Shard>::Parameters parms = {150, 500};