apache / rocketmq-mqttConditional 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 882 units with 7,989 lines of code in units (67.1% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
15 medium complex units (673 lines of code)
68 simple units (1,873 lines of code)
799 very simple units (5,443 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
public void notifyPullMessage() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java	52	16	3
private void masterLoop() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java	58	16	0
private void _getAllPath() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Trie.java	34	16	7
public PullResultStatus pullMessage() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java	81	15	6
public boolean addSendingMessages() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java	42	14	3
private void doPull() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java	58	14	1
private void doRetryCache() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/RetryDriver.java	50	13	0
public void freshQueue() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java	39	13	2
protected void channelRead0() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketDispatcher.java	50	12	2
private void _channelRead0() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketDispatcher.java	35	11	3
private boolean preHandler() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketDispatcher.java	26	11	2
public void notify() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/notify/MessageNotifyAction.java	26	11	1
public void ack() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java	37	11	3
private void loadCache() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java	52	11	6
public static boolean isMatch() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/TopicUtils.java	33	11	2
public void notifyMessage() in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java	36	10	1
public void doHandler() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttSubscribeHandler.java	47	10	3
public void push() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/PushAction.java	33	10	4
public void removeSubscription() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match/MatchAction.java	26	10	2
public static void addInvoke() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/StatUtil.java	34	10	4
private static String getLocalAddress() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/IpUtil.java	32	10	0
private Set findValuePath() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Trie.java	32	10	6
private void refresh() in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java	30	9	0
public void checkFirstTopicIfCreated() in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/FirstTopicManager.java	24	9	1
public void save() in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store/LmqOffsetStoreManager.java	33	9	2
public void onApply() in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttStateMachine.java	49	9	1
public void closeConnect() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/DefaultChannelManager.java	56	9	3
private void saveRetryQueue() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/RetryDriver.java	39	9	2
public Message rollNext() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java	34	9	3
public List pendMessageList() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java	26	9	2
public Session unloadSession() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java	31	9	2
private void handleShutDownCS() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java	47	9	1
public static void addPv() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/StatUtil.java	30	9	3
private void refreshMeta() in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/MetaPersistManagerSample.java	37	8	0
public static File openFile() in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/DiskUtils.java	31	8	3
public Response onReadRequest() in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java	49	8	1
private void sendRetainMessage() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttSubscribeHandler.java	33	8	2
public void doHandler() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttConnectHandler.java	47	8	3
public void messageArrive() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/PushAction.java	22	8	3
public void addSubscription() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match/MatchAction.java	21	8	2
private void addSubscriptionAndInit() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java	26	8	3
private void initOffset() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java	34	8	6
private void csLoop() in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java	27	8	0
private static void printSecondInvokeStat() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/StatUtil.java	38	8	0
public boolean equals() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java	16	8	1
public synchronized boolean deleteTrieNode() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Trie.java	28	8	2
private Map findValueSet() in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Trie.java	22	8	5
private Message toLmqMessage() in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store/LmqQueueStoreManager.java	33	7	2
public static boolean writeFile() in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/DiskUtils.java	17	7	3
public Response onWriteRequest() in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/WillMsgStateProcessor.java	27	7	1