tqcq/redis-cpp
0
0
Fork 0
Code Issues Pull Requests Projects Releases Activity

fix: supprot PING/PONG

Browse Source
This commit is contained in:
tqcq
2025-09-09 19:43:06 +08:00
parent ae28a458b7
commit 0e1230d011
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/session.cc
View File

@@ -25,10 +25,11 @@ RedisSession::startReceive()
auto self = weak_self.lock(); auto self = weak_self.lock();
if (!self) { return; } if (!self) { return; }
if (!ec) { if (!ec) {
std::string recv(_recv_buf.data(), received);
if (recv == "*1\r\n$4\r\nPING\r\n") {
auto sent = _socket.send(asio::buffer("+PONG\r\n")); auto sent = _socket.send(asio::buffer("+PONG\r\n"));
LOGI("sent to {}:{} 7 bytes", _socket.remote_endpoint().address().to_string(),
_socket.remote_endpoint().port());
OnClose(); OnClose();
}
} else { } else {
startReceive(); startReceive();
} }