wip

README.md

@@ -1,6 +1,11 @@
 # DistriNS
 A Distributed approach to Authoritative DNS
 
+## Useful Commands
+```
+inotifywait -m -q -r -e close_write --format %f ../src/ | grep --line-buffered "\.[h,c]pp$" | while IFS= read -r file; do make && src/core/Plains; done
+```
+
 PLAINS - Peering Local Authoratative Integrated Name Server
 
 ## Coding Style

src/api/Server.cpp

@@ -3,7 +3,7 @@
 namespace Plains {
 namespace API {
 
-Server::Server(EventBus& eventBus) : eventBus(eventBus) {
+Server::Server(EventBus& eventBus) : eventBus_(eventBus) {
     //Constructor
 }
 

src/api/include/Server.hpp

@@ -8,7 +8,7 @@ namespace API {
 using Core::EventBus;
 
 class Server {
-    const EventBus& eventBus;
+    const EventBus& eventBus_;
 
     public:
     Server(EventBus& eventBus);

src/core/ConfigManager.cpp

@@ -8,12 +8,12 @@ namespace Core {
 using std::string;
 
 ConfigManager::ConfigManager(Logger& logger, vector<string>& parameters) :
-    logger(logger),
-    parameters(parameters)
+    logger_(logger),
+    parameters_(parameters)
 {
     // move this to a function that can return an error code?
     if ( parameters.size() == 0 ) return;
-    logger.debug.ln("Interpreting Paremters...");
+    logger_.debug.ln("Interpreting Paremters...");
     
     /*
     for (unsigned i = 0; i < (numParameters-1); ++i) {
@@ -21,8 +21,8 @@ ConfigManager::ConfigManager(Logger& logger, vector<string>& parameters) :
         string v = string(parameters[i+1]);
         // Check if this parameter is an argument or an argument value:
         if ( p.compare(0,1,"-") == 0 ) {
-            logger.debug("Interpreting parameter " << p);
-            if ( ! p.compare("--initial-peer") ) logger.debug("Peer " << v << " set");
+            logger_.debug("Interpreting parameter " << p);
+            if ( ! p.compare("--initial-peer") ) logger_.debug("Peer " << v << " set");
         }
     }
     */

src/core/EventBus.cpp

@@ -4,10 +4,10 @@
 namespace Plains {
 namespace Core {
 
-EventBus::EventBus(Logger& logger) : logger(logger) {};
+EventBus::EventBus(Logger& logger) : logger_(logger) {};
 
 void EventBus::test() {
-    logger.debug << "Testing from within EventBus!" << Logger::commit;
+    logger_.debug << "Testing from within EventBus!" << Logger::commit;
 }
 
 

src/core/dns/include/Record.hpp

@@ -14,9 +14,9 @@ using std::string;
 class Record : public Resource
 {
     public:
-    const uint16_t id;
+    const uint16_t id_;
     string serialize();
-    Record(const uint16_t id) : id(id) {}
+    Record(const uint16_t id) : id_(id) {}
 };
 
 class ARecord : public Record { ARecord(); };

src/core/include/ConfigManager.hpp

@@ -16,8 +16,8 @@ class ConfigManager
     ConfigManager(Logger& logger, vector<string>& parameters);
 
     private:
-    Logger& logger;
-    const vector<string>& parameters;
+    Logger& logger_;
+    const vector<string>& parameters_;
 };
 
 }}

src/core/include/EventBus.hpp

@@ -8,7 +8,7 @@ namespace Core {
 
 class EventBus {
     private:
-    Logger& logger;
+    Logger& logger_;
 
     public:
     EventBus(Logger& logger);

src/dhcp/Server.cpp

@@ -3,7 +3,7 @@
 namespace Plains {
 namespace DHCP {
 
-Server::Server(EventBus& eventBus) : eventBus(eventBus) {
+Server::Server(EventBus& eventBus) : eventBus_(eventBus) {
     //Constructor
 }
 

src/dhcp/include/Server.hpp

@@ -8,7 +8,7 @@ namespace DHCP {
 using Core::EventBus;
 
 class Server {
-    const EventBus& eventBus;
+    const EventBus& eventBus_;
 
     public:
     Server(EventBus& eventBus);

src/resolver/Server.cpp

@@ -40,8 +40,8 @@ static char* intToHex(unsigned byteCount, int c) {
 }
 
 Server::Server(Logger& logger, EventBus& eventBus)
-  : logger(logger),
-    eventBus(eventBus)
+  : logger_(logger),
+    eventBus_(eventBus)
 {
     logger.debug << "Testing some stuff..." << Logger::commit;
     logger.debug << "Message header overall size: " << sizeof(Message::Header) << Logger::commit;
@@ -76,7 +76,7 @@ Server::Server(Logger& logger, EventBus& eventBus)
     myfile.close();
     //Testing over
 
-    socket_ = new udp::socket(io_context, udp::endpoint(udp::v4(), 8853));
+    socket_ = new udp::socket(io_context_, udp::endpoint(udp::v4(), 8853));
 }
 
 Server::~Server() {
@@ -84,7 +84,7 @@ Server::~Server() {
 }
 
 void Server::run() {
-    io_context.run();
+    io_context_.run();
     do_receive();
 }
 

src/resolver/include/Server.hpp

@@ -15,12 +15,13 @@ using Core::Logger;
 class Server
 {
     private:
-    EventBus& eventBus;
-    Logger& logger;
-    asio::io_context io_context;
+    EventBus& eventBus_;
+    Logger& logger_;
+    asio::io_context io_context_;
     asio::ip::udp::socket* socket_;
     asio::ip::udp::endpoint sender_endpoint_;
     char data_[1024];
+
     void do_receive();
     void do_send(std::size_t length);