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

I'm not interested in EPOLLRDHUP

Browse Source
This commit is contained in:
Andrew Noyes
2025-08-21 13:01:42 -04:00
parent 6e9d045b2b
commit 093e618b98
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/server.cpp
View File

@@ -102,9 +102,9 @@ void Server::receiveConnectionBack(Connection *connection) {
struct epoll_event event{};
if (!connection->hasMessages()) {
event.events = EPOLLIN | EPOLLONESHOT | EPOLLRDHUP;
event.events = EPOLLIN | EPOLLONESHOT;
} else {
event.events = EPOLLOUT | EPOLLONESHOT | EPOLLRDHUP;
event.events = EPOLLOUT | EPOLLONESHOT;
}
connection->tsan_release();
@@ -456,9 +456,9 @@ void Server::process_connection_batch(
if (conn) {
struct epoll_event event{};
if (!conn->hasMessages()) {
event.events = EPOLLIN | EPOLLONESHOT | EPOLLRDHUP;
event.events = EPOLLIN | EPOLLONESHOT;
} else {
event.events = EPOLLOUT | EPOLLONESHOT | EPOLLRDHUP;
event.events = EPOLLOUT | EPOLLONESHOT;
}
int fd = conn->getFd();

4
tools/load_tester.cpp
View File

@@ -670,9 +670,9 @@ int main(int argc, char *argv[]) {
// Transfer back to epoll instance. This thread or another thread
// will wake when fd is ready
if (conn->hasMessages()) {
events[i].events = EPOLLOUT | EPOLLONESHOT | EPOLLRDHUP;
events[i].events = EPOLLOUT | EPOLLONESHOT;
} else {
events[i].events = EPOLLIN | EPOLLONESHOT | EPOLLRDHUP;
events[i].events = EPOLLIN | EPOLLONESHOT;
}
conn->tsan_release();
Connection *raw_conn = conn.release();