Class: Vernier::Collector::TimeCollector

Inherits:

Vernier::Collector

• Object
• Vernier::Collector
• Vernier::Collector::TimeCollector

Defined in:

ext/vernier/vernier.cc

Instance Attribute Summary

Attributes inherited from Vernier::Collector

#stack_table

Class Method Summary

• .new(mode, options) ⇒ Object

Instance Method Summary

• #start ⇒ Object

Methods inherited from Vernier::Collector

#add_marker, #current_time, #initialize, #record_interval, #stop

Constructor Details

This class inherits a constructor from Vernier::Collector

Class Method Details

.new(mode, options) ⇒ Object

# File 'ext/vernier/vernier.cc', line 1185

static VALUE collector_new(VALUE self, VALUE mode, VALUE options) {
    BaseCollector *collector;

    VALUE stack_table = StackTable::stack_table_new();
    if (mode == sym("wall")) {
        VALUE intervalv = rb_hash_aref(options, sym("interval"));
        TimeStamp interval;
        if (NIL_P(intervalv)) {
            interval = TimeStamp::from_microseconds(500);
        } else {
            interval = TimeStamp::from_microseconds(NUM2UINT(intervalv));
        }

        VALUE allocation_intervalv = rb_hash_aref(options, sym("allocation_interval"));
        if (NIL_P(allocation_intervalv))
            allocation_intervalv = rb_hash_aref(options, sym("allocation_sample_rate"));

        unsigned int allocation_interval;
        if (NIL_P(allocation_intervalv)) {
            allocation_interval = 0;
        } else {
            allocation_interval = NUM2UINT(allocation_intervalv);
        }
        collector = new TimeCollector(stack_table, interval, allocation_interval);
    } else {
        rb_raise(rb_eArgError, "invalid mode");
    }
    VALUE obj = TypedData_Wrap_Struct(self, &rb_collector_type, collector);
    rb_ivar_set(obj, rb_intern("@stack_table"), stack_table);
    rb_funcall(obj, rb_intern("initialize"), 2, mode, options);
    return obj;
}

Instance Method Details

#start ⇒ Object

# File 'ext/vernier/vernier.cc', line 1166

static VALUE
collector_start(VALUE self) {
    auto *collector = get_collector(self);

    if (!collector->start()) {
        rb_raise(rb_eRuntimeError, "collector already running");
    }

    return Qtrue;
}