Path	Lines of Code
src/MQClientAPIImpl.cpp	800
src/MQClientAPIImpl.h	174
src/MQClientFactory.cpp	996
src/MQClientFactory.h	159
src/MQClientManager.cpp	40
src/MQClientManager.h	27
src/common/Arg_helper.cpp	42
src/common/AsyncArg.h	13
src/common/AsyncCallbackWrap.cpp	148
src/common/AsyncCallbackWrap.h	48
src/common/ByteOrder.h	142
src/common/ClientRPCHook.cpp	52
src/common/ClientRPCHook.h	23
src/common/CommunicationMode.h	6
src/common/DefaultMQClient.cpp	207
src/common/FilterAPI.h	35
src/common/InputStream.cpp	76
src/common/InputStream.h	27
src/common/MQClientErrorContainer.cpp	10
src/common/MQClientErrorContainer.h	14
src/common/MQVersion.cpp	15
src/common/MQVersion.h	935
src/common/MemoryInputStream.cpp	48
src/common/MemoryInputStream.h	24
src/common/MemoryOutputStream.cpp	103
src/common/MemoryOutputStream.h	32
src/common/MessageAccessor.cpp	35
src/common/MessageAccessor.h	15
src/common/MessageSysFlag.cpp	15
src/common/MessageSysFlag.h	17
src/common/NameSpaceUtil.cpp	80
src/common/NameSpaceUtil.h	23
src/common/NamesrvConfig.h	27
src/common/OutputStream.cpp	68
src/common/OutputStream.h	25
src/common/PermName.cpp	30
src/common/PermName.h	17
src/common/PullSysFlag.cpp	38
src/common/PullSysFlag.h	19
src/common/ServiceState.h	6
src/common/SubscriptionGroupConfig.h	27
src/common/TopAddressing.cpp	76
src/common/TopAddressing.h	26
src/common/TopicConfig.cpp	75
src/common/TopicConfig.h	37
src/common/TopicFilterType.h	9
src/common/UtilAll.cpp	305
src/common/UtilAll.h	140
src/common/Validators.cpp	60
src/common/Validators.h	20
src/common/VirtualEnvUtil.cpp	30
src/common/VirtualEnvUtil.h	13
src/common/big_endian.cpp	73
src/common/big_endian.h	64
src/common/dataBlock.cpp	149
src/common/dataBlock.h	44
src/common/noncopyable.h	12
src/common/sync_http_client.cpp	91
src/common/sync_http_client.h	8
src/common/url.cpp	39
src/common/url.h	18
src/consumer/AllocateMQStrategy.h	65
src/consumer/ConsumeMessageConcurrentlyService.cpp	291
src/consumer/ConsumeMessageHookImpl.cpp	89
src/consumer/ConsumeMessageHookImpl.h	15
src/consumer/ConsumeMessageOrderlyService.cpp	231
src/consumer/ConsumeMsgService.h	83
src/consumer/DefaultMQPullConsumer.cpp	141
src/consumer/DefaultMQPullConsumerImpl.cpp	314
src/consumer/DefaultMQPullConsumerImpl.h	75
src/consumer/DefaultMQPushConsumer.cpp	164
src/consumer/DefaultMQPushConsumerImpl.cpp	1023
src/consumer/DefaultMQPushConsumerImpl.h	127
src/consumer/FindBrokerResult.h	11
src/consumer/OffsetStore.cpp	283
src/consumer/OffsetStore.h	70
src/consumer/PullAPIWrapper.cpp	98
src/consumer/PullAPIWrapper.h	39
src/consumer/PullRequest.cpp	198
src/consumer/PullRequest.h	68
src/consumer/PullResult.cpp	22
src/consumer/PullResultExt.h	36
src/consumer/Rebalance.cpp	552
src/consumer/Rebalance.h	75
src/consumer/SubscriptionData.cpp	96
src/consumer/SubscriptionData.h	35
src/dllmain.cpp	15
src/include/BatchMessage.h	12
src/include/DefaultMQClient.h	89
src/include/MQConsumer.h	45
src/include/MQProducer.h	32
src/include/QueryResult.h	19
src/log/Logging.cpp	90
src/log/Logging.h	81
src/message/BatchMessage.cpp	40
src/message/MQDecoder.cpp	163
src/message/MQDecoder.h	30
src/message/MQMessage.cpp	215
src/message/MQMessageExt.cpp	129
src/message/MQMessageId.h	27
src/message/MQMessageQueue.cpp	67
src/producer/DefaultMQProducer.cpp	186
src/producer/DefaultMQProducerImpl.cpp	660
src/producer/DefaultMQProducerImpl.h	93
src/producer/SendMessageHookImpl.cpp	75
src/producer/SendMessageHookImpl.h	15
src/producer/SendResult.cpp	90
src/producer/StringIdMaker.cpp	90
src/producer/StringIdMaker.h	30
src/producer/TopicPublishInfo.h	212
src/producer/TransactionMQProducer.cpp	140
src/producer/TransactionMQProducerImpl.cpp	177
src/producer/TransactionMQProducerImpl.h	51
src/protocol/CommandHeader.cpp	553
src/protocol/CommandHeader.h	432
src/protocol/ConsumerRunningInfo.cpp	88
src/protocol/ConsumerRunningInfo.h	45
src/protocol/HeartbeatData.h	97
src/protocol/KVTable.h	19
src/protocol/LockBatchBody.cpp	103
src/protocol/LockBatchBody.h	53
src/protocol/MQProtos.h	114
src/protocol/MessageQueue.cpp	75
src/protocol/MessageQueue.h	28
src/protocol/ProcessQueueInfo.h	64
src/protocol/RemotingCommand.cpp	255
src/protocol/RemotingCommand.h	72
src/protocol/RemotingSerializable.h	11
src/protocol/TopicList.h	14
src/protocol/TopicRouteData.h	111
src/status/ConsumeStats.cpp	21
src/status/ConsumeStats.h	20
src/status/StatsItem.h	29
src/status/StatsServer.cpp	206
src/status/StatsServer.h	60
src/status/StatsServerManager.cpp	35
src/status/StatsServerManager.h	26
src/thread/disruptor/batch_descriptor.h	19
src/thread/disruptor/claim_strategy.h	75
src/thread/disruptor/event_processor.h	79
src/thread/disruptor/event_publisher.h	18
src/thread/disruptor/exception_handler.h	25
src/thread/disruptor/exceptions.h	8
src/thread/disruptor/interface.h	87
src/thread/disruptor/ring_buffer.h	37
src/thread/disruptor/sequence.h	61
src/thread/disruptor/sequence_barrier.h	52
src/thread/disruptor/sequencer.h	78
src/thread/disruptor/utils.h	6
src/thread/disruptor/wait_strategy.h	270
src/thread/disruptorLFQ.h	75
src/thread/task_queue.cpp	69
src/thread/task_queue.h	670
src/trace/ConsumeMessageContext.cpp	66
src/trace/ConsumeMessageContext.h	47
src/trace/ConsumeMessageHook.h	14
src/trace/SendMessageContext.cpp	74
src/trace/SendMessageContext.h	53
src/trace/SendMessageHook.h	14
src/trace/TraceBean.cpp	80
src/trace/TraceBean.h	47
src/trace/TraceConstant.cpp	12
src/trace/TraceConstant.h	28
src/trace/TraceContext.cpp	72
src/trace/TraceContext.h	46
src/trace/TraceTransferBean.cpp	17
src/trace/TraceTransferBean.h	17
src/trace/TraceUtil.cpp	97
src/trace/TraceUtil.h	14
src/transport/ClientRemotingProcessor.cpp	153
src/transport/ClientRemotingProcessor.h	41
src/transport/EventLoop.cpp	266
src/transport/EventLoop.h	75
src/transport/ResponseFuture.cpp	126
src/transport/ResponseFuture.h	66
src/transport/SocketUtil.cpp	57
src/transport/SocketUtil.h	37
src/transport/TcpRemotingClient.cpp	527
src/transport/TcpRemotingClient.h	88
src/transport/TcpTransport.cpp	230
src/transport/TcpTransport.h	59