apache / pulsar-dotpulsar - 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 691 units with 7,013 lines of code in units (52.0% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
12 medium complex units (518 lines of code)
51 simple units (1,061 lines of code)
628 very simple units (5,434 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
private async Task Monitor() in src/DotPulsar/Internal/Consumer.cs	74	19	0
public async ValueTask Enqueue() in src/DotPulsar/Internal/Producer.cs	73	17	4
private async ValueTask Processor() in src/DotPulsar/Internal/MessageProcessor.cs	54	15	1
public static uint ReadUInt32() in src/DotPulsar/Internal/Extensions/ReadOnlySequenceExtensions.cs	43	15	3
public static bool TryParse() in src/DotPulsar/MessageId.cs	44	15	2
private async Task Monitor() in src/DotPulsar/Internal/Producer.cs	43	14	0
private async Task Monitor() in src/DotPulsar/Internal/Reader.cs	45	13	0
private bool ValidateServerCertificate() in src/DotPulsar/Internal/Connector.cs	23	12	4
private static Encode FindEncode() in src/DotPulsar/Internal/Compression/Lz4Compression.cs	22	12	2
protected override void CalculateState() in src/DotPulsar/Internal/ConsumerProcess.cs	40	12	0
public void Handle() in src/DotPulsar/Internal/Abstractions/Process.cs	36	11	1
private static Decode FindDecode() in src/DotPulsar/Internal/Compression/Lz4Compression.cs	21	11	1
protected override void CalculateState() in src/DotPulsar/Internal/ProducerProcess.cs	35	10	0
public override bool Equals() in src/DotPulsar/MessageId.cs	16	10	1
private static TypeInfo FindDecompressor() in src/DotPulsar/Internal/Compression/ZstdSharpCompression.cs	16	9	2
private static TypeInfo FindCompressor() in src/DotPulsar/Internal/Compression/ZstdSharpCompression.cs	16	9	2
private static TypeInfo Find() in src/DotPulsar/Internal/Compression/ZstdCompression.cs	16	9	2
private static MethodInfo FindUnwrap() in src/DotPulsar/Internal/Compression/ZstdCompression.cs	19	9	1
private string GetBrokerServiceUrl() in src/DotPulsar/Internal/ConnectionPool.cs	20	8	1
protected override void CalculateState() in src/DotPulsar/Internal/ReaderProcess.cs	30	8	0
public async ValueTask Send() in src/DotPulsar/Internal/ChunkingPipeline.cs	35	8	1
private static TypeInfo FindSnappy() in src/DotPulsar/Internal/Compression/SnappyCompression.cs	13	8	1
private static MethodInfo FindUnwrap() in src/DotPulsar/Internal/Compression/ZstdSharpCompression.cs	18	8	1
private static TypeInfo FindLZ4Codec() in src/DotPulsar/Internal/Compression/Lz4Compression.cs	13	8	1
public void Register() in src/DotPulsar/Internal/ProcessManager.cs	31	8	1
private object LoadGenericDatumReader() in src/DotPulsar/Schemas/AvroGenericRecordSchema.cs	24	8	0
private static MethodInfo LoadGenericDatumWriterMethod() in src/DotPulsar/Schemas/AvroGenericRecordSchema.cs	20	8	1
private static object LoadSpecificDatumWriter() in src/DotPulsar/Schemas/AvroISpecificRecordSchema.cs	24	8	0
private static MethodInfo LoadSpecificDatumWriterMethod() in src/DotPulsar/Schemas/AvroISpecificRecordSchema.cs	20	8	1
public static ReadOnlySequence GetBytes() in benchmarks/Compression/MessageBytes.cs	10	7	2
public static async ValueTask OnStateChangeTo() in src/DotPulsar/Extensions/StateHolderExtensions.cs	47	7	4
public async ValueTask NextItem() in src/DotPulsar/Internal/AsyncQueueWithCursor.cs	45	7	1
private async Task ProcessIncomingFrames() in src/DotPulsar/Internal/Connection.cs	26	7	1
public async ValueTask FindConnectionForTopic() in src/DotPulsar/Internal/ConnectionPool.cs	33	7	2
private static CommandConnect WithProxyToBroker() in src/DotPulsar/Internal/ConnectionPool.cs	16	7	2
private static async Task GetStream() in src/DotPulsar/Internal/Connector.cs	29	7	3
public async Task Send() in src/DotPulsar/Internal/ProducerChannel.cs	41	7	4
private static TypeInfo FindLZ4Level() in src/DotPulsar/Internal/Compression/Lz4Compression.cs	13	7	1
public static uint Calculate() in src/DotPulsar/Internal/Crc32C.cs	40	7	1
private static TypeInfo LoadSchemaType() in src/DotPulsar/Schemas/AvroGenericRecordSchema.cs	9	7	1
private static MethodInfo LoadAvroSchemaParseMethod() in src/DotPulsar/Schemas/AvroGenericRecordSchema.cs	16	7	1
private static Type LoadSpecificDatumWriterType() in src/DotPulsar/Schemas/AvroISpecificRecordSchema.cs	10	7	1
private static Type LoadSpecificDatumReaderType() in src/DotPulsar/Schemas/AvroISpecificRecordSchema.cs	10	7	1
static Factories() in benchmarks/Compression/Factories.cs	23	6	0
public static async ValueTask OnStateChangeTo() in src/DotPulsar/Extensions/StateExtensions.cs	27	6	4
public static async ValueTask OnStateChangeFrom() in src/DotPulsar/Extensions/StateExtensions.cs	27	6	4
public async ValueTask Process() in src/DotPulsar/Internal/MessageProcessor.cs	20	6	1
private async ValueTask AcknowledgeProcessedMessages() in src/DotPulsar/Internal/MessageProcessor.cs	20	6	1
public MessageIdData? Acknowledge() in src/DotPulsar/Internal/BatchHandler.cs	21	6	1
public static bool StartsWith() in src/DotPulsar/Internal/Extensions/ReadOnlySequenceExtensions.cs	20	6	2