network analyzer - first attempt
[svn/Prometheus-QoS/.git] / parsehosts.c
index 1e8dbe6..04fce9f 100644 (file)
@@ -1,4 +1,4 @@
-/* Modified by: xChaos, 20121007 */\r
+/* Modified by: xChaos, 20131028 */\r
 \r
 #include "cll1-0.6.2.h"\r
 #include "ipstruct.h"\r
@@ -7,7 +7,7 @@
 #define FIRSTIPCLASS 2048\r
 \r
 /* globals declared in prometheus.c */\r
-extern struct IP *ips, *ip, *sharedip;\r
+extern struct IP *ips, *ip, *sharedip, *networks;\r
 extern struct Group *groups, *group;\r
 extern struct Keyword *keyword, *defaultkeyword, *keywords;\r
 extern int class_count;\r
@@ -17,8 +17,11 @@ extern int free_min;
 extern const int highest_priority;\r
 extern char *ip6prefix;\r
 \r
+struct IP* find_network_for_ip(char *ipaddr_orig);\r
+/* implemented in networks.c */\r
+\r
 /* This must be object oriented! This looks almost like constructor ;-) */\r
-void TheIP(char *ipaddr)\r
+void TheIP(char *ipaddr, int is_network)\r
 {\r
  create(ip,IP);\r
  ip->name        = "";\r
@@ -40,14 +43,22 @@ void TheIP(char *ipaddr)
  ip->pktsdown    = 0;\r
  ip->keyword     = keywords;\r
  ip->v6          = (strchr(ip->addr,':')!=NULL);\r
- push(ip,ips);\r
+ ip->mask        = ((ip->v6)?64:32);\r
+ if(is_network)\r
+ {\r
+  push(ip, networks);\r
+ }\r
+ else\r
+ {\r
+  push(ip, ips); \r
+ }\r
  ip_count++;\r
 }\r
 \r
 struct IP *lastIP6;\r
 \r
 /* == This function strips extra characters after IPv4 address and stores it = */\r
-parse_ip(char *str)\r
+void parse_and_append_ip(char *str, struct IP *listhead)\r
 {\r
  char *ptr, *ipaddr, *ip6range = NULL, *ipname = NULL, *lmsid = NULL;\r
 \r
@@ -104,7 +115,7 @@ parse_ip(char *str)
   if_exists(ip, ips, eq(ip->addr,ip6range));\r
   else\r
   {\r
-   TheIP(ip6range);\r
+   TheIP(ip6range, FALSE);\r
   }\r
   ip->name = ip6range;\r
   ip->keyword = defaultkeyword; /* settings for default keyword */\r
@@ -119,10 +130,10 @@ parse_ip(char *str)
   lastIP6 = NULL;\r
  }\r
 \r
- if_exists(ip, ips, eq(ip->addr,ipaddr));\r
+ if_exists(ip, listhead, eq(ip->addr,ipaddr));\r
  else\r
  {\r
-  TheIP(ipaddr);\r
+  TheIP(ipaddr, (listhead==networks));\r
  }\r
  ip->name = ipname;\r
  if(lmsid)\r
@@ -138,6 +149,7 @@ void parse_hosts(char *hosts)
  int groupidx = FIRSTGROUPID;\r
  char *str, *ptr;\r
  char *substring;\r
