This is an automated email from the ASF dual-hosted git repository.
jamesge pushed a change to branch rdma
in repository https://gitbox.apache.org/repos/asf/incubator-brpc.git.
from e09b620 Merge pull request #829 from tanguofu/patch-1
new 61020d6 Add support of RDMA
new d72188a fix some problems according to review comments
new bda4bc1 fix a fatal bug when using IOBUF_HUGE_BLOCK
new b0fae66 display completion error status
new 63de928 allow connect to multiple servers
new e74c061 fix some problems according to previous comments
new b5dc858 CMakeFile conflict fixed
new 575c76e fix some problems according to previous comments
new caec41b fix a bug when memory pool is used up
new 31f4db9 fix the build problem when use glog
new 6647007 fix some problems
new 2d3e0a8 diable local RDMA connection
new 0d63160 improve performance when using huge block for iobuf
new dbb7f62 fix some minor problems
new aa78e41 fix a bug may result in CQE error of RDMA
new 38b5b76 Merge with updates from baidu-internal and brpc/brpc
new 5702392 reduce cpu overhead when using rdma
new b33f712 fix rdma fallback channel
new 34ee969 fix a few bugs when using rdma
new 5bf565a fix problem of rdma_performance
new 0e11f7f modify the example/rdma_performance
new a2b42f4 support aarch64
new a4e8b8b merge with upstream
new fe183d7 improve rdma performance for small message
new ad00fe9 Merge pull request #369 from Tuvie/master
The 1823 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:
CMakeLists.txt | 23 +-
Makefile | 2 +-
.../CMakeLists.txt | 25 +-
example/rdma_performance/README.md | 59 +
example/rdma_performance/client.cpp | 303 ++++
example/rdma_performance/server.cpp | 98 ++
example/rdma_performance/test.proto | 16 +
src/CMakeLists.txt | 5 +
src/brpc/acceptor.cpp | 88 +-
src/brpc/acceptor.h | 34 +-
src/brpc/builtin/connections_service.cpp | 9 +-
src/brpc/channel.cpp | 41 +-
src/brpc/channel.h | 6 +
src/brpc/controller.cpp | 5 +
src/brpc/controller.h | 6 +
src/brpc/details/naming_service_thread.cpp | 3 +-
src/brpc/details/naming_service_thread.h | 1 +
src/brpc/errno.proto | 7 +
src/brpc/input_messenger.cpp | 229 +--
src/brpc/input_messenger.h | 31 +
src/brpc/rdma/README.md | 13 +
src/brpc/rdma/block_pool.cpp | 481 ++++++
src/brpc/rdma/block_pool.h | 95 ++
src/brpc/rdma/rdma_communication_manager.cpp | 379 +++++
src/brpc/rdma/rdma_communication_manager.h | 140 ++
src/brpc/rdma/rdma_completion_queue.cpp | 731 +++++++++
src/brpc/rdma/rdma_completion_queue.h | 204 +++
src/brpc/rdma/rdma_endpoint.cpp | 1229 ++++++++++++++
src/brpc/rdma/rdma_endpoint.h | 236 +++
src/brpc/rdma/rdma_fallback_channel.cpp | 314 ++++
src/brpc/rdma/rdma_fallback_channel.h | 107 ++
src/brpc/rdma/rdma_helper.cpp | 736 +++++++++
src/brpc/rdma/rdma_helper.h | 69 +
src/brpc/rdma/rdma_traffic_control.cpp | 48 +
src/brpc/rdma/rdma_traffic_control.h | 50 +
src/brpc/rdma_health.proto | 11 +
src/brpc/rdma_traffic_control.proto | 15 +
src/brpc/server.cpp | 71 +-
src/brpc/server.h | 4 +
src/brpc/socket.cpp | 205 ++-
src/brpc/socket.h | 24 +
src/brpc/socket_inl.h | 1 +
src/brpc/socket_map.cpp | 10 +-
src/brpc/socket_map.h | 32 +-
src/bthread/context.cpp | 88 +
src/bthread/context.h | 3 +
src/bthread/execution_queue_inl.h | 6 +
src/bthread/processor.h | 4 +
src/butil/containers/case_ignored_flat_map.cpp | 4 +-
src/butil/containers/case_ignored_flat_map.h | 2 +-
src/butil/fast_rand.h | 2 +-
src/butil/iobuf.cpp | 23 +-
src/butil/iobuf.h | 6 +-
src/butil/third_party/snappy/snappy-internal.h | 2 +-
.../third_party/snappy/snappy-stubs-internal.h | 2 +-
src/butil/time.h | 6 +
test/CMakeLists.txt | 5 +
test/brpc_block_pool_unittest.cpp | 189 +++
test/brpc_rdma_unittest.cpp | 1697 ++++++++++++++++++++
test/bthread_work_stealing_queue_unittest.cpp | 3 +-
test/iobuf_unittest.cpp | 23 +-
test/rand_util_unittest.cc | 20 +
tools/CMakeLists.txt | 3 +
tools/rdma_traffic_control/CMakeLists.txt | 2 +
tools/rdma_traffic_control/traffic_control.cpp | 87 +
65 files changed, 8194 insertions(+), 179 deletions(-)
copy example/{auto_concurrency_limiter => rdma_performance}/CMakeLists.txt
(85%)
create mode 100644 example/rdma_performance/README.md
create mode 100644 example/rdma_performance/client.cpp
create mode 100644 example/rdma_performance/server.cpp
create mode 100644 example/rdma_performance/test.proto
create mode 100644 src/brpc/rdma/README.md
create mode 100644 src/brpc/rdma/block_pool.cpp
create mode 100644 src/brpc/rdma/block_pool.h
create mode 100644 src/brpc/rdma/rdma_communication_manager.cpp
create mode 100644 src/brpc/rdma/rdma_communication_manager.h
create mode 100644 src/brpc/rdma/rdma_completion_queue.cpp
create mode 100644 src/brpc/rdma/rdma_completion_queue.h
create mode 100755 src/brpc/rdma/rdma_endpoint.cpp
create mode 100755 src/brpc/rdma/rdma_endpoint.h
create mode 100644 src/brpc/rdma/rdma_fallback_channel.cpp
create mode 100644 src/brpc/rdma/rdma_fallback_channel.h
create mode 100644 src/brpc/rdma/rdma_helper.cpp
create mode 100644 src/brpc/rdma/rdma_helper.h
create mode 100644 src/brpc/rdma/rdma_traffic_control.cpp
create mode 100644 src/brpc/rdma/rdma_traffic_control.h
create mode 100644 src/brpc/rdma_health.proto
create mode 100644 src/brpc/rdma_traffic_control.proto
create mode 100644 test/brpc_block_pool_unittest.cpp
create mode 100644 test/brpc_rdma_unittest.cpp
create mode 100644 tools/rdma_traffic_control/CMakeLists.txt
create mode 100644 tools/rdma_traffic_control/traffic_control.cpp
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
