This is an automated email from the ASF dual-hosted git repository.
rexxiong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git
from e244d01af [CELEBORN-1876] Log remote address on RPC exception for
TransportRequestHandler
add 8c04e5e8a [CELEBORN-1871][CIP-14] Add NettyRpcEndpointRef to cppClient
No new revisions were added by this update.
Summary of changes:
cpp/celeborn/network/CMakeLists.txt | 3 +-
cpp/celeborn/network/Message.h | 5 +
cpp/celeborn/network/NettyRpcEndpointRef.cpp | 76 +++++++++++++
cpp/celeborn/network/NettyRpcEndpointRef.h | 61 +++++++++++
cpp/celeborn/network/TransportClient.h | 29 ++---
cpp/celeborn/network/tests/CMakeLists.txt | 3 +-
.../network/tests/NettyRpcEndpointRefTest.cpp | 118 +++++++++++++++++++++
cpp/celeborn/utils/CMakeLists.txt | 1 +
cpp/celeborn/utils/CelebornUtils.cpp | 19 +++-
cpp/celeborn/utils/CelebornUtils.h | 8 ++
10 files changed, 304 insertions(+), 19 deletions(-)
create mode 100644 cpp/celeborn/network/NettyRpcEndpointRef.cpp
create mode 100644 cpp/celeborn/network/NettyRpcEndpointRef.h
create mode 100644 cpp/celeborn/network/tests/NettyRpcEndpointRefTest.cpp