+ struct IP *network;\r
 \r
  parse(hosts)\r
  {\r
@@ -154,7 +166,7 @@ void parse_hosts(char *hosts)
   if(substring)\r
   { \r
    substring += 8; /* "sharing-" */\r
-   parse_ip(str);\r
+   parse_and_append_ip(str, ips);\r
    ip->sharing = substring;\r
    ip->keyword = defaultkeyword; /* settings for default keyword */\r
    if(lastIP6)\r
@@ -170,75 +182,116 @@ void parse_hosts(char *hosts)
   }\r
   else\r
   {\r
-   /*Do we have to create new QoS class for this IP ? */\r
-\r
-   if_exists(keyword,keywords,(substring=strstr(str,keyword->key)))\r
+   substring = strstr(str, "#255.");\r
+   if(substring and not strstr(str, "#255.255.255.255")) /* do not ping /32 ranges */\r
    {\r
-    parse_ip(str);\r
-    if(lastIP6)\r
-    {\r
-     lastIP6->sharing = ip->name;\r
-     lastIP6 = NULL;\r
-    }\r
-    ip->keyword = keyword;\r
-    keyword->ip_count++;\r
-    ip->prio = keyword->default_prio;\r
-    substring += strlen(keyword->key)+1;\r
-    ptr = substring;\r
-    while(*ptr and *ptr != '-')\r
-    {\r
-     ptr++;\r
-    }\r
-    if(*ptr == '-')\r
+    /* netmask detected - save network*/\r
+    unsigned bit;\r
+    unsigned num, mask = 8;\r
+    substring += 5;\r
+    while(substring && *substring)\r
     {\r
-     *ptr=0;\r
-     ip->max = ip->desired = atoi(ptr+1);\r
-    }\r
-    ip->min = atoi(substring);\r
-    if(ip->min <= 0)\r
-    {\r
-     printf(" %s: Illegal value of minimum bandwidth 0 kbps, using %d kb/s\n",\r
-            str, free_min);\r
-     ip->min = free_min;\r
-    }\r
-    if(ip->max <= ip->min)\r
-    {\r
-     ip->fixedprio = TRUE;\r
-     ip->max = ip->min + ip->keyword->reserve_min;\r
-    }\r
-    else \r
-    {\r
-     ip->max -= ip->keyword->reserve_max;\r
-     if(ip->max<ip->min)\r
+     ptr = substring;\r
+     substring = strchr(substring, '.');\r
+     if(substring)\r
+     {\r
+      *substring = 0;\r
+      substring += 1;\r
+     }\r
+     num = atoi(ptr);\r
+     for(bit = 1; bit <=128 ; bit<<=1)\r
      {\r
-      ip->max=ip->min;\r
+      if(bit & num)\r
+      {\r
+       mask++;\r
+      }\r
      }\r
-    }\r
-    ip->mark = FIRSTIPCLASS+1+class_count++;\r
-\r
-    if_exists(group,groups,(group->min == ip->min)) \r
-    { \r
-     group->count++;      \r
-     group->desired += ip->min;\r
-     ip->group = group->id;   \r
-    }\r
-    else\r
+    } \r
+    parse_and_append_ip(str, networks);\r
+    ip->mask = mask;\r
+   }\r
+   else\r
+   {\r
+    /*Do we have to create new QoS class for this IP ? */\r
+    if_exists(keyword,keywords,(substring=strstr(str,keyword->key)))\r
     {\r
-     create(group,Group);\r
-     group->min = ip->min;\r
-     group->id = groupidx++;\r
-     ip->group = group->id;\r
-\r
-     if(group->min < 8) group->min = 8;\r
-     /* Warning - this is maybe because of primitive tc namespace, can be fixed */\r
-     /* it is because class IDs are derived from min. bandwidth. - xCh */\r
-     //if(group->min>MAX_GUARANTED_KBPS) group->min=MAX_GUARANTED_KBPS;\r
-     \r
-     group->count = 1;\r
-     group->desired = ip->min;   \r
-     insert(group, groups, desc_order_by,min);\r
-    }\r
-   }//endif keyword-\r
+     parse_and_append_ip(str, ips);\r
+     if(lastIP6)\r
+     {\r
+      lastIP6->sharing = ip->name;\r
+      lastIP6 = NULL;\r
+     }\r
+     ip->keyword = keyword;\r
+     keyword->ip_count++;\r
+     ip->prio = keyword->default_prio;\r
+     substring += strlen(keyword->key)+1;\r
+     ptr = substring;\r
+     while(*ptr and *ptr != '-')\r
+     {\r
+      ptr++;\r
+     }\r
+     if(*ptr == '-')\r
+     {\r
+      *ptr=0;\r
+      ip->max = ip->desired = atoi(ptr+1);\r
+     }\r
+     ip->min = atoi(substring);\r
+     if(ip->min <= 0)\r
+     {\r
+      printf(" %s: Illegal value of minimum bandwidth 0 kbps, using %d kb/s\n",\r
+             str, free_min);\r
+      ip->min = free_min;\r
+     }\r
+     if(ip->max <= ip->min)\r
+     {\r
+      ip->fixedprio = TRUE;\r
+      ip->max = ip->min + ip->keyword->reserve_min;\r
+     }\r
+     else \r
+     {\r
+      ip->max -= ip->keyword->reserve_max;\r
+      if(ip->max<ip->min)\r
+      {\r
+       ip->max=ip->min;\r
+      }\r
+     }\r
+     ip->mark = FIRSTIPCLASS+1+class_count++;\r
+\r
+     network = find_network_for_ip(ip->addr);\r
+     if(network)\r
+     {\r
+      network->min += ip->min;\r
+      network->desired += ip->max;\r
+      if(ip->max > network->max)\r
+      {\r
+       network->max = ip->max;\r
+      }\r
+     }\r
+\r
+     if_exists(group,groups,(group->min == ip->min)) \r
+     { \r
+      group->count++;      \r
+      group->desired += ip->min;\r
+      ip->group = group->id;   \r
+     }\r
+     else\r
+     {\r
+      create(group,Group);\r
+      group->min = ip->min;\r
+      group->id = groupidx++;\r
+      ip->group = group->id;\r
+\r
+      if(group->min < 8) group->min = 8;\r
+      /* Warning - this is maybe because of primitive tc namespace, can be fixed */\r
+      /* it is because class IDs are derived from min. bandwidth. - xCh */\r
+      //if(group->min>MAX_GUARANTED_KBPS) group->min=MAX_GUARANTED_KBPS;\r
+      \r
+      group->count = 1;\r
+      group->desired = ip->min;   \r
+      insert(group, groups, desc_order_by,min);\r
+     }\r
+    }//endif keyword-\r
+   }//endif netmask\r
   }//endif sharing-\r
  }\r
  fail\r
This page took 0.266824 seconds and 4 git commands to generate.