X-Git-Url: http://git.lttng.org./?a=blobdiff_plain;ds=inline;f=tests%2Ftest_urcu_ja_range.c;h=898adafc126a74b7cf9a4d26b668ef7d4cdb62b1;hb=9a655aa82416c5df001c4ff7298344332e7d846a;hp=b4bc42909f5888fcc47937aa72f3ab3e24a38b7b;hpb=3d1d2331956ada311463d3fb10836fc21f97b126;p=userspace-rcu.git

diff --git a/tests/test_urcu_ja_range.c b/tests/test_urcu_ja_range.c
index b4bc429..898adaf 100644
--- a/tests/test_urcu_ja_range.c
+++ b/tests/test_urcu_ja_range.c
@@ -296,9 +296,13 @@ void *test_ja_rw_thr_writer(void *_count)
 				end = tmp;
 			}
 			rcu_read_lock();
-			range = cds_ja_range_add(test_ja, start, end, NULL);
-			if (!range) {
-				fprintf(stderr, "Error in cds_ja_range_add: %d\n");
+			ret = cds_ja_range_add(test_ja, start, end, NULL);
+			if (ret) {
+				if (ret == -EEXIST) {
+					URCU_TLS(nr_addexist)++;
+				} else {
+					assert(0);
+				}
 			} else {
 				URCU_TLS(nr_add)++;
 			}
@@ -371,13 +375,13 @@ int do_mt_populate_ja(void)
 		key = (unsigned long) iter;
 		key *= key_mul;
 		rcu_read_lock();
-		range = cds_ja_range_add(test_ja, key, key, NULL);
+		ret = cds_ja_range_add(test_ja, key, key, NULL);
 		URCU_TLS(nr_add)++;
 		URCU_TLS(nr_writes)++;
 		rcu_read_unlock();
-		if (!range) {
-			fprintf(stderr, "Error adding range %" PRIu64 "\n",
-				key);
+		if (ret) {
+			fprintf(stderr, "Error (%d) adding range %" PRIu64 "\n",
+				ret, key);
 			assert(0);
 		}
 	}
@@ -458,6 +462,9 @@ int do_mt_test(void)
 	}
 	rcu_thread_online_qsbr();
 
+	ret = cds_ja_range_validate(test_ja);
+	assert(!ret);
+
 	ret = cds_ja_range_destroy(test_ja, NULL);
 	if (ret) {
 		fprintf(stderr, "Error destroying judy array\n");