ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-12-06 17:27:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove print statements

Browse Source
This commit is contained in:
Richard Holland
2024-11-29 10:05:40 +11:00
parent 531078b539
commit fb18d370ce
1 changed files with 12 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/ripple/app/misc/DatagramMonitor.h
View File

@@ -229,7 +229,6 @@ private:
int sock = socket(endpoint.is_ipv6 ? AF_INET6 : AF_INET, SOCK_DGRAM, 0); int sock = socket(endpoint.is_ipv6 ? AF_INET6 : AF_INET, SOCK_DGRAM, 0);
if (sock < 0) if (sock < 0)
throw std::runtime_error("Failed to create socket"); throw std::runtime_error("Failed to create socket");
std::cout << "DatagramMonitor createSocket = " << sock << "\n";
return sock; return sock;
} }
@@ -261,8 +260,6 @@ private:
addr_len = sizeof(struct sockaddr_in); addr_len = sizeof(struct sockaddr_in);
} }
std::cout << "Datagram monitor sending packet of size " << buffer.size()
<< "\n";
sendto( sendto(
sock, sock,
buffer.data(), buffer.data(),
@@ -346,15 +343,17 @@ private:
// Count only non-zero intervals and calculate total size needed // Count only non-zero intervals and calculate total size needed
size_t validRangeCount = 0; size_t validRangeCount = 0;
for (auto const& interval : rangeSet) { for (auto const& interval : rangeSet)
{
// Skip intervals where both lower and upper are 0 // Skip intervals where both lower and upper are 0
if (interval.lower() != 0 || interval.upper() != 0) { if (interval.lower() != 0 || interval.upper() != 0)
{
validRangeCount++; validRangeCount++;
} }
} }
size_t totalSize = sizeof(ServerInfoHeader) + (validRangeCount * sizeof(LgrRange)); size_t totalSize =
sizeof(ServerInfoHeader) + (validRangeCount * sizeof(LgrRange));
// Allocate buffer and initialize header // Allocate buffer and initialize header
std::vector<uint8_t> buffer(totalSize); std::vector<uint8_t> buffer(totalSize);
@@ -505,11 +504,14 @@ private:
header->ledger_range_count = validRangeCount; header->ledger_range_count = validRangeCount;
// Append only non-zero ranges after the header // Append only non-zero ranges after the header
auto* rangeData = reinterpret_cast<LgrRange*>(buffer.data() + sizeof(ServerInfoHeader)); auto* rangeData = reinterpret_cast<LgrRange*>(
buffer.data() + sizeof(ServerInfoHeader));
size_t i = 0; size_t i = 0;
for (auto const& interval : rangeSet) { for (auto const& interval : rangeSet)
{
// Only pack non-zero ranges // Only pack non-zero ranges
if (interval.lower() != 0 || interval.upper() != 0) { if (interval.lower() != 0 || interval.upper() != 0)
{
rangeData[i].start = interval.lower(); rangeData[i].start = interval.lower();
rangeData[i].end = interval.upper(); rangeData[i].end = interval.upper();
++i; ++i;
@@ -522,8 +524,6 @@ private:
monitorThread() monitorThread()
{ {
auto endpoint = parseEndpoint(app_.config().DATAGRAM_MONITOR); auto endpoint = parseEndpoint(app_.config().DATAGRAM_MONITOR);
std::cout << "Datagram monitor, endpoint: "
<< app_.config().DATAGRAM_MONITOR << "\n";
int sock = createSocket(endpoint); int sock = createSocket(endpoint);
while (running_) while (running_)
@@ -533,7 +533,6 @@ private:
auto info = generateServerInfo(); auto info = generateServerInfo();
sendPacket(sock, endpoint, info); sendPacket(sock, endpoint, info);
std::this_thread::sleep_for(std::chrono::seconds(1)); std::this_thread::sleep_for(std::chrono::seconds(1));
std::cout << "Sending datagram monitor packet\n";
} }
catch (const std::exception& e) catch (const std::exception& e)
{ {