Overhauls Resolver Message class structure

This commit is contained in:
Sven Luethi committed 2021-04-18 23:30:15 +02:00
1 parent 4089e7a3cc
commit 95c9fbd176
4 files changed
+62 -39

No files matched your search

+6 -6
View File
@@ -12,7 +12,6 @@
#include <unistd.h>
//Testing:
#include <iostream>
#include <fstream>
#include <iomanip>
@@ -30,7 +29,7 @@ Server::Server(Logger& logger, EventBus& eventBus)
_logger.debug.ln ("Starting Resolver...");
_logger.warn << "Testing some stuff..." << Logger::commit;
_logger.warn << "Message header overall size: " << sizeof(Message::Header) << Logger::commit;
_logger.warn << "Message::Header class overall size: " << sizeof(Message::Header) << Logger::commit;
//_logger.debug << "Message::QR:RESPONSE Enum:" << Message::QR::RESPONSE << endl;
/*
@@ -99,7 +98,7 @@ void Server::run() {
clientAddressLength = sizeof(clientAddress);
// Create receive buffer
char buffer[65508] = { 0 }; // (2**16 = 65,536 − 8 byte UDP header − 20 byte IP header)
unsigned char buffer[65508] = { 0 }; // (2**16 = 65,536 − 8 byte UDP header − 20 byte IP header)
// Create new UDP Socket
if ((udpServerSocket = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
@@ -114,18 +113,19 @@ void Server::run() {
while(!_stop) {
udpReadStatus = recvfrom(udpServerSocket, buffer, sizeof(buffer), 0, (struct sockaddr*)&clientAddress, &clientAddressLength);
if (udpServerSocket < 0) {
if (udpServerSocket < 0) {
close(udpServerSocket);
_logger.warn.ln("reading error...");
}
//std::cout.write(buffer, udpReadStatus);
//std::cout << "size: " << udpReadStatus << std::endl;
/*
for(int i=0; i<udpReadStatus; ++i) {
//std::cout << std::hex << (char)buffer[i];
std::cout << std::setw(2) << static_cast<unsigned>(buffer[i]) << " ";
}
std::cout << std::endl << std::endl;
*/
Message* message = (Message*) &buffer;
if ( sendto(udpServerSocket, msg, strlen(msg), 0, (struct sockaddr*)&clientAddress, clientAddressLength) < 0 ) {
close(udpServerSocket);