apache / rocketmq-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,448 units with 12,809 lines of code in units (49.8% of code).

0 very complex units (0 lines of code)
2 complex units (311 lines of code)
25 medium complex units (1,707 lines of code)
61 simple units (2,174 lines of code)
1,360 very simple units (8,617 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
void ConsumeMessageConcurrentlyService::ConsumeRequest() in src/consumer/ConsumeMessageConcurrentlyService.cpp	168	33	2
void DefaultMQPushConsumerImpl::pullMessage() in src/consumer/DefaultMQPushConsumerImpl.cpp	143	27	1
virtual void onSuccess() in src/consumer/DefaultMQPushConsumerImpl.cpp	112	24	3
void ConsumeMessageOrderlyService::ConsumeRequest() in src/consumer/ConsumeMessageOrderlyService.cpp	112	23	1
static bool ParseArgs() in example/common.h	77	22	3
MQMessageQueue selectOneActiveMessageQueue() in src/producer/TopicPublishInfo.h	66	17	2
SendResult DefaultMQProducerImpl::sendKernelImpl() in src/producer/DefaultMQProducerImpl.cpp	67	17	4
SendResult DefaultMQProducerImpl::sendAutoRetrySelectImpl() in src/producer/DefaultMQProducerImpl.cpp	76	17	7
bool EventLoop::CreateSslContext() in src/transport/EventLoop.cpp	83	16	1
string MQClientAPIImpl::fetchNameServerAddr() in src/MQClientAPIImpl.cpp	65	16	1
int64 RebalancePush::computePullFromWhere() in src/consumer/Rebalance.cpp	82	16	1
void SendCallbackWrap::operationComplete() in src/common/AsyncCallbackWrap.cpp	62	15	2
void Rebalance::doRebalance() in src/consumer/Rebalance.cpp	80	15	0
void DefaultMQPushConsumerImpl::pullMessageAsync() in src/consumer/DefaultMQPushConsumerImpl.cpp	87	15	1
void RemotingCommand::SetExtHeader() in src/protocol/RemotingCommand.cpp	48	15	1
TraceTransferBean TraceUtil::CovertTraceContextToTransferBean() in src/trace/TraceUtil.cpp	79	15	1
SendResult DefaultMQProducerImpl::sendDefaultImpl() in src/producer/DefaultMQProducerImpl.cpp	67	15	4
virtual void allocate() in src/consumer/AllocateMQStrategy.h	45	14	4
bool SyncfetchNsAddr() in src/common/sync_http_client.cpp	66	13	2
int main() in example/PullConsumer.cpp	64	13	2
std::shared_ptr TcpRemotingClient::CreateTransport() in src/transport/TcpRemotingClient.cpp	54	12	2
void PullCallbackWrap::operationComplete() in src/common/AsyncCallbackWrap.cpp	36	12	2
bool RebalancePush::updateRequestTableInRebalance() in src/consumer/Rebalance.cpp	65	12	2
void DefaultMQPushConsumerImpl::start() in src/consumer/DefaultMQPushConsumerImpl.cpp	79	12	0
TransactionSendResult TransactionMQProducerImpl::sendMessageInTransaction() in src/producer/TransactionMQProducerImpl.cpp	54	12	2
int add_param_to_list() in libs/signature/src/param_list.c	52	12	3
static int _load_credential() in libs/signature/src/spas_client.c	29	11	2
void DefaultMQPullConsumerImpl::start() in src/consumer/DefaultMQPullConsumerImpl.cpp	60	10	0
void MQClientFactory::resetOffset() in src/MQClientFactory.cpp	47	10	3
bool UtilAll::StringToInt32() in src/common/UtilAll.cpp	17	9	2
void Rebalance::unlockAll() in src/consumer/Rebalance.cpp	45	9	1
void Rebalance::lockAll() in src/consumer/Rebalance.cpp	51	9	0
void DefaultMQPushConsumerImpl::logConfigs() in src/consumer/DefaultMQPushConsumerImpl.cpp	36	9	0
bool MQClientFactory::updateTopicRouteInfoFromNameServer() in src/MQClientFactory.cpp	54	9	3
boost::shared_ptr MQClientFactory::topicRouteData2TopicPublishInfo() in src/MQClientFactory.cpp	36	9	2
void MQClientFactory::shutdown() in src/MQClientFactory.cpp	35	9	0
void MQClientFactory::sendHeartbeatToAllBroker() in src/MQClientFactory.cpp	32	9	0
MQMessageQueue selectOneMessageQueue() in src/producer/TopicPublishInfo.h	45	9	2
BatchMessage DefaultMQProducerImpl::buildBatchMessage() in src/producer/DefaultMQProducerImpl.cpp	37	9	1
int main() in example/PullConsumeMessage.c	57	9	2
int spas_load_credential() in libs/signature/src/spas_client.c	43	9	2
bool TcpRemotingClient::CloseTransport() in src/transport/TcpRemotingClient.cpp	33	8	2
u_long TcpTransport::getInetAddr() in src/transport/TcpTransport.cpp	35	8	1
void TcpTransport::readNextMessageIntCallback() in src/transport/TcpTransport.cpp	41	8	2
bool UtilAll::StringToInt64() in src/common/UtilAll.cpp	15	8	2
void MemoryBlock::setSize() in src/common/dataBlock.cpp	19	8	2
int64 LocalFileOffsetStore::readOffset() in src/consumer/OffsetStore.cpp	33	8	3
int64 RemoteBrokerOffsetStore::readOffset() in src/consumer/OffsetStore.cpp	32	8	3
std::shared_ptr TcpRemotingClient::CreateNameServerTransport() in src/transport/TcpRemotingClient.cpp	30	7	1
void ClientRPCHook::doBeforeRequest() in src/common/ClientRPCHook.cpp	38	7	2