Fix TLS connection for sendAuth in replication

PragmaTwice · Sep 20, 2023 · ac497ec · ac497ec
1 parent 3092081
commit ac497ec
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/cluster/replication.cc b/src/cluster/replication.cc
@@ -839,8 +839,8 @@ Status ReplicationThread::sendAuth(int sock_fd, ssl_st *ssl) {
     auto s = util::SockSend(sock_fd, auth_command, ssl);
     if (!s.IsOK()) return s.Prefixed("send auth command err");
     while (true) {
-      if (evbuffer_read(evbuf.get(), sock_fd, -1) <= 0) {
-        return Status::FromErrno("read auth response err");
+      if (auto s = util::EvbufferRead(evbuf.get(), sock_fd, -1, ssl); !s) {
+        return std::move(s).Prefixed("read auth response err");
       }
       UniqueEvbufReadln line(evbuf.get(), EVBUFFER_EOL_CRLF_STRICT);
       if (!line) continue;