sven
/
libicsneo
mirror of https://github.com/intrepidcs/libicsneo.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Servd: Adjust buffer sizes

master
Kyle Schwarz 2026-03-18 18:21:55 -04:00
parent 5a4a1489a8
commit 22d2b7c984
2 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
include/icsneo/platform/socket.h
View File

@ -103,6 +103,14 @@ public:
#endif
}
bool set_rcvbuf(uint32_t size) {
return ::setsockopt(mFD, SOL_SOCKET, SO_RCVBUF, (char*)&size, sizeof(size)) == 0;
}
bool set_sndbuf(uint32_t size) {
return ::setsockopt(mFD, SOL_SOCKET, SO_SNDBUF, (char*)&size, sizeof(size)) == 0;
}
bool connect(const Address& to) {
return ::connect(mFD, (sockaddr*)&to.sockaddr(), sizeof(sockaddr_in)) != -1;
}
@ -203,13 +211,6 @@ public:
return true;
}
bool join_multicast(const std::string& interfaceIP, const std::string& multicastIP) {
ip_mreq mreq;
inet_pton(AF_INET, interfaceIP.c_str(), &mreq.imr_interface);
inet_pton(AF_INET, multicastIP.c_str(), &mreq.imr_multiaddr);
return setsockopt(mFD, IPPROTO_IP, IP_ADD_MEMBERSHIP, (const char*)&mreq, sizeof(mreq)) == 0;
}
operator bool() const { return mFD != -1; }
operator SocketHandleType() const { return mFD; }
private:

8
platform/servd.cpp
View File

@ -116,6 +116,14 @@ bool Servd::open() {
return false;
}
dataSocket = std::make_unique<Socket>(AF_INET, SOCK_STREAM, 0);
if(!dataSocket->set_rcvbuf(4 * 1024 * 1024)) {
EventManager::GetInstance().add(APIEvent::Type::SyscallError, APIEvent::Severity::Error);
return false;
}
if(!dataSocket->set_sndbuf(4 * 1024 * 1024)) {
EventManager::GetInstance().add(APIEvent::Type::SyscallError, APIEvent::Severity::Error);
return false;
}
const auto& ip = tokens[0];
uint16_t port = 0;
try {