apache / pulsar-client-cppConditional 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,675 units with 16,093 lines of code in units (55.6% of code).

3 very complex units (817 lines of code)
5 complex units (639 lines of code)
29 medium complex units (1,803 lines of code)
91 simple units (3,135 lines of code)
1,547 very simple units (9,699 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	139	29	2
static Result getResult() in lib/ClientConnection.cc	58	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 ConsumerImpl::messageReceived() in lib/ConsumerImpl.cc	85	25	6
Result HTTPLookupService::sendHTTPRequest() in lib/HTTPLookupService.cc	115	24	3
void ClientConnection::handleIncomingCommand() in lib/ClientConnection.cc	85	24	1
void ProducerImpl::handleCreateProducer() in lib/ProducerImpl.cc	97	23	3
int main() in perf/PerfProducer.cc	182	23	2
static unsigned LZ4_NbCommonBytes() in lib/lz4/lz4.cc	79	21	1
PULSAR_PUBLIC SchemaType enumSchemaType() in lib/Schema.cc	37	17	1
void ClientConnection::handleTcpConnected() in lib/ClientConnection.cc	97	17	2
void ClientConnection::close() in lib/ClientConnection.cc	66	17	1
bool MessageCrypto::encrypt() in lib/MessageCrypto.cc	94	16	5
uint32_t ConsumerImpl::receiveIndividualMessagesFromBatch() in lib/ConsumerImpl.cc	56	15	4
void ConsumerImpl::processPossibleToDLQ() in lib/ConsumerImpl.cc	101	15	2
bool TopicName::validate() in lib/TopicName.cc	14	15	0
auto ServiceURI::parse() in lib/ServiceURI.cc	44	13	1
boost::optional ConsumerImpl::processMessageChunk() in lib/ConsumerImpl.cc	65	13	5
void ClientImpl::closeAsync() in lib/ClientImpl.cc	37	13	1
void MultiTopicsConsumerImpl::closeAsync() in lib/MultiTopicsConsumerImpl.cc	53	12	1
int LZ4_compress_fast_continue() in lib/lz4/lz4.cc	44	12	6
void HandlerBase::handleDisconnection() in lib/HandlerBase.cc	34	12	3
static void crc32c_init_sw() in lib/checksum/crc32c_sw.cc	22	12	0
KeyFile KeyFile::fromParamMap() in lib/auth/AuthOauth2.cc	43	11	1
const std::string ZTSClient::getRoleToken() in lib/auth/athenz/ZTSClient.cc	85	11	0
void ConsumerImpl::handleCreateConsumer() in lib/ConsumerImpl.cc	49	11	2
AuthenticationPtr tryCreateBuiltinAuth() in lib/Authentication.cc	19	11	2
AuthenticationPtr tryCreateBuiltinAuth() in lib/Authentication.cc	19	11	2
void AckGroupingTracker::doImmediateAck() in lib/AckGroupingTracker.cc	36	11	2
auto BinaryProtoLookupService::findBroker() in lib/BinaryProtoLookupService.cc	58	11	4
void PartitionedProducerImpl::handleGetPartitions() in lib/PartitionedProducerImpl.cc	47	11	2
bool TopicName::init() in lib/TopicName.cc	40	11	1
SharedBuffer Commands::newSubscribe() in lib/Commands.cc	68	10	16
void MultiTopicsConsumerImpl::subscribeTopicPartitions() in lib/MultiTopicsConsumerImpl.cc	73	10	4
void ConsumerImpl::redeliverUnacknowledgedMessages() in lib/ConsumerImpl.cc	30	10	1
static unsigned LZ4_count() in lib/lz4/lz4.cc	24	10	3
void ClientConnection::processIncomingBuffer() in lib/ClientConnection.cc	86	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 startPerfConsumer() in perf/PerfConsumer.cc	58	10	1
void HTTPLookupService::handleGetSchemaHTTPRequest() in lib/HTTPLookupService.cc	63	9	2
const std::string ZTSClient::getPrincipalToken() in lib/auth/athenz/ZTSClient.cc	66	9	0
Result ProducerImpl::canEnqueueRequest() in lib/ProducerImpl.cc	22	9	1
void ProducerImpl::closeAsync() in lib/ProducerImpl.cc	46	9	1
bool MessageCrypto::decryptData() in lib/MessageCrypto.cc	56	9	4