[kvrocks] branch unstable updated: Use StatusOr in util::GetPeerAddr (#1688)

[twice]

This is an automated email from the ASF dual-hosted git repository.

twice pushed a commit to branch unstable
in repository https://gitbox.apache.org/repos/asf/kvrocks.git


The following commit(s) were added to refs/heads/unstable by this push:
     new f9f93fbb Use StatusOr in util::GetPeerAddr (#1688)
f9f93fbb is described below

commit f9f93fbbd8684d0d111c0624d41301c2ff669e30
Author: Twice <twice.m...@gmail.com>
AuthorDate: Tue Aug 22 11:22:57 2023 +0800

    Use StatusOr in util::GetPeerAddr (#1688)
---
 src/common/io_util.cc | 17 +++++++----------
 src/common/io_util.h  |  2 +-
 src/server/worker.cc  |  5 ++---
 3 files changed, 10 insertions(+), 14 deletions(-)

diff --git a/src/common/io_util.cc b/src/common/io_util.cc
index cb30a480..b4779f86 100644
--- a/src/common/io_util.cc
+++ b/src/common/io_util.cc
@@ -272,29 +272,26 @@ StatusOr<std::string> SockReadLine(int fd) {
   return std::string(line.get(), line.length);
 }
 
-int GetPeerAddr(int fd, std::string *addr, uint32_t *port) {
-  addr->clear();
-
+StatusOr<std::tuple<std::string, uint32_t>> GetPeerAddr(int fd) {
   sockaddr_storage sa{};
   socklen_t sa_len = sizeof(sa);
   if (getpeername(fd, reinterpret_cast<sockaddr *>(&sa), &sa_len) < 0) {
-    return -1;
+    return Status::FromErrno("Failed to get peer name");
   }
 
   if (sa.ss_family == AF_INET6) {
     char buf[INET6_ADDRSTRLEN];
     auto sa6 = reinterpret_cast<sockaddr_in6 *>(&sa);
     inet_ntop(AF_INET6, reinterpret_cast<void *>(&sa6->sin6_addr), buf, 
INET_ADDRSTRLEN);
-    addr->append(buf);
-    *port = ntohs(sa6->sin6_port);
-  } else {
+    return {buf, ntohs(sa6->sin6_port)};
+  } else if (sa.ss_family == AF_INET) {
     auto sa4 = reinterpret_cast<sockaddr_in *>(&sa);
     char buf[INET_ADDRSTRLEN];
     inet_ntop(AF_INET, reinterpret_cast<void *>(&sa4->sin_addr), buf, 
INET_ADDRSTRLEN);
-    addr->append(buf);
-    *port = ntohs(sa4->sin_port);
+    return {buf, ntohs(sa4->sin_port)};
   }
-  return 0;
+
+  return {Status::NotOK, "Failed to get peer name due to invalid family type"};
 }
 
 int GetLocalPort(int fd) {
diff --git a/src/common/io_util.h b/src/common/io_util.h
index 8391d2cc..9ab288ae 100644
--- a/src/common/io_util.h
+++ b/src/common/io_util.h
@@ -35,7 +35,7 @@ Status SockSend(int fd, const std::string &data);
 StatusOr<std::string> SockReadLine(int fd);
 Status SockSendFile(int out_fd, int in_fd, size_t size);
 Status SockSetBlocking(int fd, int blocking);
-int GetPeerAddr(int fd, std::string *addr, uint32_t *port);
+StatusOr<std::tuple<std::string, uint32_t>> GetPeerAddr(int fd);
 int GetLocalPort(int fd);
 bool IsPortInUse(uint32_t port);
 
diff --git a/src/server/worker.cc b/src/server/worker.cc
index 788229cf..22ae28d2 100644
--- a/src/server/worker.cc
+++ b/src/server/worker.cc
@@ -176,9 +176,8 @@ void Worker::newTCPConnection(evconnlistener *listener, 
evutil_socket_t fd, sock
     return;
   }
 
-  std::string ip;
-  uint32_t port = 0;
-  if (util::GetPeerAddr(fd, &ip, &port) == 0) {
+  if (auto s = util::GetPeerAddr(fd)) {
+    auto [ip, port] = std::move(*s);
     conn->SetAddr(ip, port);
   }