Refactored the arguments to be a ParsedArguments class.

Author: squidarth

src/frontend/linkshell.cc

@@ -12,6 +12,7 @@
 #include "link_queue.hh"
 #include "packetshell.cc"
 #include "tokenize.hh"
+#include "parsed_arguments.hh"
 
 using namespace std;
 
@@ -35,7 +36,7 @@ void usage_error( const string & program_name )
     throw runtime_error( "invalid arguments" );
 }
 
-unique_ptr<AbstractPacketQueue> get_packet_queue( const string & type, const map<string, string> & args, const string & program_name )
+unique_ptr<AbstractPacketQueue> get_packet_queue( const string & type, ParsedArguments  args, const string & program_name )
 {
     if ( type == "infinite" ) {
         return unique_ptr<AbstractPacketQueue>( new InfinitePacketQueue( args ) );
@@ -73,10 +74,10 @@ string shell_quote( const string & arg )
     return ret;
 }
 
-map<string, string> parse_queue_args( const string & arg) {
+ParsedArguments  parse_queue_args( const string & arg) {
   map<string, string> argMap = map<string, string>();
   if (arg.size() == 0) {
-    return argMap;
+    return ParsedArguments( argMap );
   }
   vector<string> argList = split(arg, ",");
 
@@ -90,7 +91,7 @@ map<string, string> parse_queue_args( const string & arg) {
     argMap.insert(pair<string, string>(argParts[0], argParts[1]));
   }
 
-  return argMap;
+  return ParsedArguments( argMap );
 }
 
 int main( int argc, char *argv[] )

src/packet/Makefile.am

@@ -9,4 +9,4 @@ libpacket_a_SOURCES = packetshell.hh packetshell.cc queued_packet.hh \
                       codel_packet_queue.cc codel_packet_queue.hh \
 		        red_packet_queue.cc red_packet_queue.hh \
                       pie_packet_queue.cc pie_packet_queue.hh \
-                      bindworkaround.hh
+                      bindworkaround.hh ../frontend/parsed_arguments.hh

src/packet/abstract_packet_queue.hh

@@ -6,6 +6,7 @@
 #include <string>
 
 #include "queued_packet.hh"
+#include "parsed_arguments.hh"
 
 class AbstractPacketQueue
 {

src/packet/codel_packet_queue.cc

@@ -5,19 +5,16 @@
 
 using namespace std;
 
-CODELPacketQueue::CODELPacketQueue( const map<string, string> & args )
+CODELPacketQueue::CODELPacketQueue( ParsedArguments & args )
   : DroppingPacketQueue(args),
-    target_ ( get_int_arg( args, "target") ),
-    interval_ ( get_int_arg( args, "interval") ),
+    target_ ( args.get_int_arg("target") ),
+    interval_ ( args.get_int_arg( "interval") ),
     first_above_time_ ( 0 ),
     drop_next_( 0 ),
     count_ ( 0 ),
     lastcount_ ( 0 ),
     dropping_ ( 0 )
 {
-  if ( target_ == 0 || interval_ == 0 ) {
-    throw runtime_error( "CoDel queue must have target and interval arguments." );
-  }
 }
 
 //NOTE: CoDel makes drop decisions at dequeueing. 

src/packet/codel_packet_queue.hh

@@ -45,7 +45,7 @@ private:
     uint64_t control_law ( uint64_t t, uint32_t count );
 
 public:
-    CODELPacketQueue( const std::map<std::string, std::string> & args );
+    CODELPacketQueue( ParsedArguments & args );
 
     void enqueue( QueuedPacket && p ) override;
 

src/packet/dropping_packet_queue.cc

@@ -8,31 +8,15 @@
 
 using namespace std;
 
-DroppingPacketQueue::DroppingPacketQueue( const map<string, string> & args )
-    : packet_limit_( get_int_arg( args, "packets" ) ),
-      byte_limit_( get_int_arg( args, "bytes" ) )
+DroppingPacketQueue::DroppingPacketQueue( ParsedArguments & args )
+    : packet_limit_( args.get_int_arg( "packets", 0 ) ),
+      byte_limit_( args.get_int_arg( "bytes", 0 ) )
 {
     if ( packet_limit_ == 0 and byte_limit_ == 0 ) {
         throw runtime_error( "Dropping queue must have a byte or packet limit." );
     }
 }
 
-unsigned int DroppingPacketQueue::get_int_arg(const map<string, string> & args, const string & name) {
-  if (args.count(name) > 0) {
-    return myatoi(args.at(name));
-  } else {
-    return 0;
-  }
-}
-
-double DroppingPacketQueue::get_float_arg(const map<string, string> & args, const string & name) {
-  if (args.count(name) > 0) {
-    return myatof(args.at(name));
-  } else {
-    return 0;
-  }
-}
-
 QueuedPacket DroppingPacketQueue::dequeue( void )
 {
     assert( not internal_queue_.empty() );

src/packet/dropping_packet_queue.hh

@@ -35,7 +35,7 @@ protected:
                     const unsigned int size_in_packets ) const;
 
 public:
-    DroppingPacketQueue( const std::map<std::string, std::string> & args );
+    DroppingPacketQueue( ParsedArguments & args );
 
     virtual void enqueue( QueuedPacket && p ) = 0;
 

src/packet/infinite_packet_queue.hh

@@ -17,7 +17,7 @@ private:
     std::queue<QueuedPacket> internal_queue_ {};
 
 public:
-    InfinitePacketQueue( const std::map<std::string, std::string> & args )
+    InfinitePacketQueue( ParsedArguments & args )
     {
         if ( not args.empty() ) {
             throw std::runtime_error( "InfinitePacketQueue does not take arguments." );

src/packet/pie_packet_queue.cc

@@ -8,10 +8,10 @@ using namespace std;
 
 #define DQ_COUNT_INVALID   (uint32_t)-1
 
-PIEPacketQueue::PIEPacketQueue( const map<string, string> & args )
+PIEPacketQueue::PIEPacketQueue( ParsedArguments & args )
   : DroppingPacketQueue(args),
-    qdelay_ref_ ( get_int_arg( args, "qdelay_ref" ) ),
-    max_burst_ ( get_int_arg( args, "max_burst" ) ),
+    qdelay_ref_ ( args.get_int_arg( "qdelay_ref" ) ),
+    max_burst_ ( args.get_int_arg( "max_burst" ) ),
     alpha_ ( 0.125 ),
     beta_ ( 1.25 ),
     t_update_ ( 30 ),

src/packet/pie_packet_queue.hh

@@ -52,7 +52,7 @@ private:
     void calculate_drop_prob ( void );
 
 public:
-    PIEPacketQueue( const std::map<std::string, std::string> & args );
+    PIEPacketQueue( ParsedArguments & args );
 
     void enqueue( QueuedPacket && p ) override;