#include "histogram.h" // NOLINT(build/include_inline) #include "base_object-inl.h" #include "histogram-inl.h" #include "memory_tracker-inl.h" #include "node_errors.h" #include "node_external_reference.h" namespace node { using v8::BigInt; using v8::FunctionCallbackInfo; using v8::FunctionTemplate; using v8::Integer; using v8::Local; using v8::Map; using v8::Number; using v8::Object; using v8::String; using v8::Uint32; using v8::Value; Histogram::Histogram(const Options& options) { hdr_histogram* histogram; CHECK_EQ(0, hdr_init(options.lowest, options.highest, options.figures, &histogram)); histogram_.reset(histogram); } void Histogram::MemoryInfo(MemoryTracker* tracker) const { tracker->TrackFieldWithSize("histogram", GetMemorySize()); } HistogramImpl::HistogramImpl(const Histogram::Options& options) : histogram_(new Histogram(options)) {} HistogramImpl::HistogramImpl(std::shared_ptr histogram) : histogram_(std::move(histogram)) {} HistogramBase::HistogramBase( Environment* env, Local wrap, const Histogram::Options& options) : BaseObject(env, wrap), HistogramImpl(options) { MakeWeak(); } HistogramBase::HistogramBase( Environment* env, Local wrap, std::shared_ptr histogram) : BaseObject(env, wrap), HistogramImpl(std::move(histogram)) { MakeWeak(); } void HistogramBase::MemoryInfo(MemoryTracker* tracker) const { tracker->TrackField("histogram", histogram()); } void HistogramBase::GetCount(const v8::FunctionCallbackInfo& args) { HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); double value = static_cast((*histogram)->Count()); args.GetReturnValue().Set(value); } void HistogramBase::GetCountBigInt( const v8::FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set( BigInt::NewFromUnsigned(env->isolate(), (*histogram)->Count())); } void HistogramBase::GetMin(const FunctionCallbackInfo& args) { HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); double value = static_cast((*histogram)->Min()); args.GetReturnValue().Set(value); } void HistogramBase::GetMinBigInt(const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set(BigInt::New(env->isolate(), (*histogram)->Min())); } void HistogramBase::GetMax(const FunctionCallbackInfo& args) { HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); double value = static_cast((*histogram)->Max()); args.GetReturnValue().Set(value); } void HistogramBase::GetMaxBigInt(const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set( BigInt::New(env->isolate(), (*histogram)->Max())); } void HistogramBase::GetMean(const FunctionCallbackInfo& args) { HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set((*histogram)->Mean()); } void HistogramBase::GetExceeds(const FunctionCallbackInfo& args) { HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); double value = static_cast((*histogram)->Exceeds()); args.GetReturnValue().Set(value); } void HistogramBase::GetExceedsBigInt(const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set( BigInt::NewFromUnsigned(env->isolate(), (*histogram)->Exceeds())); } void HistogramBase::GetStddev(const FunctionCallbackInfo& args) { HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set((*histogram)->Stddev()); } void HistogramBase::GetPercentile(const FunctionCallbackInfo& args) { HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); CHECK(args[0]->IsNumber()); double percentile = args[0].As()->Value(); double value = static_cast((*histogram)->Percentile(percentile)); args.GetReturnValue().Set(value); } void HistogramBase::GetPercentileBigInt( const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); CHECK(args[0]->IsNumber()); double percentile = args[0].As()->Value(); int64_t value = (*histogram)->Percentile(percentile); args.GetReturnValue().Set(BigInt::New(env->isolate(), value)); } void HistogramBase::GetPercentiles(const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); CHECK(args[0]->IsMap()); Local map = args[0].As(); (*histogram)->Percentiles([map, env](double key, int64_t value) { USE(map->Set( env->context(), Number::New(env->isolate(), key), Number::New(env->isolate(), static_cast(value)))); }); } void HistogramBase::GetPercentilesBigInt( const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); CHECK(args[0]->IsMap()); Local map = args[0].As(); (*histogram)->Percentiles([map, env](double key, int64_t value) { USE(map->Set( env->context(), Number::New(env->isolate(), key), BigInt::New(env->isolate(), value))); }); } void HistogramBase::DoReset(const FunctionCallbackInfo& args) { HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); (*histogram)->Reset(); } void HistogramBase::RecordDelta(const FunctionCallbackInfo& args) { HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); (*histogram)->RecordDelta(); } void HistogramBase::Record(const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); CHECK_IMPLIES(!args[0]->IsNumber(), args[0]->IsBigInt()); bool lossless = true; int64_t value = args[0]->IsBigInt() ? args[0].As()->Int64Value(&lossless) : static_cast(args[0].As()->Value()); if (!lossless || value < 1) return THROW_ERR_OUT_OF_RANGE(env, "value is out of range"); HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); (*histogram)->Record(value); } void HistogramBase::Add(const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); HistogramBase* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); CHECK(GetConstructorTemplate(env)->HasInstance(args[0])); HistogramBase* other; ASSIGN_OR_RETURN_UNWRAP(&other, args[0]); double count = (*histogram)->Add(*(other->histogram())); args.GetReturnValue().Set(count); } BaseObjectPtr HistogramBase::Create( Environment* env, const Histogram::Options& options) { Local obj; if (!GetConstructorTemplate(env) ->InstanceTemplate() ->NewInstance(env->context()).ToLocal(&obj)) { return BaseObjectPtr(); } return MakeBaseObject(env, obj, options); } BaseObjectPtr HistogramBase::Create( Environment* env, std::shared_ptr histogram) { Local obj; if (!GetConstructorTemplate(env) ->InstanceTemplate() ->NewInstance(env->context()).ToLocal(&obj)) { return BaseObjectPtr(); } return MakeBaseObject(env, obj, std::move(histogram)); } void HistogramBase::New(const FunctionCallbackInfo& args) { CHECK(args.IsConstructCall()); Environment* env = Environment::GetCurrent(args); CHECK_IMPLIES(!args[0]->IsNumber(), args[0]->IsBigInt()); CHECK_IMPLIES(!args[1]->IsNumber(), args[1]->IsBigInt()); CHECK(args[2]->IsUint32()); int64_t lowest = 1; int64_t highest = std::numeric_limits::max(); bool lossless_ignored; if (args[0]->IsNumber()) { lowest = args[0].As()->Value(); } else if (args[0]->IsBigInt()) { lowest = args[0].As()->Int64Value(&lossless_ignored); } if (args[1]->IsNumber()) { highest = args[1].As()->Value(); } else if (args[1]->IsBigInt()) { highest = args[1].As()->Int64Value(&lossless_ignored); } int32_t figures = args[2].As()->Value(); new HistogramBase(env, args.This(), Histogram::Options { lowest, highest, figures }); } Local HistogramBase::GetConstructorTemplate( Environment* env) { Local tmpl = env->histogram_ctor_template(); if (tmpl.IsEmpty()) { tmpl = env->NewFunctionTemplate(New); Local classname = FIXED_ONE_BYTE_STRING(env->isolate(), "Histogram"); tmpl->SetClassName(classname); tmpl->Inherit(BaseObject::GetConstructorTemplate(env)); tmpl->InstanceTemplate()->SetInternalFieldCount( HistogramBase::kInternalFieldCount); env->SetProtoMethodNoSideEffect(tmpl, "count", GetCount); env->SetProtoMethodNoSideEffect(tmpl, "countBigInt", GetCountBigInt); env->SetProtoMethodNoSideEffect(tmpl, "exceeds", GetExceeds); env->SetProtoMethodNoSideEffect(tmpl, "exceedsBigInt", GetExceedsBigInt); env->SetProtoMethodNoSideEffect(tmpl, "min", GetMin); env->SetProtoMethodNoSideEffect(tmpl, "minBigInt", GetMinBigInt); env->SetProtoMethodNoSideEffect(tmpl, "max", GetMax); env->SetProtoMethodNoSideEffect(tmpl, "maxBigInt", GetMaxBigInt); env->SetProtoMethodNoSideEffect(tmpl, "mean", GetMean); env->SetProtoMethodNoSideEffect(tmpl, "stddev", GetStddev); env->SetProtoMethodNoSideEffect(tmpl, "percentile", GetPercentile); env->SetProtoMethodNoSideEffect(tmpl, "percentileBigInt", GetPercentileBigInt); env->SetProtoMethodNoSideEffect(tmpl, "percentiles", GetPercentiles); env->SetProtoMethodNoSideEffect(tmpl, "percentilesBigInt", GetPercentilesBigInt); env->SetProtoMethod(tmpl, "reset", DoReset); env->SetProtoMethod(tmpl, "record", Record); env->SetProtoMethod(tmpl, "recordDelta", RecordDelta); env->SetProtoMethod(tmpl, "add", Add); env->set_histogram_ctor_template(tmpl); } return tmpl; } void HistogramBase::RegisterExternalReferences( ExternalReferenceRegistry* registry) { registry->Register(New); registry->Register(GetCount); registry->Register(GetCountBigInt); registry->Register(GetExceeds); registry->Register(GetExceedsBigInt); registry->Register(GetMin); registry->Register(GetMinBigInt); registry->Register(GetMax); registry->Register(GetMaxBigInt); registry->Register(GetMean); registry->Register(GetStddev); registry->Register(GetPercentile); registry->Register(GetPercentileBigInt); registry->Register(GetPercentiles); registry->Register(GetPercentilesBigInt); registry->Register(DoReset); registry->Register(Record); registry->Register(RecordDelta); registry->Register(Add); } void HistogramBase::Initialize(Environment* env, Local target) { env->SetConstructorFunction(target, "Histogram", GetConstructorTemplate(env)); } BaseObjectPtr HistogramBase::HistogramTransferData::Deserialize( Environment* env, v8::Local context, std::unique_ptr self) { return Create(env, std::move(histogram_)); } std::unique_ptr HistogramBase::CloneForMessaging() const { return std::make_unique(this); } void HistogramBase::HistogramTransferData::MemoryInfo( MemoryTracker* tracker) const { tracker->TrackField("histogram", histogram_); } Local IntervalHistogram::GetConstructorTemplate( Environment* env) { Local tmpl = env->intervalhistogram_constructor_template(); if (tmpl.IsEmpty()) { tmpl = FunctionTemplate::New(env->isolate()); tmpl->Inherit(HandleWrap::GetConstructorTemplate(env)); tmpl->InstanceTemplate()->SetInternalFieldCount( HistogramBase::kInternalFieldCount); env->SetProtoMethodNoSideEffect(tmpl, "count", GetCount); env->SetProtoMethodNoSideEffect(tmpl, "countBigInt", GetCountBigInt); env->SetProtoMethodNoSideEffect(tmpl, "exceeds", GetExceeds); env->SetProtoMethodNoSideEffect(tmpl, "exceedsBigInt", GetExceedsBigInt); env->SetProtoMethodNoSideEffect(tmpl, "min", GetMin); env->SetProtoMethodNoSideEffect(tmpl, "minBigInt", GetMinBigInt); env->SetProtoMethodNoSideEffect(tmpl, "max", GetMax); env->SetProtoMethodNoSideEffect(tmpl, "maxBigInt", GetMaxBigInt); env->SetProtoMethodNoSideEffect(tmpl, "mean", GetMean); env->SetProtoMethodNoSideEffect(tmpl, "stddev", GetStddev); env->SetProtoMethodNoSideEffect(tmpl, "percentile", GetPercentile); env->SetProtoMethodNoSideEffect(tmpl, "percentileBigInt", GetPercentileBigInt); env->SetProtoMethodNoSideEffect(tmpl, "percentiles", GetPercentiles); env->SetProtoMethodNoSideEffect(tmpl, "percentilesBigInt", GetPercentilesBigInt); env->SetProtoMethod(tmpl, "reset", DoReset); env->SetProtoMethod(tmpl, "start", Start); env->SetProtoMethod(tmpl, "stop", Stop); env->set_intervalhistogram_constructor_template(tmpl); } return tmpl; } void IntervalHistogram::RegisterExternalReferences( ExternalReferenceRegistry* registry) { registry->Register(GetCount); registry->Register(GetCountBigInt); registry->Register(GetExceeds); registry->Register(GetExceedsBigInt); registry->Register(GetMin); registry->Register(GetMinBigInt); registry->Register(GetMax); registry->Register(GetMaxBigInt); registry->Register(GetMean); registry->Register(GetStddev); registry->Register(GetPercentile); registry->Register(GetPercentileBigInt); registry->Register(GetPercentiles); registry->Register(GetPercentilesBigInt); registry->Register(DoReset); registry->Register(Start); registry->Register(Stop); } IntervalHistogram::IntervalHistogram( Environment* env, Local wrap, AsyncWrap::ProviderType type, int32_t interval, std::function on_interval, const Histogram::Options& options) : HandleWrap( env, wrap, reinterpret_cast(&timer_), type), HistogramImpl(options), interval_(interval), on_interval_(std::move(on_interval)) { MakeWeak(); uv_timer_init(env->event_loop(), &timer_); } BaseObjectPtr IntervalHistogram::Create( Environment* env, int32_t interval, std::function on_interval, const Histogram::Options& options) { Local obj; if (!GetConstructorTemplate(env) ->InstanceTemplate() ->NewInstance(env->context()).ToLocal(&obj)) { return BaseObjectPtr(); } return MakeBaseObject( env, obj, AsyncWrap::PROVIDER_ELDHISTOGRAM, interval, std::move(on_interval), options); } void IntervalHistogram::TimerCB(uv_timer_t* handle) { IntervalHistogram* histogram = ContainerOf(&IntervalHistogram::timer_, handle); Histogram* h = histogram->histogram().get(); histogram->on_interval_(*h); } void IntervalHistogram::MemoryInfo(MemoryTracker* tracker) const { tracker->TrackField("histogram", histogram()); } void IntervalHistogram::OnStart(StartFlags flags) { if (enabled_ || IsHandleClosing()) return; enabled_ = true; if (flags == StartFlags::RESET) histogram()->Reset(); uv_timer_start(&timer_, TimerCB, interval_, interval_); uv_unref(reinterpret_cast(&timer_)); } void IntervalHistogram::OnStop() { if (!enabled_ || IsHandleClosing()) return; enabled_ = false; uv_timer_stop(&timer_); } void IntervalHistogram::Start(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); histogram->OnStart(args[0]->IsTrue() ? StartFlags::RESET : StartFlags::NONE); } void IntervalHistogram::Stop(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); histogram->OnStop(); } void IntervalHistogram::GetCount(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); double value = static_cast((*histogram)->Count()); args.GetReturnValue().Set(value); } void IntervalHistogram::GetCountBigInt( const v8::FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set( BigInt::NewFromUnsigned(env->isolate(), (*histogram)->Count())); } void IntervalHistogram::GetMin(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); double value = static_cast((*histogram)->Min()); args.GetReturnValue().Set(value); } void IntervalHistogram::GetMinBigInt(const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set(BigInt::New(env->isolate(), (*histogram)->Min())); } void IntervalHistogram::GetMax(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); double value = static_cast((*histogram)->Max()); args.GetReturnValue().Set(value); } void IntervalHistogram::GetMaxBigInt(const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set(BigInt::New(env->isolate(), (*histogram)->Min())); } void IntervalHistogram::GetMean(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set((*histogram)->Mean()); } void IntervalHistogram::GetExceeds(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); double value = static_cast((*histogram)->Exceeds()); args.GetReturnValue().Set(value); } void IntervalHistogram::GetExceedsBigInt( const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set( BigInt::New(env->isolate(), (*histogram)->Exceeds())); } void IntervalHistogram::GetStddev(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); args.GetReturnValue().Set((*histogram)->Stddev()); } void IntervalHistogram::GetPercentile(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); CHECK(args[0]->IsNumber()); double percentile = args[0].As()->Value(); double value = static_cast((*histogram)->Percentile(percentile)); args.GetReturnValue().Set(value); } void IntervalHistogram::GetPercentileBigInt( const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); CHECK(args[0]->IsNumber()); double percentile = args[0].As()->Value(); int64_t value = (*histogram)->Percentile(percentile); args.GetReturnValue().Set(BigInt::New(env->isolate(), value)); } void IntervalHistogram::GetPercentiles( const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); CHECK(args[0]->IsMap()); Local map = args[0].As(); (*histogram)->Percentiles([map, env](double key, int64_t value) { USE(map->Set( env->context(), Number::New(env->isolate(), key), Number::New(env->isolate(), static_cast(value)))); }); } void IntervalHistogram::GetPercentilesBigInt( const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); CHECK(args[0]->IsMap()); Local map = args[0].As(); (*histogram)->Percentiles([map, env](double key, int64_t value) { USE(map->Set( env->context(), Number::New(env->isolate(), key), BigInt::New(env->isolate(), value))); }); } void IntervalHistogram::DoReset(const FunctionCallbackInfo& args) { IntervalHistogram* histogram; ASSIGN_OR_RETURN_UNWRAP(&histogram, args.Holder()); (*histogram)->Reset(); } std::unique_ptr IntervalHistogram::CloneForMessaging() const { return std::make_unique(histogram()); } } // namespace node