|
@@ -43,7 +43,7 @@ int test__thread_mg_share(void)
|
|
leader && t1 && t2 && t3 && other);
|
|
leader && t1 && t2 && t3 && other);
|
|
|
|
|
|
mg = leader->mg;
|
|
mg = leader->mg;
|
|
- TEST_ASSERT_EQUAL("wrong refcnt", mg->refcnt, 4);
|
|
|
|
|
|
+ TEST_ASSERT_EQUAL("wrong refcnt", atomic_read(&mg->refcnt), 4);
|
|
|
|
|
|
/* test the map groups pointer is shared */
|
|
/* test the map groups pointer is shared */
|
|
TEST_ASSERT_VAL("map groups don't match", mg == t1->mg);
|
|
TEST_ASSERT_VAL("map groups don't match", mg == t1->mg);
|
|
@@ -71,25 +71,25 @@ int test__thread_mg_share(void)
|
|
machine__remove_thread(machine, other_leader);
|
|
machine__remove_thread(machine, other_leader);
|
|
|
|
|
|
other_mg = other->mg;
|
|
other_mg = other->mg;
|
|
- TEST_ASSERT_EQUAL("wrong refcnt", other_mg->refcnt, 2);
|
|
|
|
|
|
+ TEST_ASSERT_EQUAL("wrong refcnt", atomic_read(&other_mg->refcnt), 2);
|
|
|
|
|
|
TEST_ASSERT_VAL("map groups don't match", other_mg == other_leader->mg);
|
|
TEST_ASSERT_VAL("map groups don't match", other_mg == other_leader->mg);
|
|
|
|
|
|
/* release thread group */
|
|
/* release thread group */
|
|
thread__put(leader);
|
|
thread__put(leader);
|
|
- TEST_ASSERT_EQUAL("wrong refcnt", mg->refcnt, 3);
|
|
|
|
|
|
+ TEST_ASSERT_EQUAL("wrong refcnt", atomic_read(&mg->refcnt), 3);
|
|
|
|
|
|
thread__put(t1);
|
|
thread__put(t1);
|
|
- TEST_ASSERT_EQUAL("wrong refcnt", mg->refcnt, 2);
|
|
|
|
|
|
+ TEST_ASSERT_EQUAL("wrong refcnt", atomic_read(&mg->refcnt), 2);
|
|
|
|
|
|
thread__put(t2);
|
|
thread__put(t2);
|
|
- TEST_ASSERT_EQUAL("wrong refcnt", mg->refcnt, 1);
|
|
|
|
|
|
+ TEST_ASSERT_EQUAL("wrong refcnt", atomic_read(&mg->refcnt), 1);
|
|
|
|
|
|
thread__put(t3);
|
|
thread__put(t3);
|
|
|
|
|
|
/* release other group */
|
|
/* release other group */
|
|
thread__put(other_leader);
|
|
thread__put(other_leader);
|
|
- TEST_ASSERT_EQUAL("wrong refcnt", other_mg->refcnt, 1);
|
|
|
|
|
|
+ TEST_ASSERT_EQUAL("wrong refcnt", atomic_read(&other_mg->refcnt), 1);
|
|
|
|
|
|
thread__put(other);
|
|
thread__put(other);
|
|
|
|
|