Add missing barriers

opencog · Aug 7, 2020 · 09c8f1a · 09c8f1a
1 parent 9f1ad9c
commit 09c8f1a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/tests/persist/sql/multi-driver/QueryPersistUTest.cxxtest b/tests/persist/sql/multi-driver/QueryPersistUTest.cxxtest
@@ -292,6 +292,7 @@ void QueryPersistUTest::do_test_meet(void)
 
 	// Run the query
 	_as->fetch_query(qry, key);
+	_as->barrier();
 
 	// Verify that only bicycles and cars were fetched
 	ValuePtr results = qry->getValue(key);
@@ -317,6 +318,7 @@ void QueryPersistUTest::do_test_meet(void)
 
 	// Should get back the same results.
 	_as->fetch_query(qry, key);
+	_as->barrier();
 	ValuePtr rtoo = qry->getValue(key);
 	printf("Re-got: %s\n", rtoo->to_string().c_str());
 
@@ -359,6 +361,7 @@ void QueryPersistUTest::do_test_join(void)
 
 	// Run the join
 	_as->fetch_query(join, key);
+	_as->barrier();
 
 	// Verify that vehicles were fetched
 	ValuePtr results = join->getValue(key);