LCOV - code coverage report
Current view: top level - src - disruptor.cc (source / functions) Hit Total Coverage
Test: lcov_final.info Lines: 550 550 100.0 %
Date: 2023-02-17 22:37:01 Functions: 105 105 100.0 %
Branches: 0 0 -

Function Name Sort by function name Hit count Sort by hit count
Disruptor::ProduceClaimAvailSync(Napi::CallbackInfo const&) 2
Disruptor::ProduceClaimAvailAsync(Napi::CallbackInfo const&) 2
Disruptor::ProduceClaimAvailAsync(Napi::CallbackInfo const&, unsigned int) 3
Disruptor::ThrowErrnoError(Napi::CallbackInfo const&, char const*) 8
Disruptor::ProduceClaimManySync(Napi::CallbackInfo const&) 11
Disruptor::ProduceClaimManyAsync(Napi::CallbackInfo const&) 11
Disruptor::SetStatus(Napi::CallbackInfo const&, Napi::Value const&) 11
Disruptor::GetConsumers(Napi::CallbackInfo const&) 12
void Disruptor::ProduceGetBuffers<AsyncArray<AsyncBuffer>, AsyncBuffer>(Napi::Env const&, unsigned long, unsigned long, bool, AsyncArray<AsyncBuffer>&) 12
Disruptor::ProduceClaimManyAsync(Napi::CallbackInfo const&, unsigned int) 12
Disruptor::ConsumeNewSync(Napi::CallbackInfo const&) 13
Disruptor::ProduceClaimMany(Napi::CallbackInfo const&) 40
Napi::Array Disruptor::ProduceClaimManySync<Napi::Array, SyncBuffer>(Napi::Env const&, unsigned int, bool, unsigned long&, unsigned long&, bool&) 51
Disruptor::ProduceRecover(Napi::CallbackInfo const&) 76
Disruptor::GetPendingSeqCursor(Napi::CallbackInfo const&) 87
Disruptor::GetConsumer(Napi::CallbackInfo const&) 222
Disruptor::GetNext(Napi::CallbackInfo const&) 222
Disruptor::GetCursor(Napi::CallbackInfo const&) 222
_register_disruptor 254
Initialize(Napi::Env, Napi::Object) 506
__napi_Initialize(napi_env__*, napi_value__*) 506
Disruptor::Initialize(Napi::Env, Napi::Object) 506
Disruptor::ProduceClaimSync(Napi::CallbackInfo const&) 807
Disruptor::ProduceCommitSync(Napi::CallbackInfo const&) 811
Disruptor::ProduceCommitAsync(Napi::CallbackInfo const&) 811
Disruptor::GetElements(Napi::CallbackInfo const&) 1556
Disruptor::GetSpin(Napi::CallbackInfo const&) 2026
Disruptor::GetElementSize(Napi::CallbackInfo const&) 2104
void Disruptor::ProduceGetBuffers<Napi::Array, SyncBuffer>(Napi::Env const&, unsigned long, unsigned long, bool, Napi::Array&) 2224
Disruptor::~Disruptor() 4758
Disruptor::~Disruptor().2 4758
Disruptor::Disruptor(Napi::CallbackInfo const&)::{lambda(Napi::Env, unsigned char*)#1}::operator()(Napi::Env, unsigned char*) const 4758
Disruptor::ProduceClaimAsync(Napi::CallbackInfo const&) 5019
Disruptor::Release(Napi::CallbackInfo const&) 5257
CloseFD::operator()(int*) 5763
Disruptor::Disruptor(Napi::CallbackInfo const&) 5771
Disruptor::Release() 10015
ProduceClaimAvailAsyncWorker::Retry() 72684
ProduceClaimAvailAsyncWorker::Execute() 72687
ProduceClaimAvailAsyncWorker::ProduceClaimAvailAsyncWorker(Disruptor*, Napi::Function const&, unsigned int) 72687
AsyncArray<AsyncBuffer> Disruptor::ProduceClaimAvailSync<AsyncArray<AsyncBuffer>, AsyncBuffer>(Napi::Env const&, unsigned int, bool, unsigned long&, unsigned long&, bool&) 72687
Disruptor::ProduceClaimAvail(Napi::CallbackInfo const&) 84312
Napi::Array Disruptor::ProduceClaimAvailSync<Napi::Array, SyncBuffer>(Napi::Env const&, unsigned int, bool, unsigned long&, unsigned long&, bool&) 84314
AsyncBoolean::ToValue(Napi::Env, Disruptor*) 127723
Disruptor::ProduceCommitAsync(Napi::CallbackInfo const&, unsigned long, unsigned long, unsigned int) 127723
ProduceClaimManyAsyncWorker::Retry() 147484
ProduceClaimManyAsyncWorker::Execute() 147496
ProduceClaimManyAsyncWorker::ProduceClaimManyAsyncWorker(Disruptor*, Napi::Function const&, unsigned int) 147496
AsyncArray<AsyncBuffer> Disruptor::ProduceClaimManySync<AsyncArray<AsyncBuffer>, AsyncBuffer>(Napi::Env const&, unsigned int, bool, unsigned long&, unsigned long&, bool&) 147496
ProduceClaimAsyncWorker::Retry() 165826
AsyncBuffer::Length() 170845
DisruptorAsyncWorker<AsyncBuffer, unsigned long, unsigned long, bool>::OnOK() 170845
DisruptorAsyncWorker<AsyncBuffer, unsigned long, unsigned long, bool>::DisruptorAsyncWorker(Disruptor*, Napi::Function const&) 170845
ProduceClaimAsyncWorker::Execute() 170845
ProduceClaimAsyncWorker::ProduceClaimAsyncWorker(Disruptor*, Napi::Function const&) 170845
AsyncBuffer::Buffer Disruptor::ProduceClaimSync<AsyncBuffer>(Napi::Env const&, bool, unsigned long&, unsigned long&, bool&) 170845
DisruptorAsyncWorker<AsyncArray<AsyncBuffer>, unsigned long, unsigned long, bool>::OnOK() 220183
DisruptorAsyncWorker<AsyncArray<AsyncBuffer>, unsigned long, unsigned long, bool>::DisruptorAsyncWorker(Disruptor*, Napi::Function const&) 220183
Disruptor::ConsumeNewAsync(Napi::CallbackInfo const&) 355460
AsyncArray<AsyncBuffer>::ToValue(Napi::Env, Disruptor*) 355475
AsyncArray<AsyncBuffer>::Set(unsigned int, AsyncBuffer&&) 355520
AsyncBuffer::ToValue(Napi::Env, Disruptor*) 360539
ToValue(Napi::Env const&, unsigned long) 370562
GetCallback(Napi::CallbackInfo const&, unsigned int) 488217
Disruptor::ProduceClaim(Napi::CallbackInfo const&) 519445
SyncBuffer::Buffer Disruptor::ProduceClaimSync<SyncBuffer>(Napi::Env const&, bool, unsigned long&, unsigned long&, bool&) 520252
Disruptor::ProduceCommit(Napi::CallbackInfo const&) 521618
Napi::Boolean Disruptor::ProduceCommitSync<Napi::Boolean>(Napi::Env const&, unsigned long, unsigned long, bool) 522429
Disruptor::GetSeqNext(Napi::CallbackInfo const&, unsigned long&, unsigned long&) 523240
AsyncBuffer::New(Napi::Env, Disruptor*, unsigned long, unsigned long) 526365
AsyncBuffer::AsyncBuffer() 526365
Disruptor::GetAllConsumersIgnoring(Napi::CallbackInfo const&) 604649
Disruptor::GetPendingSeqNext(Napi::CallbackInfo const&) 604663
Disruptor::GetPendingSeqNextEnd(Napi::CallbackInfo const&) 604663
ConsumeNewAsyncWorker::Retry() 718864
Disruptor::UpdateSeqNext(unsigned long, unsigned long, bool) 995665
AsyncBuffer::AsyncBuffer(unsigned long, unsigned long, unsigned int) 1052730
Disruptor::UpdatePending(unsigned long, unsigned long) 1054217
DisruptorAsyncWorker<AsyncArray<AsyncBuffer>, unsigned long, AsyncUndefined, AsyncUndefined>::OnOK() 1074324
DisruptorAsyncWorker<AsyncArray<AsyncBuffer>, unsigned long, AsyncUndefined, AsyncUndefined>::DisruptorAsyncWorker(Disruptor*, Napi::Function const&) 1074324
ConsumeNewAsyncWorker::Execute() 1074324
ConsumeNewAsyncWorker::ConsumeNewAsyncWorker(Disruptor*, Napi::Function const&) 1074324
AsyncArray<AsyncBuffer> Disruptor::ConsumeNewSync<AsyncArray<AsyncBuffer>, AsyncBuffer>(Napi::Env const&, bool, unsigned long&) 1074324
ToValue(Napi::Env const&, AsyncUndefined const&) 1094089
AsyncArray<AsyncBuffer>::New(Napi::Env) 1294507
AsyncArray<AsyncBuffer>::Length() 1294507
SyncBuffer::New(Napi::Env, Disruptor*, unsigned long, unsigned long) 1582385
ProduceCommitAsyncWorker::Retry() 2003078
AsyncBoolean::New(Napi::Env, bool) 2130801
AsyncBoolean::AsyncBoolean(bool) 2130801
AsyncBoolean::AsyncBoolean() 2130801
DisruptorAsyncWorker<AsyncBoolean, AsyncUndefined, AsyncUndefined, AsyncUndefined>::OnOK() 2130801
DisruptorAsyncWorker<AsyncBoolean, AsyncUndefined, AsyncUndefined, AsyncUndefined>::DisruptorAsyncWorker(Disruptor*, Napi::Function const&) 2130801
ProduceCommitAsyncWorker::Execute() 2130801
ProduceCommitAsyncWorker::ProduceCommitAsyncWorker(Disruptor*, Napi::Function const&, unsigned long, unsigned long) 2130801
AsyncBoolean Disruptor::ProduceCommitSync<AsyncBoolean>(Napi::Env const&, unsigned long, unsigned long, bool) 2130801
AsyncBoolean::operator bool() const 2130801
AsyncArray<AsyncBuffer>::AsyncArray() 2589014
Disruptor::Spin() 3596153
Disruptor::ConsumeNew(Napi::CallbackInfo const&) 7074862
Napi::Array Disruptor::ConsumeNewSync<Napi::Array, SyncBuffer>(Napi::Env const&, bool, unsigned long&) 7074875
Disruptor::ConsumeCommit(Napi::CallbackInfo const&) 7074880
Disruptor::GetPendingSeqConsumer(Napi::CallbackInfo const&) 7074962
Disruptor::GetStatus(Napi::CallbackInfo const&) 12036314
Disruptor::ConsumeCommit() 15224079

Generated by: LCOV version 1.16