apache / pulsar-client-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 1,719 units with 16,696 lines of code in units (55.1% of code).

3 very complex units (817 lines of code)
6 complex units (729 lines of code)
32 medium complex units (1,948 lines of code)
100 simple units (3,383 lines of code)
1,578 very simple units (9,819 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
static int dissect_pulsar_message() in wireshark/pulsarDissector.cc	502	82	4
std::string Commands::messageType() in lib/Commands.cc	173	58	1
FORCE_INLINE int LZ4_decompress_generic() in lib/lz4/lz4.cc	142	55	11
FORCE_INLINE int LZ4_compress_generic() in lib/lz4/lz4.cc	172	44	10
void ProducerImpl::sendAsyncWithStatsUpdate() in lib/ProducerImpl.cc	138	29	2
static Result getResult() in lib/ClientConnection.cc	59	28	2
static void dissect_message_metadata() in wireshark/pulsarDissector.cc	146	28	4
static int LZ4_compress_destSize_generic() in lib/lz4/lz4.cc	124	27	6
void ClientConnection::handleIncomingCommand() in lib/ClientConnection.cc	90	26	1
void ConsumerImpl::messageReceived() in lib/ConsumerImpl.cc	85	25	6
Result ProducerImpl::handleCreateProducer() in lib/ProducerImpl.cc	98	24	3
int main() in perf/PerfProducer.cc	183	23	2
void ClientConnection::close() in lib/ClientConnection.cc	89	22	2
static unsigned LZ4_NbCommonBytes() in lib/lz4/lz4.cc	79	21	1
void ClientConnection::handleTcpConnected() in lib/ClientConnection.cc	103	19	2
PULSAR_PUBLIC SchemaType enumSchemaType() in lib/Schema.cc	37	17	1
bool MessageCrypto::encrypt() in lib/MessageCrypto.cc	94	16	5
boost::optional ConsumerImpl::processMessageChunk() in lib/ConsumerImpl.cc	68	16	5
inline CurlWrapper::Result CurlWrapper::get() in lib/CurlWrapper.h	69	16	4
bool TopicName::validate() in lib/TopicName.cc	14	15	0
Result HTTPLookupService::sendHTTPRequest() in lib/HTTPLookupService.cc	68	15	3
uint32_t ConsumerImpl::receiveIndividualMessagesFromBatch() in lib/ConsumerImpl.cc	56	15	4
void ConsumerImpl::processPossibleToDLQ() in lib/ConsumerImpl.cc	102	15	2
const std::string ZTSClient::getRoleToken() in lib/auth/athenz/ZTSClient.cc	89	15	0
void ClientImpl::closeAsync() in lib/ClientImpl.cc	41	14	1
auto ServiceURI::parse() in lib/ServiceURI.cc	44	13	1
void AckGroupingTracker::doImmediateAck() in lib/AckGroupingTracker.cc	46	13	2
void ConsumerImpl::hasMessageAvailableAsync() in lib/ConsumerImpl.cc	50	13	1
static void crc32c_init_sw() in lib/checksum/crc32c_sw.cc	22	12	0
int LZ4_compress_fast_continue() in lib/lz4/lz4.cc	44	12	6
void MultiTopicsConsumerImpl::closeAsync() in lib/MultiTopicsConsumerImpl.cc	53	12	1
AuthenticationPtr tryCreateBuiltinAuth() in lib/Authentication.cc	19	11	2
AuthenticationPtr tryCreateBuiltinAuth() in lib/Authentication.cc	19	11	2
bool TopicName::init() in lib/TopicName.cc	40	11	1
void PartitionedProducerImpl::sendAsync() in lib/PartitionedProducerImpl.cc	34	11	2
void PartitionedProducerImpl::handleGetPartitions() in lib/PartitionedProducerImpl.cc	47	11	2
auto BinaryProtoLookupService::findBroker() in lib/BinaryProtoLookupService.cc	59	11	4
Result ConsumerImpl::handleCreateConsumer() in lib/ConsumerImpl.cc	50	11	2
void MultiTopicsConsumerImpl::subscribeTopicPartitions() in lib/MultiTopicsConsumerImpl.cc	76	11	4
void HandlerBase::handleDisconnection() in lib/HandlerBase.cc	27	11	2
KeyFile KeyFile::fromParamMap() in lib/auth/AuthOauth2.cc	43	11	1
void startPerfConsumer() in perf/PerfConsumer.cc	59	10	1
void ClientConnection::processIncomingBuffer() in lib/ClientConnection.cc	84	10	0
static uint32_t crc32c_words() in lib/checksum/crc32c_sse42.cc	28	10	3
static uint32_t crc32c_bytes() in lib/checksum/crc32c_sse42.cc	28	10	3
void ProducerImpl::flushAsync() in lib/ProducerImpl.cc	34	10	1
static unsigned LZ4_count() in lib/lz4/lz4.cc	24	10	3
void ConsumerImpl::redeliverUnacknowledgedMessages() in lib/ConsumerImpl.cc	30	10	1
void ClientCredentialFlow::initialize() in lib/auth/AuthOauth2.cc	59	10	0
Oauth2TokenResultPtr ClientCredentialFlow::authenticate() in lib/auth/AuthOauth2.cc	70	10	0