dart::SafepointTestTask Class Reference

Inheritance diagram for dart::SafepointTestTask:

Public Member Functions
	SafepointTestTask (Isolate *isolate, Monitor *monitor, intptr_t *expected_count, intptr_t *total_done, intptr_t *exited)
virtual void	Run ()
Public Member Functions inherited from dart::ThreadPool::Task
virtual	~Task ()
virtual void	Run ()=0
Public Member Functions inherited from dart::IntrusiveDListEntry< Task >
	IntrusiveDListEntry ()
	~IntrusiveDListEntry ()

Static Public Attributes
static constexpr intptr_t	kTaskCount = 5

Additional Inherited Members
Protected Member Functions inherited from dart::ThreadPool::Task
	Task ()

Detailed Description

Definition at line 523 of file thread_test.cc.

Constructor & Destructor Documentation

SafepointTestTask()

dart::SafepointTestTask::SafepointTestTask ( Isolate *  isolate, Monitor *  monitor, intptr_t *  expected_count, intptr_t *  total_done, intptr_t *  exited  )

inline

Definition at line 527 of file thread_test.cc.

      : isolate_(isolate),
        monitor_(monitor),
        expected_count_(expected_count),
        total_done_(total_done),
        exited_(exited),
        local_done_(false) {}

Member Function Documentation

Run()

virtual void dart::SafepointTestTask::Run ( )

inlinevirtual

Implements dart::ThreadPool::Task.

Definition at line 539 of file thread_test.cc.

                     {
    const bool kBypassSafepoint = false;
    Thread::EnterIsolateGroupAsHelper(isolate_->group(), Thread::kUnknownTask,
                                      kBypassSafepoint);
    {
      MonitorLocker ml(monitor_);
      ++*expected_count_;
    }
    Thread* thread = Thread::Current();
    for (int i = reinterpret_cast<intptr_t>(thread);; ++i) {
      StackZone stack_zone(thread);
      Zone* zone = thread->zone();
      const intptr_t kUniqueSmi = 928327281;
      Smi& smi = Smi::Handle(zone, Smi::New(kUniqueSmi));
      if ((i % 100) != 0) {
        // Usually, we just cooperate.
        TransitionVMToBlocked transition(thread);
      } else {
        // But occasionally, organize a rendezvous.
        HeapIterationScope iteration(thread);  // Establishes a safepoint.
        ASSERT(thread->OwnsSafepoint());
        ObjectCounter counter(isolate_->group(), &smi);
        iteration.IterateStackPointers(&counter,
                                       ValidationPolicy::kValidateFrames);
        {
          MonitorLocker ml(monitor_);
          EXPECT_EQ(*expected_count_, counter.count());
        }
        UserTag& tag = UserTag::Handle(zone, isolate_->current_tag());
        if (tag.ptr() != isolate_->default_tag()) {
          String& label = String::Handle(zone, tag.label());
          EXPECT(label.Equals("foo"));
          MonitorLocker ml(monitor_);
          if (*expected_count_ == kTaskCount && !local_done_) {
            // Success for the first time! Remember that we are done, and
            // update the total count.
            local_done_ = true;
            ++*total_done_;
          }
        }
      }
      // Check whether everyone is done.
      {
        MonitorLocker ml(monitor_);
        if (*total_done_ == kTaskCount) {
          // Another task might be at SafepointThreads when resuming. Ensure its
          // expectation reflects reality, since we pop our handles here.
          --*expected_count_;
          break;
        }
      }
    }
    Thread::ExitIsolateGroupAsHelper(kBypassSafepoint);
    {
      MonitorLocker ml(monitor_);
      ++*exited_;
      ml.Notify();
    }
  }

Member Data Documentation

kTaskCount

constexpr intptr_t dart::SafepointTestTask::kTaskCount = 5

staticconstexpr

Definition at line 525 of file thread_test.cc.

---

The documentation for this class was generated from the following file:

• third_party/dart-lang/sdk/runtime/vm/thread_test.cc