1 /* Modified by: xChaos, 20131220 */
3 #include "cll1-0.6.2.h"
6 #define FIRSTGROUPID 1024
7 #define FIRSTIPCLASS 2048
9 /* globals declared in prometheus.c */
10 extern struct IP
*ips
, *ip
, *sharedip
, *networks
;
11 extern struct Group
*groups
, *group
;
12 extern struct Keyword
*keyword
, *defaultkeyword
, *keywords
;
13 extern struct Macro
*macro
, *macros
;
14 extern int class_count
;
16 extern int found_lmsid
;
18 extern const int highest_priority
;
19 extern char *ip6prefix
;
21 void update_network(char *look_for
, struct IP
* ip
);
22 /* implemented in networks.c */
24 /* This must be object oriented! This looks almost like constructor ;-) */
25 void TheIP(char *ipaddr
, int is_network
)
31 ip
->prio
= highest_priority
+1;
46 ip
->keyword
= keywords
;
47 ip
->v6
= (strchr(ip
->addr
,':')!=NULL
);
48 ip
->mask
= ((ip
->v6
)?64:32);
60 struct IP
*lastIP6range
, *lastIP6uplink
;
62 /* == This function strips extra characters after IPv4 address and stores it = */
63 void parse_and_append_ip(char *str
, struct IP
*listhead
)
65 char *ptr
, *ipaddr
, *nextip6
, *ip6buf
;
66 char *ip6uplink
= NULL
, *ip6range
= NULL
, *ipname
= NULL
, *lmsid
= NULL
;
68 if(ip6prefix
) /* Try this only if IPv6 subsystem is active... */
70 ptr
= strstr(str
, "::");
71 while(ptr
&& ptr
-str
> 4)
73 nextip6
= strstr(ptr
+ 2, "::");
75 duplicate(ptr
, ip6buf
);
76 ptr
= strstr(ip6buf
, "::");
81 *(ptr
+3) = 0; /* ends with ::+ */
86 *(ptr
+2) = 0; /* ends with :: */
94 ptr
= strchr(str
, '{');
98 while(*ptr
and *ptr
!= '}')
106 while(*ptr
and *ptr
!=' ' and *ptr
!=9)
114 while(*ptr
and (*ptr
==' ' or *ptr
==9))
119 while(*ptr
and *ptr
!=' ' and *ptr
!=9)
127 concatenate(ip6prefix
,ip6range
,ptr
);
129 if_exists(ip
, ips
, eq(ip
->addr
,ip6range
)); /* check - allocated range must be unique */
132 TheIP(ip6range
, FALSE
);
135 ip
->keyword
= defaultkeyword
; /* settings for default keyword */
138 ip
->lmsid
= atoi(lmsid
);
147 /* it is ugly to copy+paste and search+replace, but... */
150 concatenate(ip6prefix
,ip6uplink
,ptr
);
152 TheIP(ip6uplink
, FALSE
); /* always new IP - more IPs in single uplink network */
153 ip
->name
= ip6uplink
;
154 ip
->keyword
= defaultkeyword
; /* settings for default keyword */
157 ip
->lmsid
= atoi(lmsid
);
163 lastIP6uplink
= NULL
;
166 if_exists(ip
, listhead
, eq(ip
->addr
,ipaddr
));
169 TheIP(ipaddr
, (listhead
==networks
));
174 ip
->lmsid
= atoi(lmsid
);
179 /* == This function parses hosts style main configuration file == */
180 void parse_hosts(char *hosts
)
182 int groupidx
= FIRSTGROUPID
;
192 if(*str
< '0' or *str
> '9')
194 /* any line starting with non-number is comment ...*/
198 ptr
= strchr(str
,'\r'); /* fore unix-style end of line */
204 /* first, expand (rewrite) any predefined macros, if found*/
205 for_each(macro
, macros
)
207 substring
= strstr(str
, macro
->rewrite_from
);
212 substring
+= strlen(macro
->rewrite_from
);
214 l3
= strlen(substring
);
215 string(ptr
, l1
+ strlen(macro
->rewrite_to
) + l3
+ 1);
217 strcat(ptr
, macro
->rewrite_to
);
218 strcat(ptr
, substring
);
220 /* printf("REWRITE: %s -> %s\n",_,str); */
224 /* Does this IP share QoS class with some other ? */
225 substring
= strstr(str
, "sharing-");
228 substring
+= 8; /* "sharing-" */
229 parse_and_append_ip(str
, ips
);
230 ip
->sharing
= substring
;
231 ip
->keyword
= defaultkeyword
; /* settings for default keyword */
234 lastIP6range
->sharing
= substring
;
239 lastIP6uplink
->sharing
= substring
;
240 lastIP6uplink
= NULL
;
242 while(*substring
and *substring
!= '\n')
250 substring
= strstr(str
, "#255.");
251 if(substring
and not strstr(str
, "#255.255.255.255")) /* do not ping /32 uplinks */
253 /* netmask detected - save network*/
255 unsigned num
, mask
= 8;
257 while(substring
&& *substring
)
260 substring
= strchr(substring
, '.');
267 for(bit
= 1; bit
<=128 ; bit
<<=1)
275 parse_and_append_ip(str
, networks
);
280 /*Do we have to create new QoS class for this IP ? */
281 if_exists(keyword
,keywords
,(substring
=strstr(str
,keyword
->key
)))
283 parse_and_append_ip(str
, ips
);
286 lastIP6range
->sharing
= ip
->name
;
291 lastIP6uplink
->sharing
= ip
->name
;
292 lastIP6uplink
= NULL
;
294 ip
->keyword
= keyword
;
296 ip
->prio
= keyword
->default_prio
;
297 substring
+= strlen(keyword
->key
)+1;
299 while(*ptr
and *ptr
!= '-')
306 ip
->max
= ip
->desired
= atoi(ptr
+1);
309 ip
->min
= atoi(substring
);
312 printf(" %s: Illegal value of minimum bandwidth 0 kbps, using %d kb/s\n",
317 if(ip
->max
<= ip
->min
)
319 ip
->fixedprio
= TRUE
;
320 ip
->max
= ip
->min
+ ip
->keyword
->reserve_min
;
324 ip
->max
-= ip
->keyword
->reserve_max
;
325 if(ip
->max
< ip
->min
)
331 /* avg MTU bytes * 8 >> 10 = in bits, max is in kb/s */
332 pktratio
= (ip
->keyword
->allowed_avgmtu
*8) >> 10;
335 ip
->pps_limit
= ip
->max
/pktratio
;
336 if(ip
->pps_limit
> 10000) /* this limit seems to be hardcoded in iptables */
338 ip
->pps_limit
= 0; /* do not apply packet limits */
342 ip
->mark
= FIRSTIPCLASS
+1+class_count
++;
343 update_network(ip
->addr
, ip
);
345 if_exists(group
,groups
,(group
->min
== ip
->min
))
348 group
->desired
+= ip
->min
;
349 ip
->group
= group
->id
;
354 group
->min
= ip
->min
;
355 group
->id
= groupidx
++;
356 ip
->group
= group
->id
;
358 if(group
->min
< 8) group
->min
= 8;
359 /* Warning - this is maybe because of primitive tc namespace, can be fixed */
360 /* it is because class IDs are derived from min. bandwidth. - xCh */
361 //if(group->min>MAX_GUARANTED_KBPS) group->min=MAX_GUARANTED_KBPS;
364 group
->desired
= ip
->min
;
365 insert(group
, groups
, desc_order_by
,min
);
376 done
; /* ugly macro end */
377 // TheIP("0.0.0.0", TRUE);
378 // ip->name = "TOTAL";
This page took 0.77156 seconds and 4 git commands to generate.