Path	Lines of Code
cpp/bazel/rocketmq_deps.bzl	164
cpp/cmake/FindProtobufWithTargets.cmake	174
cpp/cmake/FindgRPC.cmake	315
cpp/cmake/OpenCensusHelpers.cmake	85
cpp/include/rocketmq/AdminServer.h	17
cpp/include/rocketmq/BackoffPolicy.h	42
cpp/include/rocketmq/Configuration.h	48
cpp/include/rocketmq/ConfigurationDefaults.h	9
cpp/include/rocketmq/ConsumeResult.h	9
cpp/include/rocketmq/Credentials.h	51
cpp/include/rocketmq/CredentialsProvider.h	58
cpp/include/rocketmq/ErrorCategory.h	17
cpp/include/rocketmq/ErrorCode.h	61
cpp/include/rocketmq/Executor.h	6
cpp/include/rocketmq/ExpressionType.h	10
cpp/include/rocketmq/FifoProducer.h	35
cpp/include/rocketmq/FilterExpression.h	19
cpp/include/rocketmq/Logger.h	32
cpp/include/rocketmq/MQClientException.h	66
cpp/include/rocketmq/Message.h	113
cpp/include/rocketmq/MessageListener.h	7
cpp/include/rocketmq/Producer.h	41
cpp/include/rocketmq/PushConsumer.h	58
cpp/include/rocketmq/RecallReceipt.h	8
cpp/include/rocketmq/RocketMQ.h	6
cpp/include/rocketmq/SendCallback.h	8
cpp/include/rocketmq/SendReceipt.h	13
cpp/include/rocketmq/SimpleConsumer.h	67
cpp/include/rocketmq/State.h	13
cpp/include/rocketmq/Tracing.h	11
cpp/include/rocketmq/Transaction.h	16
cpp/include/rocketmq/TransactionChecker.h	7
cpp/include/rocketmq/TransactionState.h	9
cpp/proto/apache/rocketmq/v2/admin.proto	37
cpp/proto/apache/rocketmq/v2/definition.proto	462
cpp/proto/apache/rocketmq/v2/service.proto	362
cpp/source/admin/AdminClient.cpp	77
cpp/source/admin/AdminFacade.cpp	6
cpp/source/admin/AdminServerImpl.cpp	86
cpp/source/admin/AdminServiceImpl.cpp	42
cpp/source/admin/include/AdminClient.h	20
cpp/source/admin/include/AdminServerImpl.h	36
cpp/source/admin/include/AdminServiceImpl.h	16
cpp/source/admin/include/ServerCall.h	52
cpp/source/base/Configuration.cpp	29
cpp/source/base/ConfigurationDefaults.cpp	5
cpp/source/base/CredentialsProvider.cpp	88
cpp/source/base/ErrorCategory.cpp	138
cpp/source/base/ErrorCode.cpp	7
cpp/source/base/FilterExpression.cpp	19
cpp/source/base/Message.cpp	61
cpp/source/base/MessageExt.cpp	13
cpp/source/base/MetadataConstants.cpp	29
cpp/source/base/MixAll.cpp	246
cpp/source/base/Protocol.cpp	116
cpp/source/base/ThreadPoolImpl.cpp	76
cpp/source/base/UniqueIdGenerator.cpp	62
cpp/source/base/UtilAll.cpp	157
cpp/source/base/include/InvocationContext.h	66
cpp/source/base/include/MessageExt.h	10
cpp/source/base/include/MetadataConstants.h	24
cpp/source/base/include/MixAll.h	106
cpp/source/base/include/Protocol.h	55
cpp/source/base/include/RetryPolicy.h	50
cpp/source/base/include/SubscriptionEntry.h	12
cpp/source/base/include/ThreadPool.h	12
cpp/source/base/include/ThreadPoolImpl.h	30
cpp/source/base/include/UniqueIdGenerator.h	33
cpp/source/base/include/UtilAll.h	14
cpp/source/client/ClientManagerImpl.cpp	1295
cpp/source/client/LogInterceptor.cpp	70
cpp/source/client/LogInterceptorFactory.cpp	8
cpp/source/client/ReceiveMessageStreamReader.cpp	128
cpp/source/client/RpcClientImpl.cpp	123
cpp/source/client/SessionImpl.cpp	24
cpp/source/client/Signature.cpp	49
cpp/source/client/TelemetryBidiReactor.cpp	294
cpp/source/client/TlsHelper.cpp	19
cpp/source/client/TopicAssignmentInfo.cpp	33
cpp/source/client/include/Client.h	26
cpp/source/client/include/ClientConfig.h	42
cpp/source/client/include/ClientManager.h	62
cpp/source/client/include/ClientManagerImpl.h	124
cpp/source/client/include/ConsumeMessageType.h	10
cpp/source/client/include/InsecureCertificateVerifier.h	15
cpp/source/client/include/InterceptorContinuation.h	21
cpp/source/client/include/LogInterceptor.h	12
cpp/source/client/include/LogInterceptorFactory.h	9
cpp/source/client/include/Metadata.h	6
cpp/source/client/include/OpenSSLCompatible.h	289
cpp/source/client/include/ReceiveMessageCallback.h	7
cpp/source/client/include/ReceiveMessageContext.h	13
cpp/source/client/include/ReceiveMessageResult.h	19
cpp/source/client/include/ReceiveMessageStreamReader.h	38
cpp/source/client/include/RpcClient.h	52
cpp/source/client/include/RpcClientImpl.h	60
cpp/source/client/include/SendMessageContext.h	52
cpp/source/client/include/SendResult.h	12
cpp/source/client/include/SendResultCallback.h	6
cpp/source/client/include/Session.h	10
cpp/source/client/include/SessionImpl.h	19
cpp/source/client/include/Signature.h	9
cpp/source/client/include/TelemetryBidiReactor.h	53
cpp/source/client/include/TlsHelper.h	10
cpp/source/client/include/TopicAssignmentInfo.h	27
cpp/source/client/include/TopicRouteData.h	34
cpp/source/concurrent/CountdownLatch.cpp	32
cpp/source/concurrent/include/CountdownLatch.h	23
cpp/source/log/LoggerImpl.cpp	100
cpp/source/log/include/LoggerImpl.h	67
cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp	95
cpp/source/rocketmq/ClientImpl.cpp	501
cpp/source/rocketmq/ConsumeMessageServiceImpl.cpp	115
cpp/source/rocketmq/ConsumeTask.cpp	174
cpp/source/rocketmq/FifoContext.cpp	11
cpp/source/rocketmq/FifoProducer.cpp	44
cpp/source/rocketmq/FifoProducerImpl.cpp	15
cpp/source/rocketmq/FifoProducerPartition.cpp	73
cpp/source/rocketmq/MessageGroupQueueSelector.cpp	14
cpp/source/rocketmq/NamingScheme.cpp	67
cpp/source/rocketmq/ProcessQueueImpl.cpp	182
cpp/source/rocketmq/Producer.cpp	72
cpp/source/rocketmq/ProducerImpl.cpp	567
cpp/source/rocketmq/PushConsumer.cpp	31
cpp/source/rocketmq/PushConsumerImpl.cpp	533
cpp/source/rocketmq/SendContext.cpp	84
cpp/source/rocketmq/SimpleConsumer.cpp	101
cpp/source/rocketmq/SimpleConsumerImpl.cpp	338
cpp/source/rocketmq/StaticNameServerResolver.cpp	21
cpp/source/rocketmq/TopicPublishInfo.cpp	97
cpp/source/rocketmq/TransactionImpl.cpp	33
cpp/source/rocketmq/include/AsyncReceiveMessageCallback.h	19
cpp/source/rocketmq/include/ClientImpl.h	130
cpp/source/rocketmq/include/ClientResourceBundle.h	17
cpp/source/rocketmq/include/ConsumeMessageService.h	28
cpp/source/rocketmq/include/ConsumeMessageServiceImpl.h	48
cpp/source/rocketmq/include/ConsumeTask.h	38
cpp/source/rocketmq/include/Consumer.h	18
cpp/source/rocketmq/include/FifoContext.h	12
cpp/source/rocketmq/include/FifoProducerImpl.h	29
cpp/source/rocketmq/include/FifoProducerPartition.h	29
cpp/source/rocketmq/include/MessageGroupQueueSelector.h	13
cpp/source/rocketmq/include/NameServerResolver.h	13
cpp/source/rocketmq/include/NamingScheme.h	24
cpp/source/rocketmq/include/ProcessQueue.h	30
cpp/source/rocketmq/include/ProcessQueueImpl.h	65
cpp/source/rocketmq/include/ProducerImpl.h	94
cpp/source/rocketmq/include/PublishInfoCallback.h	7
cpp/source/rocketmq/include/PushConsumerImpl.h	128
cpp/source/rocketmq/include/SendContext.h	38
cpp/source/rocketmq/include/SimpleConsumerImpl.h	53
cpp/source/rocketmq/include/StaticNameServerResolver.h	18
cpp/source/rocketmq/include/TopicPublishInfo.h	29
cpp/source/rocketmq/include/TransactionImpl.h	33
cpp/source/scheduler/SchedulerImpl.cpp	155
cpp/source/scheduler/include/Scheduler.h	20
cpp/source/scheduler/include/SchedulerImpl.h	48
cpp/source/stats/ConsumeStats.cpp	58
cpp/source/stats/MetricBidiReactor.cpp	100
cpp/source/stats/OpencensusExporter.cpp	157
cpp/source/stats/OpencensusHandler.cpp	10
cpp/source/stats/PublishStats.cpp	16
cpp/source/stats/StdoutHandler.cpp	58
cpp/source/stats/Tag.cpp	19
cpp/source/stats/include/ConsumeStats.h	30
cpp/source/stats/include/MetricBidiReactor.h	35
cpp/source/stats/include/OpencensusExporter.h	27
cpp/source/stats/include/OpencensusHandler.h	10
cpp/source/stats/include/PublishStats.h	16
cpp/source/stats/include/StdoutHandler.h	47
cpp/source/stats/include/Tag.h	12
cpp/source/trace/TracingUtility.cpp	61
cpp/source/trace/include/TracingUtility.h	11
cpp/tools/fix_copyright.py	45