Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(252)

Unified Diff: runtime/vm/thread_test.cc

Issue 2995543004: [vm, gc] Require a safepoint for heap iteration. (Closed)
Patch Set: explicit-thread Created 3 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « runtime/vm/symbols.cc ('k') | runtime/vm/verifier.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: runtime/vm/thread_test.cc
diff --git a/runtime/vm/thread_test.cc b/runtime/vm/thread_test.cc
index befe7a8ac62fcf18ea010a0dc85514f3e7e4d624..4c6482206ccac0be7f67c24eb51ff0790c9e6ac1 100644
--- a/runtime/vm/thread_test.cc
+++ b/runtime/vm/thread_test.cc
@@ -130,10 +130,11 @@ class TaskWithZoneAllocation : public ThreadPool::Task {
Smi& smi = Smi::Handle(zone, Smi::New(unique_smi));
EXPECT(smi.Value() == unique_smi);
{
+ HeapIterationScope iteration(thread);
ObjectCounter counter(isolate_, &smi);
// Ensure that our particular zone is visited.
- isolate_->IterateObjectPointers(&counter,
- StackFrameIterator::kValidateFrames);
+ iteration.IterateStackPointers(&counter,
+ StackFrameIterator::kValidateFrames);
EXPECT_EQ(1, counter.count());
}
char* unique_chars = zone->PrintToString("unique_str_%" Pd, id_);
@@ -146,10 +147,11 @@ class TaskWithZoneAllocation : public ThreadPool::Task {
}
EXPECT(unique_str.Equals(unique_chars));
{
+ HeapIterationScope iteration(thread);
ObjectCounter str_counter(isolate_, &unique_str);
// Ensure that our particular zone is visited.
- isolate_->IterateObjectPointers(&str_counter,
- StackFrameIterator::kValidateFrames);
+ iteration.IterateStackPointers(&str_counter,
+ StackFrameIterator::kValidateFrames);
// We should visit the string object exactly once.
EXPECT_EQ(1, str_counter.count());
}
@@ -173,7 +175,7 @@ ISOLATE_UNIT_TEST_CASE(ManyTasksWithZones) {
const int kTaskCount = 100;
Monitor sync[kTaskCount];
bool done[kTaskCount];
- Isolate* isolate = Thread::Current()->isolate();
+ Isolate* isolate = thread->isolate();
EXPECT(isolate->heap()->GrowthControlState());
isolate->heap()->DisableGrowthControl();
for (int i = 0; i < kTaskCount; i++) {
@@ -181,20 +183,27 @@ ISOLATE_UNIT_TEST_CASE(ManyTasksWithZones) {
Dart::thread_pool()->Run(
new TaskWithZoneAllocation(isolate, &sync[i], &done[i], i));
}
+ bool in_isolate = true;
for (int i = 0; i < kTaskCount; i++) {
// Check that main mutator thread can still freely use its own zone.
String& bar = String::Handle(String::New("bar"));
if (i % 10 == 0) {
// Mutator thread is free to independently move in/out/between isolates.
Thread::ExitIsolate();
+ in_isolate = false;
}
MonitorLocker ml(&sync[i]);
while (!done[i]) {
- ml.Wait();
+ if (in_isolate) {
+ ml.WaitWithSafepointCheck(thread);
+ } else {
+ ml.Wait();
+ }
}
EXPECT(done[i]);
if (i % 10 == 0) {
Thread::EnterIsolate(isolate);
+ in_isolate = true;
}
EXPECT(bar.Equals("bar"));
}
@@ -421,10 +430,11 @@ class SafepointTestTask : public ThreadPool::Task {
TransitionVMToBlocked transition(thread);
} else {
// But occasionally, organize a rendezvous.
- SafepointOperationScope safepoint_scope(thread);
+ HeapIterationScope iteration(thread); // Establishes a safepoint.
+ ASSERT(thread->IsAtSafepoint());
ObjectCounter counter(isolate_, &smi);
- isolate_->IterateObjectPointers(&counter,
- StackFrameIterator::kValidateFrames);
+ iteration.IterateStackPointers(&counter,
+ StackFrameIterator::kValidateFrames);
{
MonitorLocker ml(monitor_);
EXPECT_EQ(*expected_count_, counter.count());
« no previous file with comments | « runtime/vm/symbols.cc ('k') | runtime/vm/verifier.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698