alibaba / loongcollector - 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 8,962 units with 157,879 lines of code in units (74.8% of code).

14 very complex units (4,367 lines of code)
55 complex units (7,080 lines of code)
366 medium complex units (24,680 lines of code)
736 simple units (25,048 lines of code)
7,791 very simple units (96,704 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() in pkg/protocol/span_event.pb.go	638	183	1
func() in pkg/protocol/pipeline_event_group.pb.go	410	113	1
bool CollectionConfig::Parse() in core/config/CollectionConfig.cpp	569	95	0
func() in plugins/input/kubernetesmetav2/meta_collector.go	158	85	1
func() in pkg/protocol/span_event.pb.go	279	78	1
func createLogstoreConfig() in pluginmanager/logstore_config.go	274	77	5
void ModifyHandler::Handle() in core/file_server/event_handler/EventHandler.cpp	364	75	1
func() in pkg/protocol/metric_event.pb.go	265	74	1
func() in pkg/protocol/sls_logs.pb.go	245	69	1
func() in pkg/protocol/span_event.pb.go	230	64	1
void AppConfig::LoadResourceConf() in core/app_config/AppConfig.cpp	211	64	1
void ProcessorFilterNativeUnittest::TestFilterNoneUtf8() in core/unittest/processor/ProcessorFilterNativeUnittest.cpp	300	61	0
bool CollectionPipeline::Init() in core/collection_pipeline/CollectionPipeline.cpp	250	58	1
func() in pkg/protocol/log_event.pb.go	174	51	1
void Logger::LoadConfig() in core/logger/Logger.cpp	142	49	1
bool SLSEventGroupSerializer::Serialize() in core/collection_pipeline/serializer/SLSSerializer.cpp	220	49	3
func file_register_Register_proto_init() in plugins/input/skywalkingv2/skywalking/apm/network/language/agent/Register.pb.go	193	45	0
func() in pkg/protocol/sls_logs.pb.go	150	42	1
bool MOODYCAMEL_NO_TSAN enqueue_bulk() in core/common/queue/concurrentqueue.h	147	41	2
ssize_t phr_decode_chunked() in core/ebpf/protocol/http/picohttpparser.cpp	124	41	3
void LogFileReader::ReadGBK() in core/file_server/reader/LogFileReader.cpp	160	40	4
bool ProcParser::ParseProcessStatus() in core/common/ProcParser.cpp	107	39	3
func binLogEventToSlsLog() in plugins/input/mysqlbinlog/mysql_binlog_helper.go	123	38	3
static void MockAsyncSendInner() in core/unittest/sender/SenderUnittest.cpp	110	37	7
bool FlusherSLS::Init() in core/plugin/flusher/sls/FlusherSLS.cpp	244	36	2
bool ProcessorParseDelimiterNative::ProcessEvent() in core/plugin/processor/ProcessorParseDelimiterNative.cpp	151	35	3
std::string GetHostIpByHostName() in core/common/MachineInfoUtil.cpp	67	34	0
bool FileDiscoveryOptions::Init() in core/file_server/FileDiscoveryOptions.cpp	194	34	3
func() in plugins/input/canal/input_canal.go	106	34	1
func() in pkg/protocol/log_event.pb.go	117	33	1
func() in pkg/protocol/sls_logs.pb.go	122	33	1
func() in pkg/protocol/sls_logs.pb.go	122	33	1
static void MockSyncSend() in core/unittest/sender/SenderUnittest.cpp	89	33	6
func() in plugins/input/canal/input_canal.go	132	33	1
func() in plugins/processor/logtoslsmetric/processor_log_to_sls_metric.go	135	33	1
void ProcessorMergeMultilineLogNative::MergeLogsByRegex() in core/plugin/processor/inner/ProcessorMergeMultilineLogNative.cpp	136	32	1
void DiskBufferWriter::SendEncryptionBuffer() in core/plugin/flusher/sls/DiskBufferWriter.cpp	181	32	2
void FlusherSLS::OnSendDone() in core/plugin/flusher/sls/FlusherSLS.cpp	204	32	2
void LogFileReader::ReadUTF8() in core/file_server/reader/LogFileReader.cpp	119	32	4
func() in pkg/helper/profile/pyroscope/jfr/parser.go	96	31	1
bool ScrapeConfig::InitStaticConfig() in core/prometheus/schedulers/ScrapeConfig.cpp	72	31	1
func() in pkg/protocol/sls_logs_transfer.pb.go	109	30	1
func() in pkg/protocol/sls_logs.pb.go	107	30	1
void TestSecondaryStorage() in core/unittest/sender/SenderUnittest.cpp	189	30	0
bool enqueue_bulk() in core/common/queue/concurrentqueue.h	121	30	2
void ProcessorSplitMultilineLogStringNative::ProcessEvent() in core/plugin/processor/inner/ProcessorSplitMultilineLogStringNative.cpp	160	30	6
func file_language_agent_DiscoveryService_proto_init() in plugins/input/skywalkingv2/skywalking/apm/network/language/agent/DiscoveryService.pb.go	135	30	0
func() in plugins/input/docker/logmeta/metric_container_info.go	126	30	1
func() in pkg/helper/container_discover_controller.go	101	29	1
bool PollingDirFile::PollingNormalConfigPath() in core/file_server/polling/PollingDirFile.cpp	126	29	5