This is an automated email from the ASF dual-hosted git repository.
gxcheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git.
from 2348b77 [TUBEMQ-345]Optimize the call logic of getMessage() in Pull
mode (#261)
new cf0ccc0 [TUBEMQ-250] Create C/C++ configure files (#170)
new 6b112f6 [TUBEMQ-250] Create C/C++ configure files
new 72b3f55 [TUBEMQ-250] Create C/C++ configure files
new 94899dd [TUBEMQ-250] Create C/C++ configure files
new cef2ff6 [TUBEMQ-250] Create C/C++ configure files
new 5c216c9 adjust code style
new f077e02 [TUBEMQ-251] Create C/C++ Codec utils
new 12f8412 [TUBEMQ-262]Create C++ flow control handler
new 3cf5c56 [TUBEMQ-262]Create C++ flow control handler
new d1e8b3c [TUBEMQ-262]Create C++ flow control handler
new d52d146 [TUBEMQ-262]Create C++ flow control handler
new d171c37 [TUBEMQ-262]Create C++ flow control handler
new 86b88f3 [TUBEMQ-267]Create C/C++ Message class (#182)
new 28d5ec3 [TUBEMQ-266] Add Tencent/rapidjson as submodule
new eee2db0 [TUBEMQ-263] Create C/C++ ini file read utils (#184)
new ebf8d48 [TUBEMQ-263] Create C/C++ ini file read utils [addendum]
(#185)
new 318c8cc [TUBEMQ-252] Create C/C++ Metadata classes (#186)
new 7880069 [TUBEMQ-252] Create C/C++ Metadata classes (#187)
new e9ce604 [TUBEMQ-268] C++ SDK log module (#190)
new 881e4be [TUBEMQ-251] Create C/C++ Codec utils (#191)
new e6df8da [TUBEMQ-262] Create C++ flow control handler (#192)
new 87ab59a [TUBEMQ-272]Unified C/C++ files's code style (#193)
new f4356b3 [TUBEMQ-272]Unified C/C++ files's code style (#194)
new d7cebd5 [TUBEMQ-269] Create C/C++ RmtDataCache class (#195)
new 38844d0 [TUBEMQ-272]Unified C/C++ files's code style (#196)
new 82e02a8 [TUBEMQ-274]Support CMake compilation (#197)
new 6a42851 [TUBEMQ-269] Create C/C++ RmtDataCache class (#198)
new 3be5ddc [TUBEMQ-269]Create C/C++ RmtDataCache class (#199)
new 37055d1 [TUBEMQ-269]Create C/C++ RmtDataCache class (#202)
new 325073c [TUBEMQ-269]Create C/C++ RmtDataCache class (#204)
new 30e6fcf [TUBEMQ-275]Thread Pool & Timer (#205)
new f88d38a [TUBEMQ-280]Create C/C++ subscribe info class (#206)
new 48649c7 [TUBEMQ-282]Create C/C++ return result class (#207)
new cd4b647 [TUBEMQ-283]Adjust C/C++ some file names: add "tubemq_"
prefix (#208)
new 2016990 [TUBEMQ-285]Replace C/C++ pthread's mutex to std::mutex (#210)
new a9a6e07 [TUBEMQ-286]Create C/C++ SDK's manager class (#211)
new 1fb720f [TUBEMQ-286]Create C/C++ SDK's manager class (#212)
new 2922467 [TUBEMQ-286]Create C/C++ SDK's manager class (#213)
new d43d8e9 [TUBEMQ-281]atomic_def.h use C++11 stdlib class (#216)
new 2d6b66b [TUBEMQ-292]C++ SDK singleton & executor_pool optimization
(#217)
new ad04f00 [TUBEMQ-290]C++ SDK TCP Connect (#252)
new 9929b10 TUBEMQ-287 add io buffer (#253)
new 09d2c9b [TUBEMQ-288]C++ SDK Codec interface (#254)
new de6fb61 [TUBEMQ-289]C++ SDK Codec TubeMQ proto support (#255)
new 8d20dc3 [TUBEMQ-293]C++ SDK Create Future class (#257)
new 99c9630 [TUBEMQ-347]C++ SDK Create client API (#258)
new 8ff63dd [TUBEMQ-349]C++ SDK Create Thread Pool (#259)
new de4960d [TUBEMQ-348]C++SDK Client handler detail (#260)
new 1cc56e5 [TUBEMQ-350]C++ SDK client code adj (#262)
new cd5ba19 [TUBEMQ-351]C++ SDK example&tests (#263)
The 50 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitignore | 1 +
.gitmodules | 4 +
pom.xml | 2 +
.../tubemq-client-cpp/.clang-format | 25 +-
.../tubemq-client-cpp/CMakeLists.txt | 42 +-
tubemq-client-twins/tubemq-client-cpp/README.md | 37 +
.../tubemq-client-cpp/build_linux.sh | 20 +-
.../tubemq-client-cpp/example/CMakeLists.txt | 27 +-
.../tubemq-client-cpp/example/README.md | 22 +
.../example/consumer/CMakeLists.txt | 16 +-
.../example/consumer/test_consumer.cc | 137 ++
.../example/consumer/test_multithread_pull.cc | 166 ++
.../include/tubemq/tubemq_atomic.h | 96 ++
.../include/tubemq/tubemq_client.h | 59 +
.../include/tubemq/tubemq_config.h | 158 ++
.../include/tubemq/tubemq_errcode.h | 117 ++
.../include/tubemq/tubemq_message.h | 75 +
.../include/tubemq/tubemq_return.h | 113 ++
.../tubemq-client-cpp}/proto/BrokerService.proto | 6 -
.../tubemq-client-cpp/proto/CMakeLists.txt | 20 +-
.../tubemq-client-cpp/proto/MasterService.proto | 192 +++
.../tubemq-client-cpp}/proto/RPC.proto | 0
.../tubemq-client-cpp/proto/readme.md | 43 +-
.../tubemq-client-cpp/src/CMakeLists.txt | 23 +-
tubemq-client-twins/tubemq-client-cpp/src/any.h | 160 ++
.../tubemq-client-cpp/src/baseconsumer.cc | 1613 ++++++++++++++++++++
.../tubemq-client-cpp/src/baseconsumer.h | 146 ++
tubemq-client-twins/tubemq-client-cpp/src/buffer.h | 356 +++++
.../tubemq-client-cpp/src/client_connection.cc | 303 ++++
.../tubemq-client-cpp/src/client_connection.h | 101 ++
.../tubemq-client-cpp/src/client_service.cc | 296 ++++
.../tubemq-client-cpp/src/client_service.h | 121 ++
.../tubemq-client-cpp/src/client_subinfo.cc | 133 ++
.../tubemq-client-cpp/src/client_subinfo.h | 79 +
.../tubemq-client-cpp/src/codec_protocol.h | 58 +
.../tubemq-client-cpp/src/connection.cc | 25 +
.../tubemq-client-cpp/src/connection.h | 120 ++
.../tubemq-client-cpp/src/connection_pool.h | 131 ++
.../tubemq-client-cpp/src/const_config.h | 120 ++
.../tubemq-client-cpp/src/const_rpc.h | 91 ++
.../tubemq-client-cpp/src/executor_pool.cc | 88 ++
.../tubemq-client-cpp/src/executor_pool.h | 95 ++
.../tubemq-client-cpp/src/file_ini.cc | 154 ++
.../tubemq-client-cpp/src/file_ini.h | 51 +
.../tubemq-client-cpp/src/flowctrl_def.cc | 785 ++++++++++
.../tubemq-client-cpp/src/flowctrl_def.h | 144 ++
tubemq-client-twins/tubemq-client-cpp/src/future.h | 143 ++
.../tubemq-client-cpp/src/logger.cc | 80 +
tubemq-client-twins/tubemq-client-cpp/src/logger.h | 118 ++
.../tubemq-client-cpp/src/meta_info.cc | 580 +++++++
.../tubemq-client-cpp/src/meta_info.h | 188 +++
.../tubemq-client-cpp/src/noncopyable.h | 37 +
.../tubemq-client-cpp/src/rmt_data_cache.cc | 669 ++++++++
.../tubemq-client-cpp/src/rmt_data_cache.h | 166 ++
.../tubemq-client-cpp/src/singleton.h | 62 +
.../tubemq-client-cpp/src/thread_pool.h | 69 +
.../tubemq-client-cpp/src/transport.h | 60 +
.../tubemq-client-cpp/src/tubemq_client.cc | 184 +++
.../tubemq-client-cpp/src/tubemq_codec.h | 312 ++++
.../tubemq-client-cpp/src/tubemq_config.cc | 612 ++++++++
.../tubemq-client-cpp/src/tubemq_message.cc | 224 +++
.../tubemq-client-cpp/src/tubemq_return.cc | 180 +++
.../tubemq-client-cpp/src/tubemq_transport.h | 58 +
.../tubemq-client-cpp/src/unique_seq_id.h | 41 +
tubemq-client-twins/tubemq-client-cpp/src/utils.cc | 559 +++++++
tubemq-client-twins/tubemq-client-cpp/src/utils.h | 71 +
.../tubemq-client-cpp/src/version.h | 33 +
.../tubemq-client-cpp/tests/CMakeLists.txt | 28 +-
.../tubemq-client-cpp/tests/README.md | 22 +
.../tests/executor_pool/CMakeLists.txt | 15 +-
.../tubemq-client-cpp/tests/executor_pool/main.cc | 58 +
.../tubemq-client-cpp/tests/log/CMakeLists.txt | 15 +-
.../tubemq-client-cpp/tests/log/main.cc | 62 +
.../tests/thread_pool/CMakeLists.txt | 15 +-
.../tubemq-client-cpp/tests/thread_pool/main.cc | 36 +
.../tubemq-client-cpp/third_party/CMakeLists.txt | 45 +
.../tubemq-client-cpp/third_party/README.md | 23 +
77 files changed, 11148 insertions(+), 188 deletions(-)
create mode 100644 .gitmodules
copy tubemq-docker/tubemq-k8s/templates/_master.tpl =>
tubemq-client-twins/tubemq-client-cpp/.clang-format (69%)
copy tubemq-docker/tubemq-k8s/templates/_master.tpl =>
tubemq-client-twins/tubemq-client-cpp/CMakeLists.txt (54%)
create mode 100644 tubemq-client-twins/tubemq-client-cpp/README.md
copy tubemq-docker/tubemq-k8s/templates/_broker.tpl =>
tubemq-client-twins/tubemq-client-cpp/build_linux.sh (69%)
mode change 100644 => 100755
copy tubemq-docker/tubemq-k8s/templates/_master.tpl =>
tubemq-client-twins/tubemq-client-cpp/example/CMakeLists.txt (60%)
create mode 100644 tubemq-client-twins/tubemq-client-cpp/example/README.md
copy tubemq-docker/tubemq-k8s/templates/_broker.tpl =>
tubemq-client-twins/tubemq-client-cpp/example/consumer/CMakeLists.txt (69%)
create mode 100644
tubemq-client-twins/tubemq-client-cpp/example/consumer/test_consumer.cc
create mode 100644
tubemq-client-twins/tubemq-client-cpp/example/consumer/test_multithread_pull.cc
create mode 100644
tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_atomic.h
create mode 100644
tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_client.h
create mode 100644
tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_config.h
create mode 100644
tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_errcode.h
create mode 100644
tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_message.h
create mode 100644
tubemq-client-twins/tubemq-client-cpp/include/tubemq/tubemq_return.h
copy {tubemq-core/src/main =>
tubemq-client-twins/tubemq-client-cpp}/proto/BrokerService.proto (95%)
copy tubemq-docker/tubemq-k8s/templates/_broker.tpl =>
tubemq-client-twins/tubemq-client-cpp/proto/CMakeLists.txt (69%)
create mode 100644
tubemq-client-twins/tubemq-client-cpp/proto/MasterService.proto
copy {tubemq-core/src/main =>
tubemq-client-twins/tubemq-client-cpp}/proto/RPC.proto (100%)
copy tubemq-core/src/main/java/org/apache/tubemq/corebase/Shutdownable.java =>
tubemq-client-twins/tubemq-client-cpp/proto/readme.md (72%)
copy tubemq-docker/tubemq-k8s/templates/_broker.tpl =>
tubemq-client-twins/tubemq-client-cpp/src/CMakeLists.txt (69%)
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/any.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/baseconsumer.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/baseconsumer.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/buffer.h
create mode 100644
tubemq-client-twins/tubemq-client-cpp/src/client_connection.cc
create mode 100644
tubemq-client-twins/tubemq-client-cpp/src/client_connection.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/client_service.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/client_service.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/client_subinfo.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/client_subinfo.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/codec_protocol.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/connection.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/connection.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/connection_pool.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/const_config.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/const_rpc.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/executor_pool.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/executor_pool.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/file_ini.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/file_ini.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/flowctrl_def.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/flowctrl_def.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/future.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/logger.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/logger.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/meta_info.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/meta_info.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/noncopyable.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/rmt_data_cache.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/rmt_data_cache.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/singleton.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/thread_pool.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/transport.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/tubemq_client.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/tubemq_codec.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/tubemq_message.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/tubemq_return.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/tubemq_transport.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/unique_seq_id.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/utils.cc
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/utils.h
create mode 100644 tubemq-client-twins/tubemq-client-cpp/src/version.h
copy tubemq-docker/tubemq-k8s/templates/_master.tpl =>
tubemq-client-twins/tubemq-client-cpp/tests/CMakeLists.txt (57%)
create mode 100644 tubemq-client-twins/tubemq-client-cpp/tests/README.md
copy tubemq-docker/tubemq-k8s/templates/_broker.tpl =>
tubemq-client-twins/tubemq-client-cpp/tests/executor_pool/CMakeLists.txt (69%)
create mode 100644
tubemq-client-twins/tubemq-client-cpp/tests/executor_pool/main.cc
copy tubemq-docker/tubemq-k8s/templates/_broker.tpl =>
tubemq-client-twins/tubemq-client-cpp/tests/log/CMakeLists.txt (69%)
create mode 100644 tubemq-client-twins/tubemq-client-cpp/tests/log/main.cc
copy tubemq-docker/tubemq-k8s/templates/_broker.tpl =>
tubemq-client-twins/tubemq-client-cpp/tests/thread_pool/CMakeLists.txt (69%)
create mode 100644
tubemq-client-twins/tubemq-client-cpp/tests/thread_pool/main.cc
create mode 100644
tubemq-client-twins/tubemq-client-cpp/third_party/CMakeLists.txt
create mode 100644 tubemq-client-twins/tubemq-client-cpp/third_party/README.md
