diff options
| author | littleblack111 <littleblack11111@gmail.com> | 2025-06-21 21:25:15 +0800 |
|---|---|---|
| committer | littleblack111 <littleblack11111@gmail.com> | 2025-06-22 11:13:20 +0800 |
| commit | 1558e1289295d6bb152495e2dc3b8e138b609789 (patch) | |
| tree | 1c179f58d6628c13d3bd1203449f668fda2ee2b3 /src/server/client.cpp | |
| parent | 2320470d342db4cb5ae0ae717dfc5ac94bd3f2d2 (diff) | |
internal(server/client:read): cleanup m_szReading reset logic
Diffstat (limited to 'src/server/client.cpp')
| -rw-r--r-- | src/server/client.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/server/client.cpp b/src/server/client.cpp index c59100e..fbb451d 100644 --- a/src/server/client.cpp +++ b/src/server/client.cpp @@ -81,19 +81,17 @@ UP<SRecvData> Client::read(std::optional<std::function<bool(const SRecvData &)>> recvData->data.resize(recvData->size); ssize_t size = recv(m_sockfd->get(), &recvData->data[0], recvData->size, 0); + m_szReading.reset(); if (size < 0 || size == 0) { recvData->good = false; - if (cb && !(*cb)(*recvData)) { - m_szReading.reset(); + if (cb && !(*cb)(*recvData)) return nullptr; - } } else { recvData->data.resize(size); recvData->good = true; } - m_szReading.reset(); return recvData; } |
