voxelcoreprojects/voxelcore
1
0
Fork 0
mirror of https://github.com/MihailRis/voxelcore.git synced 2026-10-10 21:41:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

cleanup

Browse source
This commit is contained in:
MihailRis 2025-09-25 00:16:50 +03:00
parent c65fbd767e
commit e3d1d27311
1 changed files with 1 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/network/Network.cpp
View file

@ -711,13 +711,12 @@ public:
} }
int send(const char* buffer, size_t length) override { int send(const char* buffer, size_t length) override {
logger.info() << "SocketUdpConnection send " << length << " " << getAddress();
int len = ::send(descriptor, buffer, length, 0); int len = ::send(descriptor, buffer, length, 0);
if (len < 0) { if (len < 0) {
auto err = handle_socket_error("udp sendto failed"); auto err = handle_socket_error("udp sendto failed");
closesocket(descriptor); closesocket(descriptor);
state = ConnectionState::CLOSED; state = ConnectionState::CLOSED;
logger.error() << "SocketUdpConnection sendto: " << err.what(); logger.error() << "SocketUdpConnection:send: " << err.what();
} else totalUpload += len; } else totalUpload += len;
return len; return len;
@ -788,11 +787,9 @@ public:
sockaddr_in clientAddr{}; sockaddr_in clientAddr{};
socklen_t addrlen = sizeof(clientAddr); socklen_t addrlen = sizeof(clientAddr);
logger.info() << "udp clients listener started " << open;
while (open) { while (open) {
int size = recvfrom(descriptor, buffer.data(), buffer.size(), 0, int size = recvfrom(descriptor, buffer.data(), buffer.size(), 0,
reinterpret_cast<sockaddr*>(&clientAddr), &addrlen); reinterpret_cast<sockaddr*>(&clientAddr), &addrlen);
logger.info() << "udp clients listener received " << size;
if (size <= 0) { if (size <= 0) {
if (!open) break; if (!open) break;
continue; continue;
@ -803,7 +800,6 @@ public:
callback(id, addrStr, port, buffer.data(), size); callback(id, addrStr, port, buffer.data(), size);
} }
logger.info() << "udp clients listener stopped";
}); });
} }
@ -818,7 +814,6 @@ public:
void close() override { void close() override {
if (!open) return; if (!open) return;
logger.info() << "udp server closed";
open = false; open = false;
shutdown(descriptor, 2); shutdown(descriptor, 2);
closesocket(descriptor); closesocket(descriptor);