apache / rocketmq-clientsConditional 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,395 units with 22,765 lines of code in units (52.7% of code).

2 very complex units (668 lines of code)
4 complex units (430 lines of code)
34 medium complex units (2,411 lines of code)
96 simple units (3,300 lines of code)
2,259 very simple units (15,956 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	75	50	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	69	44	2
bool ClientManagerImpl::send() in cpp/source/client/ClientManagerImpl.cpp	152	27	4
MessageConstSharedPtr ClientManagerImpl::wrapMessage() in cpp/source/client/ClientManagerImpl.cpp	142	24	1
void ReceiveMessageStreamReader::OnReadDone() in cpp/source/client/ReceiveMessageStreamReader.cpp	91	21	1
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	56	16	1
void ClientManagerImpl::ack() in cpp/source/client/ClientManagerImpl.cpp	91	16	5
void ClientManagerImpl::endTransaction() in cpp/source/client/ClientManagerImpl.cpp	96	16	5
def check() in python/rocketmq/status_checker.py	77	15	3
func() in golang/simple_consumer.go	70	15	1
public static MessageViewImpl fromProtobuf() in java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java	76	15	3
void ClientManagerImpl::queryAssignment() in cpp/source/client/ClientManagerImpl.cpp	88	15	5
public static MessageView FromProtobuf() in csharp/rocketmq-client-csharp/MessageView.cs	89	15	2
def __init__() in python/rocketmq/rpc_client.py	47	14	2
void ClientManagerImpl::resolveRoute() in cpp/source/client/ClientManagerImpl.cpp	92	14	5
void ClientManagerImpl::changeInvisibleDuration() in cpp/source/client/ClientManagerImpl.cpp	80	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 fromProtobuf_MessageView2() in golang/message.go	74	13	3
func FromTraceParentHeader() in golang/pkg/utils/utils.go	30	13	1
void TelemetryBidiReactor::OnReadDone() in cpp/source/client/TelemetryBidiReactor.cpp	86	13	1
void ProducerImpl::wrapSendMessageRequest() in cpp/source/rocketmq/ProducerImpl.cpp	60	13	3
def __init__() in python/rocketmq/publishing_message.py	22	12	4
func() in golang/loadBalancer.go	49	12	1
public PublishingMessageImpl() in java/client/src/main/java/org/apache/rocketmq/client/java/message/PublishingMessageImpl.java	29	12	3
void ClientImpl::start() in cpp/source/rocketmq/ClientImpl.cpp	86	12	0
void SimpleConsumerImpl::updateAssignments() in cpp/source/rocketmq/SimpleConsumerImpl.cpp	47	12	2
void ConsumeTask::process() in cpp/source/rocketmq/ConsumeTask.cpp	88	12	0
public PublishingMessage() in csharp/rocketmq-client-csharp/PublishingMessage.cs	32	12	3
fn transform_messages_to_protobuf() in rust/src/producer.rs	94	11	2
void ClientManagerImpl::heartbeat() in cpp/source/client/ClientManagerImpl.cpp	75	11	5
void StdoutHandler::ExportViewData() in cpp/source/stats/StdoutHandler.cpp	54	11	1
void ClientImpl::updateRouteCache() in cpp/source/rocketmq/ClientImpl.cpp	40	11	3
void PushConsumerImpl::syncProcessQueue() in cpp/source/rocketmq/PushConsumerImpl.cpp	48	11	3
def take_message_queues() in python/rocketmq/producer.py	26	10	3
private void send0() in java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java	86	10	6
public Endpoints() in java/client/src/main/java/org/apache/rocketmq/client/java/route/Endpoints.java	37	10	1
def main() in cpp/tools/fix_copyright.py	25	10	0
void LoggerImpl::init0() in cpp/source/log/LoggerImpl.cpp	59	10	0
int RSA_set0_crt_params() in cpp/source/client/include/OpenSSLCompatible.h	17	10	4
int DSA_set0_pqg() in cpp/source/client/include/OpenSSLCompatible.h	17	10	4
std::error_code ClientManagerImpl::notifyClientTermination() in cpp/source/client/ClientManagerImpl.cpp	62	10	4
private async Task Send0() in csharp/rocketmq-client-csharp/Producer.cs	78	10	2
public Endpoints() in csharp/rocketmq-client-csharp/Endpoints.cs	41	10	1