Path	Lines of Code
common/src/main/java/org/apache/rocketmq/common/AbortProcessException.java	31
common/src/main/java/org/apache/rocketmq/common/AbstractBrokerRunnable.java	22
common/src/main/java/org/apache/rocketmq/common/BoundaryType.java	18
common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java	1424
common/src/main/java/org/apache/rocketmq/common/BrokerConfigSingleton.java	18
common/src/main/java/org/apache/rocketmq/common/BrokerIdentity.java	104
common/src/main/java/org/apache/rocketmq/common/CheckRocksdbCqWriteResult.java	30
common/src/main/java/org/apache/rocketmq/common/ConfigManager.java	66
common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java	218
common/src/main/java/org/apache/rocketmq/common/CountDownLatch2.java	59
common/src/main/java/org/apache/rocketmq/common/JraftConfig.java	55
common/src/main/java/org/apache/rocketmq/common/KeyBuilder.java	56
common/src/main/java/org/apache/rocketmq/common/LifecycleAwareServiceThread.java	27
common/src/main/java/org/apache/rocketmq/common/LockCallback.java	7
common/src/main/java/org/apache/rocketmq/common/MQVersion.java	633
common/src/main/java/org/apache/rocketmq/common/MixAll.java	473
common/src/main/java/org/apache/rocketmq/common/ObjectCreator.java	4
common/src/main/java/org/apache/rocketmq/common/Pair.java	25
common/src/main/java/org/apache/rocketmq/common/PopAckConstants.java	21
common/src/main/java/org/apache/rocketmq/common/ServiceState.java	7
common/src/main/java/org/apache/rocketmq/common/ServiceThread.java	96
common/src/main/java/org/apache/rocketmq/common/SubscriptionGroupAttributes.java	10
common/src/main/java/org/apache/rocketmq/common/SystemClock.java	6
common/src/main/java/org/apache/rocketmq/common/ThreadFactoryImpl.java	39
common/src/main/java/org/apache/rocketmq/common/TopicAttributes.java	43
common/src/main/java/org/apache/rocketmq/common/TopicConfig.java	207
common/src/main/java/org/apache/rocketmq/common/TopicFilterType.java	5
common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java	33
common/src/main/java/org/apache/rocketmq/common/UnlockCallback.java	5
common/src/main/java/org/apache/rocketmq/common/UtilAll.java	638
common/src/main/java/org/apache/rocketmq/common/action/Action.java	36
common/src/main/java/org/apache/rocketmq/common/action/RocketMQAction.java	10
common/src/main/java/org/apache/rocketmq/common/annotation/ImportantField.java	11
common/src/main/java/org/apache/rocketmq/common/attribute/Attribute.java	22
common/src/main/java/org/apache/rocketmq/common/attribute/AttributeParser.java	57
common/src/main/java/org/apache/rocketmq/common/attribute/AttributeUtil.java	99
common/src/main/java/org/apache/rocketmq/common/attribute/BooleanAttribute.java	19
common/src/main/java/org/apache/rocketmq/common/attribute/CQType.java	6
common/src/main/java/org/apache/rocketmq/common/attribute/CleanupPolicy.java	5
common/src/main/java/org/apache/rocketmq/common/attribute/EnumAttribute.java	20
common/src/main/java/org/apache/rocketmq/common/attribute/LongRangeAttribute.java	23
common/src/main/java/org/apache/rocketmq/common/attribute/TopicMessageType.java	41
common/src/main/java/org/apache/rocketmq/common/chain/Handler.java	4
common/src/main/java/org/apache/rocketmq/common/chain/HandlerChain.java	28
common/src/main/java/org/apache/rocketmq/common/coldctr/AccAndTimeStamp.java	36
common/src/main/java/org/apache/rocketmq/common/compression/CompressionType.java	51
common/src/main/java/org/apache/rocketmq/common/compression/Compressor.java	6
common/src/main/java/org/apache/rocketmq/common/compression/CompressorFactory.java	14
common/src/main/java/org/apache/rocketmq/common/compression/Lz4Compressor.java	63
common/src/main/java/org/apache/rocketmq/common/compression/ZlibCompressor.java	73
common/src/main/java/org/apache/rocketmq/common/compression/ZstdCompressor.java	63
common/src/main/java/org/apache/rocketmq/common/config/AbstractRocksDBStorage.java	495
common/src/main/java/org/apache/rocketmq/common/config/ConfigHelper.java	104
common/src/main/java/org/apache/rocketmq/common/config/ConfigManagerVersion.java	13
common/src/main/java/org/apache/rocketmq/common/config/ConfigRocksDBStorage.java	106
common/src/main/java/org/apache/rocketmq/common/consistenthash/ConsistentHashRouter.java	84
common/src/main/java/org/apache/rocketmq/common/consistenthash/HashFunction.java	4
common/src/main/java/org/apache/rocketmq/common/consistenthash/Node.java	4
common/src/main/java/org/apache/rocketmq/common/consistenthash/VirtualNode.java	19
common/src/main/java/org/apache/rocketmq/common/constant/CommonConstants.java	11
common/src/main/java/org/apache/rocketmq/common/constant/ConsumeInitMode.java	5
common/src/main/java/org/apache/rocketmq/common/constant/DBMsgConstants.java	4
common/src/main/java/org/apache/rocketmq/common/constant/FIleReadaheadMode.java	4
common/src/main/java/org/apache/rocketmq/common/constant/GrpcConstants.java	36
common/src/main/java/org/apache/rocketmq/common/constant/HAProxyConstants.java	10
common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java	40
common/src/main/java/org/apache/rocketmq/common/constant/PermName.java	45
common/src/main/java/org/apache/rocketmq/common/consumer/ConsumeFromWhere.java	12
common/src/main/java/org/apache/rocketmq/common/consumer/ReceiptHandle.java	184
common/src/main/java/org/apache/rocketmq/common/fastjson/GenericMapSuperclassDeserializer.java	36
common/src/main/java/org/apache/rocketmq/common/filter/ExpressionType.java	11
common/src/main/java/org/apache/rocketmq/common/filter/FilterContext.java	10
common/src/main/java/org/apache/rocketmq/common/filter/MessageFilter.java	5
common/src/main/java/org/apache/rocketmq/common/filter/impl/Op.java	13
common/src/main/java/org/apache/rocketmq/common/filter/impl/Operand.java	6
common/src/main/java/org/apache/rocketmq/common/filter/impl/Operator.java	43
common/src/main/java/org/apache/rocketmq/common/filter/impl/PolishExpr.java	126
common/src/main/java/org/apache/rocketmq/common/filter/impl/Type.java	8
common/src/main/java/org/apache/rocketmq/common/future/FutureTaskExt.java	17
common/src/main/java/org/apache/rocketmq/common/help/FAQUrl.java	40
common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java	6
common/src/main/java/org/apache/rocketmq/common/logging/DefaultJoranConfiguratorExt.java	137
common/src/main/java/org/apache/rocketmq/common/logging/JoranConfiguratorExt.java	49
common/src/main/java/org/apache/rocketmq/common/message/Message.java	191
common/src/main/java/org/apache/rocketmq/common/message/MessageAccessor.java	68
common/src/main/java/org/apache/rocketmq/common/message/MessageBatch.java	48
common/src/main/java/org/apache/rocketmq/common/message/MessageClientExt.java	20
common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java	121
common/src/main/java/org/apache/rocketmq/common/message/MessageConst.java	123
common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java	565
common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java	217
common/src/main/java/org/apache/rocketmq/common/message/MessageExtBatch.java	23
common/src/main/java/org/apache/rocketmq/common/message/MessageExtBrokerInner.java	71
common/src/main/java/org/apache/rocketmq/common/message/MessageId.java	22
common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java	90
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java	51
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java	101
common/src/main/java/org/apache/rocketmq/common/message/MessageRequestMode.java	12
common/src/main/java/org/apache/rocketmq/common/message/MessageType.java	23
common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java	59
common/src/main/java/org/apache/rocketmq/common/metrics/MetricsExporterType.java	29
common/src/main/java/org/apache/rocketmq/common/metrics/NopLongCounter.java	12
common/src/main/java/org/apache/rocketmq/common/metrics/NopLongHistogram.java	12
common/src/main/java/org/apache/rocketmq/common/metrics/NopLongUpDownCounter.java	12
common/src/main/java/org/apache/rocketmq/common/metrics/NopObservableDoubleGauge.java	4
common/src/main/java/org/apache/rocketmq/common/metrics/NopObservableLongGauge.java	4
common/src/main/java/org/apache/rocketmq/common/namesrv/DefaultTopAddressing.java	128
common/src/main/java/org/apache/rocketmq/common/namesrv/NameServerUpdateCallback.java	4
common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java	159
common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java	4
common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java	5
common/src/main/java/org/apache/rocketmq/common/producer/RecallMessageHandle.java	59
common/src/main/java/org/apache/rocketmq/common/queue/ConcurrentTreeMap.java	46
common/src/main/java/org/apache/rocketmq/common/queue/RoundQueue.java	22
common/src/main/java/org/apache/rocketmq/common/resource/ResourcePattern.java	20
common/src/main/java/org/apache/rocketmq/common/resource/ResourceType.java	32
common/src/main/java/org/apache/rocketmq/common/resource/RocketMQResource.java	8
common/src/main/java/org/apache/rocketmq/common/running/RunningStats.java	8
common/src/main/java/org/apache/rocketmq/common/state/StateEventListener.java	4
common/src/main/java/org/apache/rocketmq/common/statistics/FutureHolder.java	32
common/src/main/java/org/apache/rocketmq/common/statistics/Interceptor.java	5
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsBrief.java	133
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsBriefInterceptor.java	47
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItem.java	108
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemFormatter.java	15
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemPrinter.java	25
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledIncrementPrinter.java	209
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledPrinter.java	52
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemStateGetter.java	4
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsKindMeta.java	24
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsManager.java	97
common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItem.java	54
common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java	101
common/src/main/java/org/apache/rocketmq/common/stats/RTStatsItem.java	13
common/src/main/java/org/apache/rocketmq/common/stats/Stats.java	31
common/src/main/java/org/apache/rocketmq/common/stats/StatsItem.java	206
common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java	225
common/src/main/java/org/apache/rocketmq/common/stats/StatsSnapshot.java	31
common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java	33
common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java	57
common/src/main/java/org/apache/rocketmq/common/sysflag/SubscriptionSysFlag.java	22
common/src/main/java/org/apache/rocketmq/common/sysflag/TopicSysFlag.java	33
common/src/main/java/org/apache/rocketmq/common/thread/FutureTaskExtThreadPoolExecutor.java	21
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolMonitor.java	101
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolQueueSizeMonitor.java	20
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolStatusMonitor.java	7
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java	86
common/src/main/java/org/apache/rocketmq/common/topic/TopicValidator.java	106
common/src/main/java/org/apache/rocketmq/common/utils/AbstractStartAndShutdown.java	51
common/src/main/java/org/apache/rocketmq/common/utils/AsyncShutdownHelper.java	52
common/src/main/java/org/apache/rocketmq/common/utils/BinaryUtil.java	36
common/src/main/java/org/apache/rocketmq/common/utils/ChannelUtil.java	14
common/src/main/java/org/apache/rocketmq/common/utils/CheckpointFile.java	92
common/src/main/java/org/apache/rocketmq/common/utils/CleanupPolicyUtils.java	27
common/src/main/java/org/apache/rocketmq/common/utils/ConcurrentHashMapUtils.java	33
common/src/main/java/org/apache/rocketmq/common/utils/CorrelationIdUtil.java	7
common/src/main/java/org/apache/rocketmq/common/utils/DataConverter.java	21
common/src/main/java/org/apache/rocketmq/common/utils/ExceptionUtils.java	24
common/src/main/java/org/apache/rocketmq/common/utils/FastJsonSerializer.java	37
common/src/main/java/org/apache/rocketmq/common/utils/FutureUtils.java	24
common/src/main/java/org/apache/rocketmq/common/utils/HttpTinyClient.java	99
common/src/main/java/org/apache/rocketmq/common/utils/IOTinyUtils.java	123
common/src/main/java/org/apache/rocketmq/common/utils/IPAddressUtils.java	77
common/src/main/java/org/apache/rocketmq/common/utils/MessageUtils.java	68
common/src/main/java/org/apache/rocketmq/common/utils/NameServerAddressUtils.java	29
common/src/main/java/org/apache/rocketmq/common/utils/NetworkUtil.java	171
common/src/main/java/org/apache/rocketmq/common/utils/PositiveAtomicCounter.java	16
common/src/main/java/org/apache/rocketmq/common/utils/QueueTypeUtils.java	27
common/src/main/java/org/apache/rocketmq/common/utils/Serializer.java	6
common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java	139
common/src/main/java/org/apache/rocketmq/common/utils/Shutdown.java	4
common/src/main/java/org/apache/rocketmq/common/utils/Start.java	4
common/src/main/java/org/apache/rocketmq/common/utils/StartAndShutdown.java	4
common/src/main/java/org/apache/rocketmq/common/utils/ThreadUtils.java	139