Path	Lines of Code
store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java	262
store/src/main/java/org/apache/rocketmq/store/AppendMessageCallback.java	10
store/src/main/java/org/apache/rocketmq/store/AppendMessageResult.java	120
store/src/main/java/org/apache/rocketmq/store/AppendMessageStatus.java	9
store/src/main/java/org/apache/rocketmq/store/CommitLog.java	1970
store/src/main/java/org/apache/rocketmq/store/CommitLogDispatcher.java	5
store/src/main/java/org/apache/rocketmq/store/CompactionAppendMsgCallback.java	5
store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java	979
store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java	367
store/src/main/java/org/apache/rocketmq/store/DefaultMessageFilter.java	25
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java	2709
store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java	202
store/src/main/java/org/apache/rocketmq/store/FileQueueSnapshot.java	61
store/src/main/java/org/apache/rocketmq/store/FlushDiskWatcher.java	53
store/src/main/java/org/apache/rocketmq/store/FlushManager.java	11
store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java	139
store/src/main/java/org/apache/rocketmq/store/GetMessageStatus.java	13
store/src/main/java/org/apache/rocketmq/store/LmqDispatch.java	36
store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java	739
store/src/main/java/org/apache/rocketmq/store/MessageArrivingListener.java	6
store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java	287
store/src/main/java/org/apache/rocketmq/store/MessageFilter.java	9
store/src/main/java/org/apache/rocketmq/store/MessageStore.java	166
store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java	89
store/src/main/java/org/apache/rocketmq/store/PutMessageContext.java	24
store/src/main/java/org/apache/rocketmq/store/PutMessageLock.java	5
store/src/main/java/org/apache/rocketmq/store/PutMessageReentrantLock.java	13
store/src/main/java/org/apache/rocketmq/store/PutMessageResult.java	47
store/src/main/java/org/apache/rocketmq/store/PutMessageSpinLock.java	17
store/src/main/java/org/apache/rocketmq/store/PutMessageStatus.java	19
store/src/main/java/org/apache/rocketmq/store/QueryMessageResult.java	43
store/src/main/java/org/apache/rocketmq/store/ReferenceResource.java	48
store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java	146
store/src/main/java/org/apache/rocketmq/store/RunningFlags.java	110
store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java	54
store/src/main/java/org/apache/rocketmq/store/SelectMappedFileResult.java	19
store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java	107
store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java	536
store/src/main/java/org/apache/rocketmq/store/StoreType.java	12
store/src/main/java/org/apache/rocketmq/store/StoreUtil.java	52
store/src/main/java/org/apache/rocketmq/store/Swappable.java	5
store/src/main/java/org/apache/rocketmq/store/TopicQueueLock.java	31
store/src/main/java/org/apache/rocketmq/store/TransientStorePool.java	60
store/src/main/java/org/apache/rocketmq/store/config/BrokerRole.java	6
store/src/main/java/org/apache/rocketmq/store/config/FlushDiskType.java	5
store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java	1348
store/src/main/java/org/apache/rocketmq/store/config/StorePathConfigHelper.java	34
store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java	910
store/src/main/java/org/apache/rocketmq/store/exception/ConsumeQueueException.java	18
store/src/main/java/org/apache/rocketmq/store/exception/StoreException.java	17
store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAClient.java	312
store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAConnection.java	363
store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java	288
store/src/main/java/org/apache/rocketmq/store/ha/FlowMonitor.java	46
store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java	128
store/src/main/java/org/apache/rocketmq/store/ha/HAClient.java	16
store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java	13
store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionState.java	8
store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionStateNotificationRequest.java	25
store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionStateNotificationService.java	105
store/src/main/java/org/apache/rocketmq/store/ha/HAService.java	39
store/src/main/java/org/apache/rocketmq/store/ha/WaitNotifyObject.java	85
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAClient.java	443
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java	558
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java	456
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/BrokerMetadata.java	72
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/EpochFileCache.java	264
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/MetadataFile.java	30
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/TempBrokerMetadata.java	65
store/src/main/java/org/apache/rocketmq/store/ha/io/AbstractHAReader.java	50
store/src/main/java/org/apache/rocketmq/store/ha/io/HAReadHook.java	4
store/src/main/java/org/apache/rocketmq/store/ha/io/HAWriteHook.java	4
store/src/main/java/org/apache/rocketmq/store/ha/io/HAWriter.java	38
store/src/main/java/org/apache/rocketmq/store/hook/PutMessageHook.java	7
store/src/main/java/org/apache/rocketmq/store/hook/SendMessageBackHook.java	6
store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java	186
store/src/main/java/org/apache/rocketmq/store/index/IndexHeader.java	84
store/src/main/java/org/apache/rocketmq/store/index/IndexService.java	321
store/src/main/java/org/apache/rocketmq/store/index/QueryOffsetResult.java	22
store/src/main/java/org/apache/rocketmq/store/kv/CommitLogDispatcherCompaction.java	15
store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java	940
store/src/main/java/org/apache/rocketmq/store/kv/CompactionPositionMgr.java	57
store/src/main/java/org/apache/rocketmq/store/kv/CompactionService.java	62
store/src/main/java/org/apache/rocketmq/store/kv/CompactionStore.java	195
store/src/main/java/org/apache/rocketmq/store/kv/MessageFetcher.java	163
store/src/main/java/org/apache/rocketmq/store/lock/AdaptiveBackOffSpinLock.java	9
store/src/main/java/org/apache/rocketmq/store/lock/AdaptiveBackOffSpinLockImpl.java	143
store/src/main/java/org/apache/rocketmq/store/lock/BackOffReentrantLock.java	13
store/src/main/java/org/apache/rocketmq/store/lock/BackOffSpinLock.java	75
store/src/main/java/org/apache/rocketmq/store/logfile/AbstractMappedFile.java	4
store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java	753
store/src/main/java/org/apache/rocketmq/store/logfile/MappedFile.java	67
store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsConstant.java	30
store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java	216
store/src/main/java/org/apache/rocketmq/store/metrics/RocksDBStoreMetricsManager.java	114
store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java	531
store/src/main/java/org/apache/rocketmq/store/plugin/MessageStoreFactory.java	26
store/src/main/java/org/apache/rocketmq/store/plugin/MessageStorePluginContext.java	40
store/src/main/java/org/apache/rocketmq/store/pop/AckMsg.java	73
store/src/main/java/org/apache/rocketmq/store/pop/BatchAckMsg.java	27
store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java	148
store/src/main/java/org/apache/rocketmq/store/queue/AbstractConsumeQueueStore.java	88
store/src/main/java/org/apache/rocketmq/store/queue/BatchConsumeQueue.java	949
store/src/main/java/org/apache/rocketmq/store/queue/BatchOffsetIndex.java	31
store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueInterface.java	35
store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java	499
store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStoreInterface.java	52
store/src/main/java/org/apache/rocketmq/store/queue/CqUnit.java	75
store/src/main/java/org/apache/rocketmq/store/queue/DispatchEntry.java	24
store/src/main/java/org/apache/rocketmq/store/queue/FileQueueLifeCycle.java	14
store/src/main/java/org/apache/rocketmq/store/queue/MultiDispatchUtils.java	39
store/src/main/java/org/apache/rocketmq/store/queue/OffsetInitializer.java	5
store/src/main/java/org/apache/rocketmq/store/queue/OffsetInitializerRocksDBImpl.java	22
store/src/main/java/org/apache/rocketmq/store/queue/QueueOffsetOperator.java	87
store/src/main/java/org/apache/rocketmq/store/queue/ReferredIterator.java	6
store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueue.java	366
store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueOffsetTable.java	555
store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueStore.java	444
store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueTable.java	291
store/src/main/java/org/apache/rocketmq/store/queue/RocksGroupCommitService.java	68
store/src/main/java/org/apache/rocketmq/store/queue/SparseConsumeQueue.java	321
store/src/main/java/org/apache/rocketmq/store/queue/offset/OffsetEntry.java	8
store/src/main/java/org/apache/rocketmq/store/queue/offset/OffsetEntryType.java	5
store/src/main/java/org/apache/rocketmq/store/rocksdb/ConsumeQueueCompactionFilterFactory.java	26
store/src/main/java/org/apache/rocketmq/store/rocksdb/ConsumeQueueRocksDBStorage.java	85
store/src/main/java/org/apache/rocketmq/store/rocksdb/RocksDBOptionsFactory.java	186
store/src/main/java/org/apache/rocketmq/store/stats/BrokerStats.java	56
store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java	698
store/src/main/java/org/apache/rocketmq/store/stats/LmqBrokerStatsManager.java	54
store/src/main/java/org/apache/rocketmq/store/timer/Slot.java	23
store/src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java	141
store/src/main/java/org/apache/rocketmq/store/timer/TimerLog.java	90
store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java	1673
store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java	256
store/src/main/java/org/apache/rocketmq/store/timer/TimerRequest.java	88
store/src/main/java/org/apache/rocketmq/store/timer/TimerWheel.java	167
store/src/main/java/org/apache/rocketmq/store/util/LibC.java	27
store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java	305