apache / nifi-minifi-cpp - Conditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

There are 4,880 units with 52,706 lines of code in units (52.4% of code).

2 very complex units (1,246 lines of code)
16 complex units (2,059 lines of code)
164 medium complex units (8,982 lines of code)
391 simple units (11,289 lines of code)
4,307 very simple units (29,130 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex units

Unit	# lines	McCabe index	# params
Value expr_escapeHtml4() in extensions/expression-language/Expression.cpp	981	191	1
int main() in minifi_main/MiNiFiMain.cpp	265	51	2
bool ProvenanceEventRecordImpl::deserialize() in libminifi/src/provenance/Provenance.cpp	181	49	1
bool ProvenanceEventRecordImpl::serialize() in libminifi/src/provenance/Provenance.cpp	159	48	1
bool PutSFTP::processOne() in extensions/sftp/processors/PutSFTP.cpp	204	46	2
int main() in controller/MiNiFiController.cpp	169	42	2
bool SFTPClient::connect() in extensions/sftp/client/SFTPClient.cpp	178	37	0
int16_t SiteToSiteClient::send() in libminifi/src/sitetosite/SiteToSiteClient.cpp	110	35	4
void ListSFTP::listByTrackingTimestamps() in extensions/sftp/processors/ListSFTP.cpp	129	33	7
void putValue() in extensions/standard-processors/utils/JoltUtils.cpp	118	31	4
void ProcessSessionImpl::commit() in libminifi/src/core/ProcessSession.cpp	106	29	0
std::pair parseKeyAccess() in extensions/standard-processors/utils/JoltUtils.cpp	104	29	1
bool PublishKafka::configureNewConnection() in extensions/kafka/PublishKafka.cpp	114	29	1
std::optional RocksDbInstance::open() in extensions/rocksdb-repos/database/RocksDbInstance.cpp	114	28	1
std::unique_ptr parseCronField() in utils/src/utils/Cron.cpp	73	27	1
Value expr_getDelimitedField() in extensions/expression-language/Expression.cpp	95	27	1
void StructuredConfiguration::parseProcessorNode() in libminifi/src/core/flow/StructuredConfiguration.cpp	108	26	2
void StructuredConfiguration::parseRemoteProcessGroup() in libminifi/src/core/flow/StructuredConfiguration.cpp	97	26	2
int main() in encrypt-config/EncryptConfigMain.cpp	80	25	2
bool SiteToSiteClient::receive() in libminifi/src/sitetosite/SiteToSiteClient.cpp	98	25	3
std::pair RemoteProcessorGroupPort::refreshRemoteSite2SiteInfo() in libminifi/src/RemoteProcessorGroupPort.cpp	92	25	0
void C2Agent::handle_sync() in libminifi/src/c2/C2Agent.cpp	133	25	1
void CompressContent::processFlowFile() in extensions/libarchive/CompressContent.cpp	114	25	2
void RunAsServiceIfNeeded() in minifi_main/MiNiFiWindowsService.cpp	148	24	0
bool RawSiteToSiteClient::handShake() in libminifi/src/sitetosite/RawSocketProtocol.cpp	87	24	0
C2Payload RESTProtocol::parseJsonResponse() in libminifi/src/c2/protocols/RESTProtocol.cpp	76	24	2
static std::shared_ptr getOrCreateDefaultStateStorage() in utils/include/core/ProcessContext.h	41	23	2
std::shared_ptr LoggerConfiguration::initialize_namespaces() in libminifi/src/core/logging/LoggerConfiguration.cpp	73	23	2
C2Payload RESTSender::sendPayload() in libminifi/src/c2/protocols/RESTSender.cpp	90	23	5
void TailFile::parseStateFileLine() in extensions/standard-processors/processors/TailFile.cpp	57	23	2
void PublishKafka::onTrigger() in extensions/kafka/PublishKafka.cpp	141	23	2
static SFTPError libssh2_sftp_error_to_sftp_error() in extensions/sftp/client/SFTPClient.cpp	33	23	1
void ListSFTP::onTrigger() in extensions/sftp/processors/ListSFTP.cpp	91	22	2
static bool parse() in libminifi/include/sitetosite/PeersEntity.h	66	21	4
bool SiteToSiteClient::receiveFlowFiles() in libminifi/src/sitetosite/SiteToSiteClient.cpp	95	21	2
std::string nodeValue2String() in extensions/opc/src/opc.cpp	95	21	1
bool SiteToSiteClient::confirm() in libminifi/src/sitetosite/SiteToSiteClient.cpp	87	20	1
bool SSLContextServiceImpl::configure_ssl_context() in libminifi/src/controllers/SSLContextService.cpp	45	20	1
void ProcessSessionImpl::import() in libminifi/src/core/ProcessSession.cpp	87	20	4
void C2Agent::handle_describe() in libminifi/src/c2/C2Agent.cpp	99	20	1
bool MetadataWalker::for_each() in extensions/windows-event-log/wel/MetadataWalker.cpp	67	20	1
nonstd::expected ConsumeWindowsEventLog::createEventRender() in extensions/windows-event-log/ConsumeWindowsEventLog.cpp	75	20	1
std::unique_ptr parseReadRegister() in extensions/standard-processors/modbus/ReadModbusFunctions.cpp	49	20	6
void FetchSFTP::onTrigger() in extensions/sftp/processors/FetchSFTP.cpp	99	20	2
bool FlowFileRecordImpl::Serialize() in libminifi/src/FlowFileRecord.cpp	79	19	1
void ProcessGroup::addConnection() in libminifi/src/core/ProcessGroup.cpp	53	19	1
void ConsumeWindowsEventLog::onSchedule() in extensions/windows-event-log/ConsumeWindowsEventLog.cpp	73	19	2
void ManipulateArchive::onTrigger() in extensions/libarchive/ManipulateArchive.cpp	77	19	2
static nonstd::expected parse() in extensions/elasticsearch/PostElasticsearch.cpp	33	19	3
void ConsumeMQTT::checkProperties() in extensions/mqtt/processors/ConsumeMQTT.cpp	46	19	0