BeamMP/BeamMP-Server
1
0
Fork 0
mirror of https://github.com/BeamMP/BeamMP-Server.git synced 2025-07-03 00:05:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix binding of udp server socket

Browse Source 
it was not binding properly because it wasn't open()ed, i guess
This commit is contained in:
Lion Kortlepel 2022-10-05 13:06:36 +02:00
parent 6e97a3cd6e
commit 7446526a19
No known key found for this signature in database
GPG Key ID: 4322FF2B4C71259B
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/TNetwork.cpp
View File

@ -5,6 +5,7 @@
#include <CustomAssert.h>
#include <Http.h>
#include <array>
#include <boost/asio/ip/address.hpp>
#include <boost/asio/ip/address_v4.hpp>
#include <boost/system/detail/error_code.hpp>
#include <cstring>
@ -46,12 +47,17 @@ TNetwork::TNetwork(TServer& Server, TPPSMonitor& PPSMonitor, TResourceManager& R
void TNetwork::UDPServerMain() {
RegisterThread("UDPServer");
mUDPSock = ip::udp::socket(mIoCtx);
ip::udp::endpoint UdpListenEndpoint(ip::udp::v4(), Application::Settings.Port);
ip::udp::endpoint UdpListenEndpoint(ip::address::from_string("0.0.0.0"), Application::Settings.Port);
boost::system::error_code ec;
mUDPSock.open(UdpListenEndpoint.protocol(), ec);
if (ec) {
beammp_error("open() failed: " + ec.what());
std::this_thread::sleep_for(std::chrono::seconds(5));
Application::GracefullyShutdown();
}
mUDPSock.bind(UdpListenEndpoint, ec);
if (ec) {
beammp_error("bind() failed: " + GetPlatformAgnosticErrorString());
beammp_error("bind() failed: " + ec.what());
std::this_thread::sleep_for(std::chrono::seconds(5));
Application::GracefullyShutdown();
}
@ -1011,7 +1017,9 @@ bool TNetwork::UDPSend(TClient& Client, std::string Data) {
std::string TNetwork::UDPRcvFromClient(ip::udp::endpoint& ClientEndpoint) {
std::array<char, 1024> Ret {};
boost::system::error_code ec;
beammp_debugf("receiving data from {}:{}", ClientEndpoint.address().to_string(), ClientEndpoint.port());
const auto Rcv = mUDPSock.receive_from(mutable_buffer(Ret.data(), Ret.size()), ClientEndpoint, 0, ec);
beammp_debugf("received {} bytes from {}:{}", Rcv, ClientEndpoint.address().to_string(), ClientEndpoint.port());
if (ec) {
beammp_errorf("UDP recvfrom() failed: {}", ec.what());
return "";