dart::SampleBuffer Class Reference

#include <profiler.h>

Inheritance diagram for dart::SampleBuffer:

Public Member Functions
	SampleBuffer ()=default
virtual	~SampleBuffer ()=default
virtual void	Init (Sample *samples, intptr_t capacity)
void	VisitSamples (SampleVisitor *visitor)
virtual Sample *	ReserveSample ()=0
virtual Sample *	ReserveSampleAndLink (Sample *previous)=0
Sample *	At (intptr_t idx) const
intptr_t	capacity () const
ProcessedSampleBuffer *	BuildProcessedSampleBuffer (SampleFilter *filter, ProcessedSampleBuffer *buffer=nullptr)

Protected Member Functions
Sample *	Next (Sample *sample)
ProcessedSample *	BuildProcessedSample (Sample *sample, const CodeLookupTable &clt)
	DISALLOW_COPY_AND_ASSIGN (SampleBuffer)

Protected Attributes
Sample *	samples_
intptr_t	capacity_

Detailed Description

Definition at line 572 of file profiler.h.

Constructor & Destructor Documentation

SampleBuffer()

dart::SampleBuffer::SampleBuffer ( )

default

~SampleBuffer()

virtual dart::SampleBuffer::~SampleBuffer ( )

virtualdefault

Member Function Documentation

At()

Sample * dart::SampleBuffer::At ( intptr_t  idx ) const

inline

Definition at line 617 of file profiler.h.

                                 {
    ASSERT(idx >= 0);
    ASSERT(idx < capacity_);
    return &samples_[idx];
  }

BuildProcessedSample()

ProcessedSample * dart::SampleBuffer::BuildProcessedSample ( Sample *  sample, const CodeLookupTable &  clt  )

protected

Definition at line 1629 of file profiler.cc.

                                {
  Thread* thread = Thread::Current();
  Zone* zone = thread->zone();
 
  ProcessedSample* processed_sample = new (zone) ProcessedSample();
 
  // Copy state bits from sample.
  processed_sample->set_timestamp(sample->timestamp());
  processed_sample->set_tid(sample->tid());
  processed_sample->set_vm_tag(sample->vm_tag());
  processed_sample->set_user_tag(sample->user_tag());
  if (sample->is_allocation_sample()) {
    processed_sample->set_allocation_cid(sample->allocation_cid());
    processed_sample->set_allocation_identity_hash(
        sample->allocation_identity_hash());
  }
  processed_sample->set_first_frame_executing(!sample->exit_frame_sample());
 
  // Copy stack trace from sample(s).
  bool truncated = false;
  Sample* current = sample;
  while (current != nullptr) {
    for (intptr_t i = 0; i < Sample::kPCArraySizeInWords; i++) {
      if (current->At(i) == 0) {
        break;
      }
      processed_sample->Add(current->At(i));
    }
 
    truncated = truncated || current->truncated_trace();
    current = Next(current);
  }
 
  if (!sample->exit_frame_sample()) {
    processed_sample->FixupCaller(clt, /* pc_marker */ 0,
                                  sample->GetStackBuffer());
  }
 
  processed_sample->set_truncated(truncated);
  return processed_sample;
}

BuildProcessedSampleBuffer()

ProcessedSampleBuffer * dart::SampleBuffer::BuildProcessedSampleBuffer	(	SampleFilter *	filter,
		ProcessedSampleBuffer *	buffer = nullptr
	)

Definition at line 1574 of file profiler.cc.

                                   {
  Thread* thread = Thread::Current();
  Zone* zone = thread->zone();
 
  if (buffer == nullptr) {
    buffer = new (zone) ProcessedSampleBuffer();
  }
 
  const intptr_t length = capacity();
  for (intptr_t i = 0; i < length; i++) {
    thread->CheckForSafepoint();
    Sample* sample = At(i);
    if (sample->ignore_sample()) {
      // Bad sample.
      continue;
    }
    if (!sample->head_sample()) {
      // An inner sample in a chain of samples.
      continue;
    }
    if (sample->timestamp() == 0) {
      // Empty.
      continue;
    }
    if (sample->At(0) == 0) {
      // No frames.
      continue;
    }
    if (filter != nullptr) {
      // If we're requesting all the native allocation samples, we don't care
      // whether or not we're in the same isolate as the sample.
      if (sample->port() != filter->port()) {
        // Another isolate.
        continue;
      }
      if (!filter->TimeFilterSample(sample)) {
        // Did not pass time filter.
        continue;
      }
      if (!filter->TaskFilterSample(sample)) {
        // Did not pass task filter.
        continue;
      }
      if (!filter->FilterSample(sample)) {
        // Did not pass filter.
        continue;
      }
    }
    buffer->Add(BuildProcessedSample(sample, buffer->code_lookup_table()));
  }
  return buffer;
}

capacity()

intptr_t dart::SampleBuffer::capacity ( ) const

inline

Definition at line 623 of file profiler.h.

{ return capacity_; }

DISALLOW_COPY_AND_ASSIGN()

dart::SampleBuffer::DISALLOW_COPY_AND_ASSIGN ( SampleBuffer  )

protected

Init()

virtual void dart::SampleBuffer::Init ( Sample *  samples, intptr_t  capacity  )

inlinevirtual

Definition at line 577 of file profiler.h.

                                                        {
    ASSERT(samples != nullptr);
    ASSERT(capacity > 0);
    samples_ = samples;
    capacity_ = capacity;
  }

Next()

Sample * dart::SampleBuffer::Next ( Sample *  sample )

protected

Definition at line 1673 of file profiler.cc.

                                         {
  if (!sample->is_continuation_sample()) return nullptr;
  Sample* next_sample = sample->continuation_sample();
  // Sanity check.
  ASSERT(sample != next_sample);
  // Detect invalid chaining.
  if (sample->port() != next_sample->port()) {
    return nullptr;
  }
  if (sample->timestamp() != next_sample->timestamp()) {
    return nullptr;
  }
  if (sample->tid() != next_sample->tid()) {
    return nullptr;
  }
  return next_sample;
}

ReserveSample()

virtual Sample * dart::SampleBuffer::ReserveSample ( )

pure virtual

Implemented in dart::SampleBlock.

ReserveSampleAndLink()

virtual Sample * dart::SampleBuffer::ReserveSampleAndLink ( Sample *  previous )

pure virtual

Implemented in dart::SampleBlock.

VisitSamples()

void dart::SampleBuffer::VisitSamples ( SampleVisitor *  visitor )

inline

Definition at line 584 of file profiler.h.

                                            {
    ASSERT(visitor != nullptr);
    const intptr_t length = capacity();
    for (intptr_t i = 0; i < length; i++) {
      Sample* sample = At(i);
      if (!sample->head_sample()) {
        // An inner sample in a chain of samples.
        continue;
      }
      if (sample->ignore_sample()) {
        // Bad sample.
        continue;
      }
      if (sample->port() != visitor->port()) {
        // Another isolate.
        continue;
      }
      if (sample->timestamp() == 0) {
        // Empty.
        continue;
      }
      if (sample->At(0) == 0) {
        // No frames.
        continue;
      }
      visitor->IncrementVisited();
      visitor->VisitSample(sample);
    }
  }

Member Data Documentation

capacity_

intptr_t dart::SampleBuffer::capacity_

protected

Definition at line 636 of file profiler.h.

samples_

Sample* dart::SampleBuffer::samples_

protected

Definition at line 635 of file profiler.h.

---

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

• third_party/dart-lang/sdk/runtime/vm/profiler.h
• third_party/dart-lang/sdk/runtime/vm/profiler.cc