weaselab/weaseldb
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

We still want to "write" empty messages

Browse Source 
So that the size of the messages queue can go to zero
This commit is contained in:
Andrew Noyes
2025-08-19 16:04:44 -04:00
parent b843e1d5a2
commit b017c6b209
1 changed files with 5 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/connection.cpp
View File

@@ -69,17 +69,13 @@ bool Connection::writeBytes() {
for (auto it = messages_.begin(); for (auto it = messages_.begin();
it != messages_.end() && iov_count < IOV_MAX; ++it) { it != messages_.end() && iov_count < IOV_MAX; ++it) {
const auto &msg = *it; const auto &msg = *it;
if (msg.size() > 0) { iov[iov_count] = {
iov[iov_count] = { const_cast<void *>(static_cast<const void *>(msg.data())),
const_cast<void *>(static_cast<const void *>(msg.data())), msg.size()};
msg.size()}; iov_count++;
iov_count++;
}
} }
if (iov_count == 0) { assert(iov_count > 0);
break;
}
ssize_t w; ssize_t w;
for (;;) { for (;;) {