apache / rocketmq-clients - 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 2,847 units with 28,003 lines of code in units (52.4% of code).

3 very complex units (745 lines of code)
5 complex units (503 lines of code)
37 medium complex units (2,447 lines of code)
118 simple units (3,962 lines of code)
2,684 very simple units (20,346 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
func file_service_proto_init() in golang/protocol/v2/service.pb.go	391	90	0
func file_definition_proto_init() in golang/protocol/v2/definition.pb.go	277	63	0
public static void Check() in csharp/rocketmq-client-csharp/StatusChecker.cs	77	51	3
std::string ErrorCategory::message() in cpp/source/base/ErrorCategory.cpp	134	47	1
public static void check() in java/client/src/main/java/org/apache/rocketmq/client/java/exception/StatusChecker.java	71	45	2
static check() in nodejs/src/exception/StatusChecker.ts	62	44	2
def check() in python/rocketmq/v5/util/messaging_result_checker.py	71	43	1
bool ClientManagerImpl::send() in cpp/source/client/ClientManagerImpl.cpp	165	29	4
MessageConstSharedPtr ClientManagerImpl::wrapMessage() in cpp/source/client/ClientManagerImpl.cpp	141	24	1
void ReceiveMessageStreamReader::OnReadDone() in cpp/source/client/ReceiveMessageStreamReader.cpp	91	21	1
public static MessageView FromProtobuf() in csharp/rocketmq-client-csharp/MessageView.cs	96	19	2
void OpencensusExporter::wrap() in cpp/source/stats/OpencensusExporter.cpp	114	19	2
void LogInterceptor::Intercept() in cpp/source/client/LogInterceptor.cpp	60	18	1
func() in golang/producer.go	80	16	1
func() in golang/producer.go	57	16	1
void ClientManagerImpl::ack() in cpp/source/client/ClientManagerImpl.cpp	94	16	5
void ClientManagerImpl::endTransaction() in cpp/source/client/ClientManagerImpl.cpp	98	16	5
public static MessageViewImpl fromProtobuf() in java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java	76	15	3
func() in golang/simple_consumer.go	70	15	1
func MatchCompressionAlgorithm() in golang/pkg/utils/utils.go	20	15	1
void ClientManagerImpl::queryAssignment() in cpp/source/client/ClientManagerImpl.cpp	90	15	5
func() in golang/client.go	58	14	1
void ClientManagerImpl::resolveRoute() in cpp/source/client/ClientManagerImpl.cpp	94	14	5
void ClientManagerImpl::changeInvisibleDuration() in cpp/source/client/ClientManagerImpl.cpp	83	14	5
void ClientManagerImpl::recallMessage() in cpp/source/client/ClientManagerImpl.cpp	85	14	5
void ClientManagerImpl::forwardMessageToDeadLetterQueue() in cpp/source/client/ClientManagerImpl.cpp	77	14	5
bool UtilAll::macAddress() in cpp/source/base/UtilAll.cpp	71	14	1
func FromTraceParentHeader() in golang/pkg/utils/utils.go	30	13	1
func fromProtobuf_MessageView2() in golang/message.go	74	13	3
void ProducerImpl::wrapSendMessageRequest() in cpp/source/rocketmq/ProducerImpl.cpp	63	13	3
private static FilterInputStream getStreamByMagicCode() in java/client/src/main/java/org/apache/rocketmq/client/java/misc/Utilities.java	17	12	2
public PublishingMessageImpl() in java/client/src/main/java/org/apache/rocketmq/client/java/message/PublishingMessageImpl.java	29	12	3
constructor() in nodejs/src/message/PublishingMessage.ts	27	12	3
func() in golang/loadBalancer.go	49	12	1
public PublishingMessage() in csharp/rocketmq-client-csharp/PublishingMessage.cs	32	12	3
void SimpleConsumerImpl::updateAssignments() in cpp/source/rocketmq/SimpleConsumerImpl.cpp	47	12	2
void ConsumeTask::process() in cpp/source/rocketmq/ConsumeTask.cpp	88	12	0
void ClientImpl::start() in cpp/source/rocketmq/ClientImpl.cpp	87	12	0
def __send_message_type() in python/rocketmq/v5/producer/producer.py	23	11	3
bool PushConsumerImpl::selectBroker() in cpp/source/rocketmq/PushConsumerImpl.cpp	32	11	2
void PushConsumerImpl::syncProcessQueue() in cpp/source/rocketmq/PushConsumerImpl.cpp	49	11	3
void ClientImpl::updateRouteCache() in cpp/source/rocketmq/ClientImpl.cpp	40	11	3
void TelemetryBidiReactor::OnReadDone() in cpp/source/client/TelemetryBidiReactor.cpp	74	11	1
void ClientManagerImpl::heartbeat() in cpp/source/client/ClientManagerImpl.cpp	77	11	5
void StdoutHandler::ExportViewData() in cpp/source/stats/StdoutHandler.cpp	54	11	1
public Endpoints() in java/client/src/main/java/org/apache/rocketmq/client/java/route/Endpoints.java	37	10	1
def __stop_client_threads() in python/rocketmq/v5/client/client.py	29	10	1
def __send_req() in python/rocketmq/v5/producer/producer.py	34	10	2
takeMessageQueues() in nodejs/src/producer/PublishingLoadBalancer.ts	36	10	2
public Endpoints() in csharp/rocketmq-client-csharp/Endpoints.cs	41	10	1