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: dev-unsubscr...@brpc.apache.org For additional commands, e-mail: dev-h...@brpc.apache.org