progress towards resolving asynch structure merges

1 files changed, 12 insertions, 0 deletions

diff --git a/benchmarks/tail-latency/standard_latency_dist.cpp b/benchmarks/tail-latency/standard_latency_dist.cpp
index 34949d4..5c96a73 100644
--- a/benchmarks/tail-latency/standard_latency_dist.cpp
+++ b/benchmarks/tail-latency/standard_latency_dist.cpp
@@ -70,6 +70,13 @@ int main(int argc, char **argv) {
             while (!extension->insert(data[j])) {
                 usleep(1);
             }
+            if (j + 1 != extension->get_record_count()) {
+                fprintf(stderr, "[E] %ld\t%ld\n", j+1, extension->get_record_count());
+                extension->print_structure();
+                fflush(stderr);
+                fflush(stdout);
+            }
+            assert(j+1 == extension->get_record_count());
         }
 
         extension->await_version();
@@ -82,6 +89,11 @@ int main(int argc, char **argv) {
                 fprintf(stderr, "[B] %ld %ld\n", j, extension->get_record_count());
                 usleep(1);
             }
+
+            if (j + 1 != extension->get_record_count()) {
+                fprintf(stderr, "[E] %ld\t%ld\n", j+1, extension->get_record_count());
+            }
+            assert(j+1 == extension->get_record_count());
         }
         TIMER_STOP();