mirror/oatpp
2
0
Fork 0
mirror of https://github.com/oatpp/oatpp.git synced 2025-02-23 17:40:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix compiler warnings (-Wduplicated-branches)

Browse Source 
Signed-off-by: Ferry Huberts <ferry.huberts@pelagic.nl>
This commit is contained in:
Ferry Huberts 2023-07-22 21:25:25 +02:00
parent 0b3a66c47c
commit f22b2a2531
1 changed files with 22 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/oatpp/network/tcp/Connection.cpp
View File

@ -120,14 +120,18 @@ v_io_size Connection::write(const void *buff, v_buff_size count, async::Action&
action = oatpp::async::Action::createIOWaitAction(m_handle, oatpp::async::Action::IOEventType::IO_EVENT_WRITE);
}
return IOError::RETRY_WRITE; // For async io. In case socket is non-blocking
} else if(e == EINTR) {
return IOError::RETRY_WRITE;
} else if(e == EPIPE) {
return IOError::BROKEN_PIPE;
} else {
//OATPP_LOGD("Connection", "write errno=%d", e);
return IOError::BROKEN_PIPE; // Consider all other errors as a broken pipe.
}
if(e == EINTR) {
return IOError::RETRY_WRITE;
}
if(e == EPIPE) {
return IOError::BROKEN_PIPE;
}
//OATPP_LOGD("Connection", "write errno=%d", e);
return IOError::BROKEN_PIPE; // Consider all other errors as a broken pipe.
}
return result;
@ -174,14 +178,18 @@ v_io_size Connection::read(void *buff, v_buff_size count, async::Action& action)
action = oatpp::async::Action::createIOWaitAction(m_handle, oatpp::async::Action::IOEventType::IO_EVENT_READ);
}
return IOError::RETRY_READ; // For async io. In case socket is non-blocking
} else if(e == EINTR) {
return IOError::RETRY_READ;
} else if(e == ECONNRESET) {
return IOError::BROKEN_PIPE;
} else {
//OATPP_LOGD("Connection", "write errno=%d", e);
return IOError::BROKEN_PIPE; // Consider all other errors as a broken pipe.
}
if(e == EINTR) {
return IOError::RETRY_READ;
}
if(e == ECONNRESET) {
return IOError::BROKEN_PIPE;
}
//OATPP_LOGD("Connection", "write errno=%d", e);
return IOError::BROKEN_PIPE; // Consider all other errors as a broken pipe.
}
return result;