b6eeb27beb663cf9a18eed5131cd5b72bd9d766b
1 /* - - - - - - - - - - - - - - - - - - - - - - - - - - - - - */
2 /* Prometheus QoS - you can "steal fire" from your ISP */
3 /* "fair-per-IP" quality of service (QoS) utility */
4 /* requires Linux 2.4.x or 2.6.x with HTB support */
5 /* Copyright(C) 2005-2012 Michael Polak, Arachne Labs */
6 /* iptables-restore support Copyright(C) 2007-2008 ludva */
7 /* Credit: CZFree.Net,Martin Devera,Netdave,Aquarius,Gandalf */
8 /* - - - - - - - - - - - - - - - - - - - - - - - - - - - - - */
10 /* Modified by: xChaos, 20120612
13 Prometheus QoS is free software; you can redistribute it and/or
14 modify it under the terms of the GNU General Public License as
15 published by the Free Software Foundation; either version 2.1 of
16 the License, or (at your option) any later version.
18 Prometheus QoS is distributed in the hope that it will be useful,
19 but WITHOUT ANY WARRANTY; without even the implied warranty of
20 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
21 General Public License for more details.
23 You should have received a copy of the GNU General Public License
24 along with Prometheus Qos; if not, write to the Free Software
25 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
27 GNU General Public License is located in file COPYING */
30 #define FIRSTGROUPID 1024
31 #define FIRSTIPCLASS 2048
34 #include "cll1-0.6.2.h"
36 const char *version
= "0.8.3-f";
38 /* Version numbers: 0.8.3 is development releases ("beta"), 0.8.4 will be "stable" */
39 /* Debian(RPM) package versions/patchlevels: 0.7.9-2, 0.8.0-1, 0.8.0-2, etc. */
40 /* C source code development versions ("beta"): 0.7.9-a, 0.8.1-b, etc. */
41 /* C source code release versions: 0.8.0, 0.8.2, 0.8.4, etc. */
43 const char *stats_html_signature
= "<span class=\"small\">Statistics generated by Prometheus QoS version %s<br />GPL+Copyright(C)2005-2012 Michael Polak, <a target=\"_blank\" href=\"http://www.arachne.cz/\">Arachne Labs</a></span>\n";
45 /* ======= All path names are defined here (for RPM patch) ======= */
47 const char *tc
= "/sbin/tc"; /* requires tc with HTB support */
48 const char *iptables
= "/sbin/iptables"; /* requires iptables utility */
49 const char *iptablessave
= "/sbin/iptables-save"; /* not yet required */
50 const char *iptablesrestore
= "/sbin/iptables-restore"; /* requires iptables-restore */
51 const char *ls
= "/bin/ls"; /* this is not user configurable :-) */
53 char *config
= "/etc/prometheus/prometheus.conf"; /* main configuration file */
54 char *hosts
= "/etc/prometheus/hosts"; /* per-IP bandwidth definition file */
56 char *iptablesfile
= "/var/spool/prometheus.iptables"; /* temporary file for iptables-restore*/
57 char *credit
= "/var/lib/misc/prometheus.credit"; /* credit log file */
58 char *classmap
= "/var/lib/misc/prometheus.classes"; /* credit log file */
59 char *html
= "/var/www/traffic.html"; /* hall of fame - html version */
60 char *preview
= "/var/www/preview.html"; /* hall of fame preview - html version */
61 char *json
= "/var/www/logs/traffic.json"; /* hall of fame - json version */
62 char *json_preview
= "/var/www/logs/preview.json"; /* hall of fame preview - json version */
63 char *cmdlog
= "/var/log/prometheuslog"; /* command log filename */
64 char *log_dir
= "/var/www/logs/"; /* log directory pathname, ended with slash */
65 char *log_url
= "/logs/"; /* log directory relative URI prefix (partial URL) */
66 char *html_log_dir
= "/var/www/logs/html/";
68 char *jquery_url
= "http://code.jquery.com/jquery-latest.js";
69 char *lms_url
= "/lms/?m=customerinfo&id=";
70 int use_jquery_popups
= 1;
71 int row_odd_even
= 0; /*<tr class="odd/even"> */
74 const char *tr_odd_even(void)
76 row_odd_even
= 1 - row_odd_even
;
79 return "<tr class=\"even\">\n";
83 return "<tr class=\"odd\">\n";
87 /* ======= Help screen is hopefuly self-documenting part of code :-) ======= */
91 puts("Command line switches:\n\
93 -d Dry run (preview tc and iptables commands on stdout)\n\
94 -r Run (reset all statistics and start shaping - daily usage)\n\
95 -p just generate Preview of data transfer statistics and exit (after -r)\n\
96 -s start Shaping FUP limits (keeps data transfer stat like -p) (after -r)\n\
97 -n run Now (like -r delay - overrides qos-free-delay keyword, after boot)\n\
98 -f just Flush iptables and tc classes and exit (stop shaping, no QiS)\n\
99 -9 emergency iptables flush (like -f, but dumps data transfer statistics)\n\
101 -c filename force alternative /etc/prometheus/prometheus.conf filename\n\
102 -h filename force alternative /etc/hosts filename (overrides hosts keyword)\n\
103 -l Mmm YYYY generate HTML summary of Logged traffic (Mmm=Jan-Dec) (and exit)\n\
104 -m generate HTML summary of traffic for yesterday's Month (and exit)\n\
105 -y generate HTML summary of traffic for yesterday's Year (and exit)\n\
106 -? --help show this help scree (and exit)\n\
107 -v --version show Version number of this utility (and exit)\n");
110 /* === Configuraration file values defaults - stored in global variables ==== */
112 int filter_type
= 1; /*1 mark, 2 classify*/
114 char *mark_iptables
= "MARK --set-mark ";
115 int dry_run
= 0; /* preview - use puts() instead of system() */
116 char *iptablespreamble
= "*mangle\n:PREROUTING ACCEPT [0:0]\n:POSTROUTING ACCEPT [0:0]\n:INPUT ACCEPT [0:0]\n:OUTPUT ACCEPT [0:0]\n:FORWARD ACCEPT [0:0]";
117 FILE *iptables_file
= NULL
;
118 int enable_credit
= 1; /* enable credit file */
119 int use_credit
= 0; /* use credit file (if enabled)*/
120 char *title
= "Hall of Fame - Greatest Suckers"; /* hall of fame title */
121 int hall_of_fame
= 1; /* enable hall of fame */
122 char *lan
= "eth0"; /* LAN interface */
123 char *lan_medium
= "100Mbit"; /* 10Mbit/100Mbit ethernet */
124 char *wan
= "eth1"; /* WAN/ISP interface */
125 char *wan_medium
= "100Mbit"; /* 10Mbit/100Mbit ethernet */
126 char *qos_leaf
= "sfq perturb 5"; /* leaf discipline */
127 char *qos_free_zone
= NULL
; /* QoS free zone */
128 int qos_proxy
= 1; /* include proxy port to QoS */
129 int found_lmsid
= 0; /* show links to users in LMS information system */
130 int include_upload
= 1; /* upload+download=total traffic */
131 char *proxy_ip
= "192.168.1.1/32"; /* our IP with proxy port */
132 int proxy_port
= 3128; /* proxy port number */
133 long long int line
= 1024; /* WAN/ISP download in kbps */
134 long long int up
= 1024; /* WAN/ISP upload in kbps */
135 int free_min
= 32; /* minimum guaranted bandwidth for all undefined hosts */
136 int free_max
= 64; /* maximum allowed bandwidth for all undefined hosts */
137 int qos_free_delay
= 0; /* seconds to sleep before applying new QoS rules */
138 int digital_divide
= 2; /* controls digital divide weirdness ratio, 1...3 */
139 int max_nesting
= 3; /* maximum nesting of HTB clases, built-in maximum seems to be 4 */
140 int htb_r2q
= 256; /* should work for leaf values 512 kbps to 8 Mbps */
141 int burst
= 8; /* HTB burst (in kbits) */
143 int burst_group
= 32;
144 int magic_treshold
= 8; /* reduce ceil by X*magic_treshhold kbps (hard shaping) */
145 int keywordcount
= 0;
146 /* not yet implemented:
147 int fixed_packets = 0; maximum number of pps per IP address (not class!)
148 int packet_limit = 5; maximum number of pps to htn CEIL, not rate !!!
150 FILE *log_file
= NULL
;
151 char *kwd
= "via-prometheus"; /* /etc/hosts comment, eg. #qos-64-128 */
153 const int highest_priority
= 0; /* highest HTB priority (HTB built-in value is 0) */
154 const int lowest_priority
= 7; /* lowest HTB priority (HTB built-in value is 7) */
155 const int idxtable_treshold1
= 24; /* this is no longer configurable */
156 const int idxtable_treshold2
= 12; /* this is no longer configurable */
157 const int idxtable_bitmask1
= 3; /* this is no longer configurable */
158 const int idxtable_bitmask2
= 3; /* this is no longer configurable */
160 /* ==== This is C<<1 stuff - learn C<<1 first! https://dev.arachne.cz/svn/cll1h ==== */
175 unsigned long long direct
;
176 unsigned long long proxy
;
177 unsigned long long upload
;
178 unsigned long long traffic
;
179 unsigned long long credit
;
180 unsigned long pktsup
;
181 unsigned long pktsdown
;
182 struct Keyword
*keyword
;
184 } *ips
=NULL
, *ip
, *sharedip
;
193 } *groups
=NULL
, *group
;
199 struct Index
*parent
;
203 } *idxs
=NULL
, *idx
, *metaindex
;
209 int asymetry_ratio
; /* ratio for ADSL-like upload */
210 int asymetry_fixed
; /* fixed treshold for ADSL-like upload */
211 int data_limit
; /* hard shaping: apply magic_treshold if max*data_limit MB exceeded */
212 int data_prio
; /* soft shaping (qos): reduce HTB prio if max*data_prio MB exceeded */
213 long fixed_limit
; /* fixed data limit for setting lower HTB ceil */
214 long fixed_prio
; /* fixed data lmit for setting lower HTB prio */
215 int reserve_min
; /* bonus for nominal HTB rate bandwidth (in kbps) */
216 int reserve_max
; /* malus for nominal HTB ceil (in kbps) */
217 // int divide_max; /* relative malus: new_ceil=rate+(old_ceil-rate)/divide_max */
218 // int htb_ceil_bonus_divide; /* relative bonus: new_ceil=old_ceil+old_ceil/htb_ceil_bonus_divide */
219 int default_prio
; /* default HTB priority for this keyword */
222 char *leaf_discipline
;
225 } *keyword
,*defaultkeyword
=NULL
,*keywords
=NULL
;
227 /* Damned, this must be object oriented! This looks almost like constructor ;-) */
235 ip
->prio
= highest_priority
+1;
249 ip
->keyword
= keywords
;
253 /* ====== iptables indexes are used to reduce complexity to log8(N) ===== */
255 char *very_ugly_ipv4_code(char *inip
,int bitmask
,int format_as_chainname
)
257 /* warning: this function was debugged only for bitmask values 20,24,28 !!!*/
259 char *ip
,*outip
,*outptr
,*fmt
;
262 /* debug printf("(%s,%d) -> ",ip,bitmask); */
264 if(ip
&& *ip
&& bitmask
>=0 && bitmask
<=32)
266 string(outip
,strlen(ip
)+10); /*fuck unicode? assertion: 10>strlen("_%d_%d") */
270 /* should never exit here */
278 if(dot
<(bitmask
/8-1))
280 if(format_as_chainname
)
293 char *cutdot
=strchr(ip
+1,'.'); /*for bitmask<24*/
299 if(format_as_chainname
)
310 n
= atoi(ip
+1)-atoi(ip
+1)%(1<<(8-bitmask
%8));
317 /*debug printf("%d/%d => [_%d_%d]\n",atoi(ip+1),bitmask,n,bitmask); */
318 sprintf(outptr
,fmt
,n
,bitmask
);
319 if(!format_as_chainname
)
327 /* debug printf("[%s]\n",outip); */
338 /*should never exit here*/
343 char *hash_id(char *ip
,int bitmask
)
345 return very_ugly_ipv4_code(ip
,bitmask
,1);
348 char *subnet_id(char *ip
,int bitmask
)
350 return very_ugly_ipv4_code(ip
,bitmask
,0);
353 /* ================= Let's parse configuration file here =================== */
355 void reject_config_and_exit(char *filename
)
357 printf("Configuration file %s rejected - abnormal exit.",filename
);
361 void get_config(char *config_filename
)
365 printf("Configured keywords: ");
366 parse(config_filename
)
368 option("keyword",kwd
);
373 create(keyword
,Keyword
);
375 keyword
->asymetry_ratio
=1; /* ratio for ADSL-like upload */
376 keyword
->asymetry_fixed
=0; /* fixed treshold for ADSL-like upload */
377 keyword
->data_limit
=8; /* hard shaping: apply magic_treshold if max*data_limit MB exceeded */
378 keyword
->data_prio
=4; /* soft shaping (qos): reduce HTB prio if max*data_prio MB exceeded */
379 keyword
->fixed_limit
=0; /* fixed data limit for setting lower HTB ceil */
380 keyword
->fixed_prio
=0; /* fixed data limit for setting lower HTB prio */
381 keyword
->reserve_min
=8; /* bonus for nominal HTB rate bandwidth (in kbps) */
382 keyword
->reserve_max
=0; /* malus for nominal HTB ceil (in kbps) */
383 keyword
->default_prio
=highest_priority
+1;
384 keyword
->html_color
="000000";
386 keyword
->leaf_discipline
="";
388 push(keyword
,keywords
);
389 if(!defaultkeyword
) defaultkeyword
=keyword
;
396 for_each(keyword
,keywords
)
398 int l
=strlen(keyword
->key
);
400 if(!strncmp(keyword
->key
,_
,l
) && strlen(_
)>l
+2)
402 char *tmptr
=_
; /* <---- l+1 ----> */
403 _
+=l
+1; /* via-prometheus-asymetry-ratio, etc. */
404 ioption("asymetry-ratio",keyword
->asymetry_ratio
);
405 ioption("asymetry-treshold",keyword
->asymetry_fixed
);
406 ioption("magic-relative-limit",keyword
->data_limit
);
407 ioption("magic-relative-prio",keyword
->data_prio
);
408 loption("magic-fixed-limit",keyword
->fixed_limit
);
409 loption("magic-fixed-prio",keyword
->fixed_prio
);
410 ioption("htb-default-prio",keyword
->default_prio
);
411 ioption("htb-rate-bonus",keyword
->reserve_min
);
412 ioption("htb-ceil-malus",keyword
->reserve_max
);
413 option("leaf-discipline",keyword
->leaf_discipline
);
414 option("html-color",keyword
->html_color
);
417 if(keyword
->data_limit
|| keyword
->fixed_limit
||
418 keyword
->data_prio
|| keyword
->fixed_prio
)
427 option("iptables",iptables
);
428 option("iptables-save",iptablessave
); /* new */
429 option("iptables-restore",iptablesrestore
); /* new */
430 option("iptables-in-filename",iptablesfile
); /* new */
431 option("hosts",hosts
);
432 option("lan-interface",lan
);
433 option("wan-interface",wan
);
434 option("lan-medium",lan_medium
);
435 option("wan-medium",wan_medium
);
436 lloption("wan-download",line
);
437 lloption("wan-upload",up
);
438 ioption("hall-of-fame-enable",hall_of_fame
);
439 option("hall-of-fame-title",title
);
440 option("hall-of-fame-filename",html
);
441 option("json-filename",json
);
442 option("hall-of-fame-preview",preview
);
443 option("json-preview",json_preview
);
444 option("log-filename",cmdlog
);
445 option("credit-filename",credit
);
446 option("classmap-filename",classmap
);
447 ioption("credit-enable",enable_credit
);
448 option("log-traffic-directory",log_dir
);
449 option("log-traffic-html-directory",html_log_dir
);
450 option("log-traffic-url-path",log_url
);
451 option("jquery-url",jquery_url
);
452 option("lms-url",lms_url
);
453 ioption("use-jquery-popups",use_jquery_popups
);
454 option("qos-free-zone",qos_free_zone
);
455 ioption("qos-free-delay",qos_free_delay
);
456 ioption("qos-proxy-enable",qos_proxy
);
457 option("qos-proxy-ip",proxy_ip
);
458 option("htb-leaf-discipline",qos_leaf
);
459 ioption("qos-proxy-port",proxy_port
);
460 ioption("free-rate",free_min
);
461 ioption("free-ceil",free_max
);
462 ioption("htb-burst",burst
);
463 ioption("htb-burst-main",burst_main
);
464 ioption("htb-burst-group",burst_group
);
465 ioption("htb-nesting-limit",max_nesting
);
466 ioption("htb-r2q",htb_r2q
);
467 ioption("magic-include-upload",include_upload
);
468 ioption("magic-treshold",magic_treshold
);
469 option("filter-type", cnf
);
470 /* not yet implemented:
471 ioption("magic-fixed-packets",fixed_packets);
472 ioption("magic-relative-packets",packet_limit);
477 perror(config_filename
);
478 puts("Warning - using built-in defaults instead ...");
480 done
; /* ugly macro end */
483 /* leaf discipline for keywords */
484 for_each(keyword
,keywords
)
486 if(!strcmpi(keyword
->leaf_discipline
, ""))
488 keyword
->leaf_discipline
= qos_leaf
;
492 if(strcmpi(cnf
, "mark"))
496 mark_iptables
= "CLASSIFY --set-class 1:";
502 mark_iptables
= "MARK --set-mark ";
505 /* are supplied values meaningful ?*/
508 puts("Illegal value of LAN or WAN bandwidth: 0 kbps.");
509 reject_config_and_exit(config_filename
);
513 /* ===================== traffic analyser - uses iptables ================ */
515 void get_traffic_statistics(void)
520 textfile(Pipe
,str
) *line
,*lines
=NULL
;
524 sprintf(cmd
,"%s -L -v -x -n -t mangle",iptables
);
536 int col
, accept
=0,proxyflag
=0,valid
=1,setchainname
=0,commonflag
=0;
537 unsigned long long traffic
=0;
538 unsigned long pkts
=0;
539 char *ipaddr
=NULL
,*ptr
;
541 /* debug puts(line->str); */
542 valid_columns(ptr
,line
->str
,' ',col
)
543 if(valid
) switch(col
)
545 case 1: if(eq(ptr
,"Chain"))
549 else if(eq(ptr
,"pkts"))
555 sscanf(ptr
,"%lu",&pkts
);
558 case 2: if(setchainname
)
560 if(!strncmp(ptr
,"post_",5) || eq(ptr
,"POSTROUTING"))
566 if(!strncmp(ptr
,"forw_",5) || eq(ptr
,"FORWARD"))
571 if(eq(ptr
,"post_common") || eq(ptr
,"forw_common"))
578 sscanf(ptr
,"%Lu",&traffic
);
583 case 3: if((strncmp(ptr
,"post_",5) && strncmp(ptr
,"forw_",5)) || commonflag
)
587 /*if(filter_type==1) accept=eq(ptr,"MARK"); else accept=eq(ptr,"CLASSIFY");*/
589 case 8: if(downloadflag
)
591 if(strstr(proxy_ip
,ptr
))
601 case 9: if(downloadflag
)ipaddr
=ptr
;break;
604 if(accept
&& traffic
>0 && ipaddr
)
610 else if(!downloadflag
)
614 printf("IP %s: %Lu MB (%ld pkts)\n", ipaddr
, traffic
, pkts
);
616 if_exists(ip
,ips
,eq(ip
->addr
,ipaddr
));
621 if(eq(ip
->addr
,"0.0.0.0/0"))
623 ip
->name
="(unregistered)";
625 ip
->max
=ip
->desired
=free_max
;
637 ip
->traffic
+=traffic
;
639 ip
->direct
=ip
->traffic
-ip
->upload
-ip
->proxy
;
648 ip
->traffic
+=traffic
;
652 if(traffic
>ip
->traffic
)
663 /* ========== This function executes, logs OR ALSO prints command ========== */
665 void safe_run(char *cmd
)
669 printf("\n=>%s\n",cmd
);
677 fprintf(log_file
,"%s\n",cmd
);
681 void save_line(char *line
)
683 fprintf(iptables_file
,"%s\n",line
);
686 void run_restore(void)
689 string(restor
,STRLEN
);
691 /*-----------------------------------------------------------------*/
692 printf("Running %s <%s ...\n", iptablesrestore
, iptablesfile
);
693 /*-----------------------------------------------------------------*/
696 fclose(iptables_file
);
703 done
; /* ugly macro end */
706 sprintf(restor
,"%s <%s",iptablesrestore
, iptablesfile
);
712 /* == This function strips extra characters after IP address and stores it = */
714 void parse_ip(char *str
)
716 char *ptr
,*ipaddr
=NULL
,*ipname
=NULL
,*lmsid
=NULL
;
722 while(*ptr
&& *ptr
!='}')
730 while(*ptr
&& *ptr
!=' ' && *ptr
!=9)
738 while(*ptr
&& (*ptr
==' ' || *ptr
==9))
743 while(*ptr
&& *ptr
!=' ' && *ptr
!=9)
749 if_exists(ip
,ips
,eq(ip
->addr
,ipaddr
));
758 ip
->lmsid
=atoi(lmsid
);
763 char *parse_datafile_line(char *str
)
765 char *ptr
=strchr(str
,' ');
790 void parse_ip_log(int argc
, char **argv
)
792 char *month
, *year
, *str
, *name
="(undefined)", *ptr
, *ptr2
, *filename
;
793 long traffic
=0l, traffic_month
, total
=0, guaranted
;
794 int col
, col2
, y_ok
, m_ok
, accept_month
, i
=1, any_month
=0, lmsid
;
795 char mstr
[4], ystr
[5];
798 string(filename
,STRLEN
);
800 if(argv
[1][1]=='l') /* -l */
804 puts("Missing parameter(s)!\nUsage: prometheus -l Mmm YYYY (Mmm=Jan-Dec or Year, YYYY=year)");
810 if(eq(month
,"Year")) any_month
=1;
816 time_t t
= time(NULL
) - 3600*24 ; /* yesterday's timestamp*/
817 struct tm
*timep
= localtime(&t
);
819 if(argv
[1][1]=='m') /* -m yestarday - month */
821 strftime(mstr
, 4, "%b", timep
);
823 strftime(ystr
, 5, "%Y", timep
);
826 else /* -y yesterday - year */
830 strftime(ystr
, 5, "%Y", timep
);
834 printf("Analysing traffic for %s %s ...\n",month
,year
);
836 /* sorry... next release of C<<1 header file will include for_path_files(name,path) { } macro */
837 sprintf(str
,"%s %s/",ls
,log_dir
);
841 if(strstr(str
,".log"))
843 ptr
=strrchr(str
,'\n');
845 sprintf(filename
,"%s/%s",log_dir
,str
);
846 printf("Parsing %s ...",filename
);
854 valid_columns(ptr
,_
,'\t',col
) switch(col
)
856 case 2: name
= ptr
;break;
857 case 3: traffic
= atol(ptr
);break;
858 /* column number - was 7, now 11...*/
863 case 11: if(isalpha(*ptr
)) /* character, not numeric string = date, just one*/
865 valid_columns(ptr2
,ptr
,' ',col2
) switch(col2
)
867 case 2: if(any_month
|| eq(ptr2
,month
)) m_ok
= 1; break;
868 case 5: if(eq(ptr2
,year
)) y_ok
= 1; break;
873 if(col
== 7) guaranted
= atol(ptr
);
874 if(col
== 10) lmsid
= atoi(ptr
);
880 traffic_month
+= traffic
;
884 done
; /* ugly macro end */
890 iplog
->guaranted
= guaranted
;
891 iplog
->traffic
= traffic_month
;
892 iplog
->lmsid
= lmsid
;
893 insert(iplog
,iplogs
,desc_order_by
,traffic
);
894 printf(" %ld MB\n",iplog
->traffic
);
898 puts(" no records.");
902 sprintf(str
,"%s/%s-%s.html",html_log_dir
,year
,month
);
903 printf("Writing %s ... ",str
);
907 fprintf(f
, "<table class=\"decorated last\"><thead>\n\
908 <tr><th colspan=\"2\">%s %s</th>\n\
909 <th style=\"text-align: right\">lms</th>\n\
910 <th colspan=\"2\">Data transfers</th>\n\
911 <th style=\"text-align: right\">Min.speed</th>\n\
912 </tr></thead><tbody>\n ",
916 for_each(iplog
, iplogs
)
920 fprintf(f
, "%s<td style=\"text-align: right\">%d</td>\n\
921 <td style=\"text-align: left\"><a class=\"blue\" target=\"_blank\" href=\"%s%s.log\">%s</td>\n\
922 <td style=\"text-align: right\">",
923 tr_odd_even(), i
++, log_url
, iplog
->name
, iplog
->name
);
926 /*base URL will be configurable soon ... */
927 fprintf(f
, "<a class=\"blue\" target=\"_blank\" href=\"%s%d\">%04d</a>\n", lms_url
, iplog
->lmsid
, iplog
->lmsid
);
929 else if(iplog
->lmsid
== 0)
933 fprintf(f
, "<td style=\"text-align: right\">%ld MB</td>\n\
934 <td style=\"text-align: right\"><strong>%ld GB</strong></td>\n\
935 <td style=\"text-align: right\">%ld kb/s</th></tr>\n",
936 iplog
->traffic
, iplog
->traffic
>>10, iplog
->guaranted
);
937 total
+=iplog
->traffic
>>10;
942 fprintf(f
,"</tbody><thead><tr>\
943 <th colspan=\"3\" style=\"text-align: left\">Total:</th>\
944 <th colspan=\"2\" style=\"text-align: right\"><strong>%ld GB</strong></th>\
945 <th style=\"text-align: right\"><strong>%Ld kb/s</strong></th></tr>\n", total
, line
);
946 fputs("</thead></table>\n", f
);
951 fputs("<a name=\"erp\"></a><p><table class=\"decorated last\">\n\
952 <caption>Enterprise Resource Planning (ERP)</caption>\n\
954 <th>Analytic category</th>\n\
955 <th colspan=\"2\" style=\"text-align: center\">Active Classes</th>\n\
956 <th colspan=\"2\" style=\"text-align: center\">Data transfers</th>\n\
957 </tr></thead><tbody>\n",f
);
959 if_exists(iplog
,iplogs
,iplog
->l
>=total
/4)
961 fprintf(f
,"%s<td>Top 25%% of traffic</td>\n", tr_odd_even());
962 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
963 <td style=\"text-align: right\">%d %%</td>\n\
964 <td style=\"text-align: right\">%ld GB</td>\n\
965 <td style=\"text-align: right\">%d %%</td></tr>\n",
966 iplog
->i
, (100*iplog
->i
+50)/i
, iplog
->l
, (int)((100*iplog
->l
+50)/total
));
969 if_exists(iplog
,iplogs
,iplog
->i
==10)
971 fprintf(f
,"%s<td>Top 10 downloaders</td>\n", tr_odd_even());
972 fprintf(f
,"<td style=\"text-align: right\"><strong>10</strong></td>\n\
973 <td style=\"text-align: right\">%d %%</td>\n\
974 <td style=\"text-align: right\">%ld GB</td>\n\
975 <td style=\"text-align: right\">%d %%</td></tr>\n",
976 (100*iplog
->i
+50)/i
, iplog
->l
, (int)((100*iplog
->l
+50)/total
));
979 if_exists(iplog
,iplogs
,iplog
->l
>=total
/2)
981 fprintf(f
,"%s<td>Top 50%% of traffic</td>\n", tr_odd_even());
982 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
983 <td style=\"text-align: right\">%d %%</td>\n\
984 <td style=\"text-align: right\">%ld GB</td>\n\
985 <td style=\"text-align: right\"><strong>%d %%</strong></td></tr>\n",
986 iplog
->i
,(100*iplog
->i
+50)/i
,iplog
->l
,(int)((100*iplog
->l
+50)/total
));
989 if_exists(iplog
,iplogs
,iplog
->l
>=4*total
/5)
991 fprintf(f
,"%s<td>Top 80%% of traffic</td>\n",tr_odd_even());
992 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
993 <td style=\"text-align: right\">%d %%</td>\n\
994 <td style=\"text-align: right\">%ld GB</td>\n\
995 <td style=\"text-align: right\"><strong>%d %%</strong></td></tr>\n",
996 iplog
->i
, (100*iplog
->i
+50)/i
, iplog
->l
, (int)((100*iplog
->l
+50)/total
));
999 if_exists (iplog
,iplogs
,iplog
->i
>=i
/5)
1001 fprintf(f
,"%s<td>Top 20%% downloaders</td>\n",tr_odd_even());
1002 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1003 <td style=\"text-align: right\"><strong>%d %%</strong></td>\n\
1004 <td style=\"text-align: right\">%ld GB</td>\n\
1005 <td style=\"text-align: right\">%d %%</td></tr>\n",
1006 iplog
->i
, (100*iplog
->i
+50)/i
, iplog
->l
, (int)((100*iplog
->l
+50)/total
));
1009 if_exists(iplog
,iplogs
,iplog
->i
>=i
/4)
1011 fprintf(f
,"%s<td>Top 25%% downloaders</td>\n", tr_odd_even());
1012 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1013 <td style=\"text-align: right\">%d %%</td>\n\
1014 <td style=\"text-align: right\">%ld GB</td>\n\
1015 <td style=\"text-align: right\">%d %%</td></tr>\n",
1016 iplog
->i
, (100*iplog
->i
+50)/i
, iplog
->l
, (int)((100*iplog
->l
+50)/total
));
1019 if_exists(iplog
,iplogs
,iplog
->i
>=i
/2)
1021 fprintf(f
,"%s<td>Top 50%% downloaders</td>\n",tr_odd_even());
1022 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1023 <td style=\"text-align: right\"><strong>%d %%</strong></td>\n\
1024 <td style=\"text-align: right\">%ld GB</td>\n\
1025 <td style=\"text-align: right\">%d %%</td></tr>\n",
1026 iplog
->i
, (100*iplog
->i
+50)/i
, iplog
->l
, (int)((100*iplog
->l
+50)/total
));
1029 if_exists(iplog
,iplogs
,iplog
->i
>=4*i
/5)
1031 fprintf(f
,"%s<td>Top 80%% downloaders</td>\n",tr_odd_even());
1032 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1033 <td style=\"text-align: right\">%d %%</td>\n\
1034 <td style=\"text-align: right\">%ld GB</td>\n\
1035 <td style=\"text-align: right\">%d %%</td></tr>\n",
1036 iplog
->i
, (100*iplog
->i
+50)/i
, iplog
->l
, (int)((100*iplog
->l
+50)/total
));
1039 fprintf(f
,"</tbody><thead><tr><th><a class=\"blue\" target=\"_blank\" href=\"%sERP.log\">All users, all traffic</a></th>\n", log_url
);
1040 fprintf(f
,"<th style=\"text-align: right\">%d</th>\n\
1041 <th style=\"text-align: right\">100 %%</th>\n\
1042 <th style=\"text-align: right\">%ld GB</th>\n\
1043 <th style=\"text-align: right\">100 %%</th></tr>\n",i
-1,total
);
1044 fputs("</thead></table>\n", f
);
1047 fprintf(f
, stats_html_signature
, version
);
1057 void append_log(struct IP
*self
) /*using global variables*/
1062 date(d
); /* this is typical cll1.h macro - prints current date */
1064 sprintf(str
,"%s/%s.log", log_dir
, self
->name
);
1068 fprintf(f
,"%ld\t%s\t%Lu\t%Lu\t%Lu\t%Lu\t%d\t%d\t%d\t%d\t%s",
1069 time(NULL
), self
->name
, self
->traffic
, self
->direct
, self
->proxy
,
1070 self
->upload
, self
->min
, self
->max
, self
->desired
, self
->lmsid
, d
); /* d = date*/
1080 /*-----------------------------------------------------------------*/
1081 /* Are you looking for int main(int argc, char **argv) ? :-)) */
1082 /*-----------------------------------------------------------------*/
1086 int i
=0; /* just plain old Fortran style integer :-) */
1087 FILE *f
=NULL
; /* everything is just stream of bytes... */
1088 char *str
, *ptr
, *d
; /* LET A$=B$ :-) */
1090 int class_count
=0,ip_count
=0;
1092 int just_flush
=FALSE
; /* deactivates all previous actions */
1094 int just_preview
=FALSE
; /* preview - generate just stats */
1095 int start_shaping
=FALSE
; /* apply FUP - requires classmap file */
1096 int just_logs
=FALSE
; /* just parse logs */
1100 char *chain_forward
, *chain_postrouting
;
1101 char *althosts
=NULL
;
1104 Prometheus QoS - \"fair-per-IP\" Quality of Service setup utility.\n\
1105 Version %s - Copyright (C)2005-2012 Michael Polak, Arachne Labs\n\
1106 iptables-restore & burst tunning & classify modification by Ludva\n\
1107 Credit: CZFree.Net, Martin Devera, Netdave, Aquarius, Gandalf\n\n",version
);
1109 /*----- Boring... we have to check command line options first: ----*/
1112 argument("-c") { nextargument(config
); }
1113 argument("-h") { nextargument(althosts
);}
1114 argument("-d") { run
=TRUE
; dry_run
=TRUE
; }
1115 argument("-f") { run
=TRUE
; just_flush
=TRUE
; }
1116 argument("-9") { run
=TRUE
; just_flush
=9; }
1117 argument("-p") { run
=TRUE
; just_preview
=TRUE
; }
1118 argument("-s") { run
=TRUE
; just_preview
=TRUE
; start_shaping
=TRUE
; }
1119 argument("-r") { run
=TRUE
; }
1120 argument("-n") { run
=TRUE
; nodelay
=TRUE
; }
1121 argument("-l") { just_logs
=TRUE
; }
1122 argument("-m") { just_logs
=TRUE
; }
1123 argument("-y") { just_logs
=TRUE
; }
1124 argument("-?") { help(); exit(0); }
1125 argument("--help") { help(); exit(0); }
1126 argument("-v") { exit(0); }
1127 argument("--version") { exit(0); }
1132 puts("*** THIS IS JUST DRY RUN ! ***\n");
1135 date(d
); /* this is typical cll1.h macro - prints current date */
1137 /*-----------------------------------------------------------------*/
1138 printf("Parsing configuration file %s ...\n", config
);
1139 /*-----------------------------------------------------------------*/
1144 parse_ip_log(argc
,argv
);
1160 /*-----------------------------------------------------------------*/
1161 puts("Parsing iptables verbose output ...");
1162 /*-----------------------------------------------------------------*/
1163 get_traffic_statistics();
1166 /*-----------------------------------------------------------------*/
1167 printf("Parsing class defintion file %s ...\n", hosts
);
1168 /*-----------------------------------------------------------------*/
1169 int groupidx
= FIRSTGROUPID
;
1174 if(*str
<'0' || *str
>'9')
1176 /* any line starting with non-number is comment ...*/
1180 //Does this IP share QoS class with some other ?
1181 substring
=strstr(str
,"sharing-");
1184 substring
+=8; //"sharing-"
1187 ip
->sharing
=substring
;
1188 ip
->keyword
=defaultkeyword
; /* settings for default keyword */
1189 while(*substring
&& *substring
!='\n')
1197 //Do we have to create new QoS class for this IP ?
1199 if_exists(keyword
,keywords
,(substring
=strstr(str
,keyword
->key
)))
1203 ip
->keyword
=keyword
;
1204 keyword
->ip_count
++;
1205 ip
->prio
=keyword
->default_prio
;
1206 substring
+=strlen(keyword
->key
)+1;
1208 while(*ptr
&& *ptr
!='-')
1215 ip
->max
= ip
->desired
=atoi(ptr
+1);
1217 ip
->min
= atoi(substring
);
1220 printf(" %s: Illegal value of minimum bandwidth 0 kbps, using %d kb/s\n",
1224 if(ip
->max
<= ip
->min
)
1227 ip
->max
= ip
->min
+ip
->keyword
->reserve_min
;
1231 ip
->max
-= ip
->keyword
->reserve_max
;
1237 ip
->mark
=FIRSTIPCLASS
+1+class_count
++;
1239 if_exists(group
,groups
,group
->min
==ip
->min
)
1242 group
->desired
+= ip
->min
;
1243 ip
->group
= group
->id
;
1247 create(group
,Group
);
1248 group
->min
= ip
->min
;
1249 group
->id
= groupidx
++;
1250 ip
->group
= group
->id
;
1252 if(group
->min
<8) group
->min
=8;
1253 /* Warning - this is maybe because of primitive tc namespace, can be fixed */
1254 /* it is because class IDs are derived from min. bandwidth. - xCh */
1255 //if(group->min>MAX_GUARANTED_KBPS) group->min=MAX_GUARANTED_KBPS;
1258 group
->desired
=ip
->min
;
1259 insert(group
,groups
,desc_order_by
,min
);
1269 done
; /* ugly macro end */
1271 /*-----------------------------------------------------------------*/
1272 /* cll1.h - let's allocate brand new character buffer... */
1273 /*-----------------------------------------------------------------*/
1276 /*-----------------------------------------------------------------*/
1277 puts("Resolving shared connections ...");
1278 /*-----------------------------------------------------------------*/
1279 for_each(ip
,ips
) if(ip
->sharing
)
1281 for_each(sharedip
,ips
) if(eq(sharedip
->name
,ip
->sharing
))
1283 sharedip
->traffic
+=ip
->traffic
;
1285 ip
->mark
=sharedip
->mark
;
1286 ip
->lmsid
=sharedip
->lmsid
;
1291 printf("Unresolved shared connection: %s %s sharing-%s\n",
1292 ip
->addr
, ip
->name
, ip
->sharing
);
1296 if(enable_credit
&& just_flush
<9)
1298 /*-----------------------------------------------------------------*/
1299 printf("Parsing credit file %s ...\n", credit
);
1300 /*-----------------------------------------------------------------*/
1303 ptr
=parse_datafile_line(_
);
1306 if_exists(ip
,ips
,eq(ip
->addr
,_
))
1308 sscanf(ptr
,"%Lu",&(ip
->credit
));
1312 done
; /* ugly macro end */
1317 /*-----------------------------------------------------------------*/
1318 puts("Initializing iptables and tc classes ...");
1319 /*-----------------------------------------------------------------*/
1321 iptables_file
=fopen(iptablesfile
,"w");
1322 if(iptables_file
== NULL
)
1324 puts("Cannot open iptablesfile!");
1328 log_file
=fopen(cmdlog
,"w");
1329 if(log_file
== NULL
)
1331 puts("Cannot open logfile!");
1335 save_line(iptablespreamble
);
1338 sprintf(str
,"%s qdisc del dev %s root 2>/dev/null",tc
,lan
);
1341 sprintf(str
,"%s qdisc del dev %s root 2>/dev/null",tc
,wan
);
1344 iptables_file
=fopen(iptablesfile
,"w");
1345 save_line(iptablespreamble
);
1347 if(qos_free_zone
&& *qos_free_zone
!='0')
1351 sprintf(str
,"-A FORWARD -d %s -o %s -j ACCEPT", qos_free_zone
, wan
);
1356 save_line(":post_noproxy - [0:0]");
1357 sprintf(str
,"-A POSTROUTING -p ! tcp -o %s -j post_noproxy", lan
);
1359 sprintf(str
,"-A POSTROUTING -s ! %s -o %s -j post_noproxy", proxy_ip
, lan
);
1361 sprintf(str
,"-A POSTROUTING -s %s -p tcp --sport ! %d -o %s -j post_noproxy", proxy_ip
, proxy_port
, lan
);
1364 chain
="post_noproxy";
1368 chain
="POSTROUTING";
1371 sprintf(str
,"-A %s -s %s -o %s -j ACCEPT", chain
, qos_free_zone
, lan
);
1375 if(ip_count
>idxtable_treshold1
&& !just_flush
)
1377 int idxcount
=0, bitmask
=32-idxtable_bitmask1
; /* default net mask: 255.255.255.240 */
1379 /*-----------------------------------------------------------------*/
1380 printf("Detected %d addresses - indexing iptables rules to improve performance...\n",ip_count
);
1381 /*-----------------------------------------------------------------*/
1383 save_line(":post_common - [0:0]");
1384 save_line(":forw_common - [0:0]");
1386 for_each(ip
,ips
) if(ip
->addr
&& *(ip
->addr
) && !eq(ip
->addr
,"0.0.0.0/0"))
1388 buf
=hash_id(ip
->addr
,bitmask
);
1389 if_exists(idx
,idxs
,eq(idx
->id
,buf
))
1398 idx
->bitmask
=bitmask
;
1406 /* brutal perfomance optimalization */
1407 while(idxcount
>idxtable_treshold2
&& bitmask
>2*idxtable_bitmask2
)
1409 bitmask
-=idxtable_bitmask2
;
1412 for_each(idx
,idxs
) if(idx
->parent
== NULL
)
1414 buf
=hash_id(idx
->addr
,bitmask
);
1415 if_exists(metaindex
,idxs
,eq(metaindex
->id
,buf
))
1417 metaindex
->children
++;
1421 create(metaindex
,Index
);
1422 metaindex
->addr
=idx
->addr
;
1424 metaindex
->bitmask
=bitmask
;
1425 metaindex
->parent
=NULL
;
1426 metaindex
->children
=0;
1428 push(metaindex
,idxs
);
1430 idx
->parent
=metaindex
;
1434 /* this should slightly optimize throughout ... */
1435 sort(idx
,idxs
,desc_order_by
,children
);
1436 sort(idx
,idxs
,order_by
,bitmask
);
1441 subnet
=subnet_id(idx
->addr
,idx
->bitmask
);
1442 printf("%d: %s/%d\n",
1443 ++i
, subnet
, idx
->bitmask
);
1445 sprintf(str
,":post_%s - [0:0]", idx
->id
);
1448 sprintf(str
,":forw_%s - [0:0]", idx
->id
);
1453 string(buf
,strlen(idx
->parent
->id
)+6);
1454 sprintf(buf
,"post_%s",idx
->parent
->id
);
1461 sprintf(str
,"-A %s -d %s/%d -o %s -j post_%s", buf
, subnet
, idx
->bitmask
, lan
, idx
->id
);
1464 sprintf(str
,"-A %s -d %s/%d -o %s -j post_common", buf
, subnet
, idx
->bitmask
, lan
);
1469 string(buf
,strlen(idx
->parent
->id
)+6);
1470 sprintf(buf
,"forw_%s",idx
->parent
->id
);
1477 sprintf(str
,"-A %s -s %s/%d -o %s -j forw_%s", buf
, subnet
, idx
->bitmask
, wan
, idx
->id
);
1480 sprintf(str
,"-A %s -s %s/%d -o %s -j forw_common", buf
, subnet
, idx
->bitmask
, wan
);
1483 printf("Total indexed iptables chains created: %d\n", i
);
1485 sprintf(str
,"-A FORWARD -o %s -j forw_common", wan
);
1488 sprintf(str
,"-A POSTROUTING -o %s -j post_common", lan
);
1496 fclose(iptables_file
);
1501 puts("Just flushed iptables and tc classes - now exiting ...");
1507 if(!dry_run
&& !nodelay
&& qos_free_delay
)
1509 printf("Flushed iptables and tc classes - now sleeping for %d seconds...\n",qos_free_delay
);
1510 sleep(qos_free_delay
);
1513 sprintf(str
,"%s qdisc add dev %s root handle 1: htb r2q %d default 1",
1517 sprintf(str
, "%s class add dev %s parent 1: classid 1:2 htb rate %s ceil %s burst %dk prio %d",
1518 tc
,lan
,lan_medium
,lan_medium
,burst_main
,highest_priority
);
1521 sprintf(str
, "%s class add dev %s parent 1:2 classid 1:1 htb rate %Ldkbit ceil %Ldkbit burst %dk prio %d",
1522 tc
,lan
,line
,line
,burst_main
,highest_priority
);
1525 sprintf(str
,"%s qdisc add dev %s root handle 1: htb r2q %d default 1",tc
,wan
,htb_r2q
);
1528 sprintf(str
, "%s class add dev %s parent 1: classid 1:2 htb rate %s ceil %s burst %dk prio %d",
1529 tc
,wan
,wan_medium
,wan_medium
,burst_main
,highest_priority
);
1532 sprintf(str
, "%s class add dev %s parent 1:2 classid 1:1 htb rate %Ldkbit ceil %Ldkbit burst %dk prio %d",
1533 tc
,wan
,up
,up
,burst_main
,highest_priority
);
1537 /*-----------------------------------------------------------------*/
1538 puts("Locating heavy downloaders and generating root classes ...");
1539 /*-----------------------------------------------------------------*/
1540 sort(ip
,ips
,desc_order_by
,traffic
);
1542 /*-----------------------------------------------------------------*/
1543 /* sub-scope - local variables */
1545 long long int rate
= line
;
1546 long long int max
= line
;
1547 int group_count
= 0;
1548 FILE *credit_file
= NULL
;
1550 if(!just_preview
&& !dry_run
&& enable_credit
)
1552 credit_file
= fopen(credit
,"w");
1555 for_each(group
,groups
)
1560 sprintf(str
,"%s class add dev %s parent 1:%d classid 1:%d htb rate %Ldkbit ceil %Ldkbit burst %dk prio %d #down desired %d",
1561 tc
, lan
, parent
, group
->id
, rate
, max
, burst_group
, highest_priority
+1, group
->desired
);
1565 sprintf(str
,"%s class add dev %s parent 1:%d classid 1:%d htb rate %Ldkbit ceil %Ldkbit burst %dk prio %d #up desired %d",
1566 tc
, wan
, parent
, group
->id
, rate
*up
/line
, max
*up
/line
, burst_group
, highest_priority
+1, group
->desired
);
1570 if(group_count
++ < max_nesting
)
1575 rate
-= digital_divide
*group
->min
;
1576 if(rate
< group
->min
)
1581 /*shaping of aggresive downloaders, with credit file support */
1584 int group_rate
= group
->min
, priority_sequence
= lowest_priority
;
1586 for_each(ip
, ips
) if(ip
->min
== group
->min
&& ip
->max
> ip
->min
)
1588 if( ip
->keyword
->data_limit
&& !ip
->fixedprio
1589 && ( ip
->traffic
>ip
->credit
1590 + (ip
->min
*ip
->keyword
->data_limit
+(ip
->keyword
->fixed_limit
<<20))) )
1592 if(group_rate
<ip
->max
)
1596 group_rate
+=magic_treshold
;
1597 ip
->prio
=lowest_priority
;
1598 if(ip
->prio
<highest_priority
+2)
1600 ip
->prio
=highest_priority
+2;
1605 if( ip
->keyword
->data_prio
1607 && ( ip
->traffic
>ip
->credit
1608 + (ip
->min
*ip
->keyword
->data_prio
+(ip
->keyword
->fixed_prio
<<20))) )
1610 ip
->prio
=priority_sequence
--;
1611 if(ip
->prio
<highest_priority
+1)
1613 ip
->prio
=highest_priority
+1;
1619 unsigned long long lcredit
=0;
1621 if((ip
->min
*ip
->keyword
->data_limit
+(ip
->keyword
->fixed_limit
<<20))>ip
->traffic
)
1623 lcredit
=(ip
->min
*ip
->keyword
->data_limit
+(ip
->keyword
->fixed_limit
<<20))-ip
->traffic
;
1625 fprintf(credit_file
,"%s %Lu\n",ip
->addr
,lcredit
);
1633 fclose(credit_file
);
1641 printf("Reading %s and applying Fair Use Policy rules ... \n", classmap
);
1649 if_exists(ip
,ips
,eq(ip
->addr
,_
))
1652 if(ip
->max
< ip
->desired
) /* apply FUP limit immediately.... */
1654 printf("Applying limit for %-22s %-16s %04d ", ip
->name
, ip
->addr
, ip
->mark
);
1655 printf("(down: %dk-%dk ", ip
->min
, ip
->max
);
1656 sprintf(str
, "%s class change dev %s parent 1:%d classid 1:%d htb rate %dkbit ceil %dkbit burst %dk prio %d",
1657 tc
, lan
, ip
->group
, ip
->mark
,ip
->min
,ip
->max
, burst
, ip
->prio
);
1659 printf("up: %dk-%dk)\n", (int)((ip
->min
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
),
1660 (int)((ip
->max
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
));
1661 sprintf(str
,"%s class change dev %s parent 1:%d classid 1:%d htb rate %dkbit ceil %dkbit burst %dk prio %d",
1662 tc
, wan
, ip
->group
, ip
->mark
,
1663 (int)((ip
->min
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
),
1664 (int)((ip
->max
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
), burst
, ip
->prio
);
1673 puts("Warning - classmap file not fund, just generating preview ...");
1674 start_shaping
=FALSE
;
1676 done
; /* ugly macro end */
1682 if(!dry_run
&& !just_flush
)
1684 /*-----------------------------------------------------------------*/
1685 printf("Writing json overview %s ... ", json
);
1686 /*-----------------------------------------------------------------*/
1695 && (ip
->traffic
|| ip
->direct
|| ip
->proxy
|| ip
->upload
))
1701 fprintf(f
, " \"%s\":{ \"lms\": %d, \"ip\":\"%s\", \"total\":%Lu, \"down\":%Lu, \"proxy\":%Lu, \"up\":%Lu, \"min\":%d, \"max\":%d, \"limit\":%d }",
1702 ip
->name
, ip
->lmsid
, ip
->addr
, ip
->traffic
, ip
->direct
, ip
->proxy
, ip
->upload
, ip
->min
, ip
->desired
, ip
->max
);
1722 /*-----------------------------------------------------------------*/
1723 printf("Sorting data and generating statistics page %s ...\n", html
);
1724 /*-----------------------------------------------------------------*/
1726 if(use_jquery_popups
)
1728 fprintf(f
,"<script type=\"text/javascript\" src=\"%s\"></script>\n", jquery_url
);
1730 fputs("<table class=\"decorated last\">\n\
1731 <caption>Bandwidth classes</caption>\n\
1733 <th style=\"text-align: right\">#</th>\n\
1734 <th style=\"text-align: right\">group</th>\n\
1735 <th style=\"text-align: right\">IPs</th>\n\
1736 <th style=\"text-align: right\">requested</th>\n",f
);
1737 fprintf(f
,"<th colspan=\"%d\">data limits</th>\n", keywordcount
);
1738 fputs("</tr></thead><tbody>\n",f
);
1741 for_each(group
, groups
)
1744 printf("%d kb/s group: %d bandwidth requested: %d kb/s\n",group
->min
,group
->count
,group
->desired
);
1746 fprintf(f
, "%s<td style=\"text-align: right\">%d</td><td style=\"text-align: right\">%d kb/s</td>",
1747 tr_odd_even(), count
, group
->min
);
1748 fprintf(f
, "<td style=\"text-align: right\">%d</td><td style=\"text-align: right\">%d kb/s</td>",
1749 group
->count
, group
->desired
);
1751 for_each(keyword
, keywords
) if(keyword
->ip_count
)
1753 fprintf(f
,"<td style=\"text-align: right\"><span style=\"color:#%s\">%d MB</span></td>",
1754 keyword
->html_color
, group
->min
*keyword
->data_limit
);
1756 i
+= group
->desired
;
1757 total
+= group
->count
;
1761 printf("Total groups: %d Total bandwidth requested: %d kb/s\nAGGREGATION: 1/%d\n",
1764 fprintf(f
,"</tr></tbody>\n\
1766 <th colspan=\"2\" style=\"text-align: left\">Line %Ld kb/s</td>",line
);
1767 fprintf(f
,"<th style=\"text-align: right\">%d</td><th style=\"text-align: right\">%d kb/s</td>",total
,i
);
1769 for_each(keyword
, keywords
) if(keyword
->ip_count
)
1771 fprintf(f
,"<th style=\"text-align: right\">%d IPs</th>",keyword
->ip_count
);
1773 fprintf(f
,"</tr><tr><th colspan=\"4\">Aggregation 1/%d</th>\n", (int)(0.5+i
/line
));
1774 fprintf(f
,"<th colspan=\"%d\">%d traffic classes</th></tr>\n", keywordcount
, total
);
1776 fputs("</thead></table>\n",f
);
1778 else if(!dry_run
&& !just_flush
)
1786 unsigned long long total_traffic
=0, total_direct
=0, total_proxy
=0, total_upload
=0, tmp_sum
=0;
1787 int active_classes
=0;
1789 struct Sum
{unsigned long long l
; int i
; list(Sum
);} *sum
,*sums
=NULL
;
1790 int limit_count
=0, prio_count
=0;
1798 fprintf(f
,"<p><table class=\"decorated last\">\n<caption>%s",title
);
1799 fprintf(f
," (%s)</caption>\n", d
);
1800 fputs("<thead><tr>\n<th colspan=\"3\"> </th>\n",f
);
1801 fputs("<th style=\"text-align: right\">credit</th>\n\
1802 <th style=\"text-align: right\">FUP</th>\n\
1803 <th style=\"text-align: right\">total</th>\n\
1804 <th style=\"text-align: right\">down</th>\n",f
);
1807 fputs("<th style=\"text-align: right\">proxy</th>\n",f
);
1809 fputs("<th style=\"text-align: right\">up</th>\n\
1810 <th style=\"text-align: right\">min</th>\n\
1811 <th style=\"text-align: right\">max</th>\n\
1812 <th style=\"text-align: right\">limit</th>\n\
1815 <th style=\"text-align: right\">#</th>\n\
1816 <th>hostname [+sharing]</th>\n\
1817 <th style=\"text-align: right\">LMS</th>\n\
1818 <th style=\"text-align: right\">MB</th>\n\
1819 <th style=\"text-align: right\">MB</th>\n\
1820 <th style=\"text-align: right\">MB</th>\n\
1821 <th style=\"text-align: right\">MB</th>\n\
1822 <th style=\"text-align: right\">MB</th>\n\
1823 <th style=\"text-align: right\">kb/s</th>\n\
1824 <th style=\"text-align: right\">kb/s</th>\n\
1825 <th style=\"text-align: right\">kb/s</th>\n\
1827 </tr></thead><tbody>\n",f
);
1830 for_each(ip
,ips
) if(!use_jquery_popups
|| !ip
->sharing
)
1832 char *f1
="", *f2
="";
1835 if(ip
->max
< ip
->desired
)
1837 f1
="<span style=\"color:red\">";
1841 else if(ip
->prio
> highest_priority
+1)
1843 f1
="<span style=\"color:brown\">";
1849 printf("%03d. %-22s %10Lu (%d/%d)\n",i
,ip
->name
, ip
->traffic
, ip
->min
, ip
->max
);
1851 /* hostnames -------------------------------------- */
1852 fprintf(f
,"%s<td style=\"text-align: right\"><a name=\"%s\"></a>%d</td><td><a class=\"blue\" target=\"_blank\" href=\"%s%s.log\">%s</a>\n",
1853 tr_odd_even(), ip
->name
, i
, log_url
, ip
->name
, ip
->name
);
1855 if(use_jquery_popups
)
1857 fprintf(f
,"<span id=\"sharing_%d\" style=\"display:none\">",i
);
1859 for_each(sharedip
, ips
) if(eq(ip
->name
, sharedip
->sharing
))
1861 fprintf(f
,"<br /><a class=\"blue\" target=\"_blank\" href=\"%s%s.log\">%s</a>\n", log_url
, sharedip
->name
, sharedip
->name
);
1864 fputs("</span>\n",f
);
1867 fprintf(f
,"<span>[<a class=\"blue\" href=\"#\" onClick=\"$(this).parent().hide();$(\'#sharing_%d\').show();$(\'#download_%d\').show();$(\'#upload_%d\').show();return(false);\" style=\"cursor: pointer;\">+%d</a>]</span>",
1868 i
, i
, i
, popup_button
);
1872 /* ----------------------------------------------- */
1876 fputs("<td style=\"text-align: right\">",f
);
1879 fprintf(f
,"<a class=\"blue\" target=\"_blank\" href=\"%s%d\">%04d</a>\n", lms_url
, ip
->lmsid
, ip
->lmsid
);
1881 else if(ip
->lmsid
== 0)
1887 fprintf(f
,"<td style=\"text-align: right\">%Lu</td>\n", ip
->credit
);
1888 fprintf(f
,"<td style=\"text-align: right\"><span style=\"color:#%s\">%Lu</span></td>",
1889 ip
->keyword
->html_color
,
1890 ip
->credit
+(ip
->min
*ip
->keyword
->data_limit
+(ip
->keyword
->fixed_limit
<<20)));
1891 fprintf(f
,"<td style=\"text-align: right\">%s%Lu%s", f1
, ip
->traffic
, f2
);
1893 /* download --------------------------------------- */
1894 fprintf(f
,"</td><td style=\"text-align: right\">%Lu", ip
->direct
);
1895 if(use_jquery_popups
)
1897 fprintf(f
,"<span id=\"download_%d\" style=\"display:none\">",i
);
1898 for_each(sharedip
, ips
) if(eq(ip
->name
, sharedip
->sharing
))
1900 fprintf(f
,"<br />%Lu", sharedip
->direct
);
1902 fputs("</span>\n",f
);
1905 /* ----------------------------------------------- */
1909 fprintf(f
,"<td style=\"text-align: right\">%Lu</td>\n", ip
->proxy
);
1911 /* upload ---------------------------------------- */
1912 fprintf(f
,"<td style=\"text-align: right\">%Lu", ip
->upload
);
1913 if(use_jquery_popups
)
1915 fprintf(f
,"<span id=\"upload_%d\" style=\"display:none\">",i
);
1916 for_each(sharedip
,ips
) if(eq(ip
->name
, sharedip
->sharing
))
1918 fprintf(f
,"<br />%Lu", sharedip
->upload
);
1920 fputs("</span>\n",f
);
1923 /* ----------------------------------------------- */
1925 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1926 <td style=\"text-align: right\">%d</td>\n\
1927 <td style=\"text-align: right\">%s%d%s</td>\n\
1928 <td>%s%d%s</td></tr>\n",
1929 ip
->min
, ip
->desired
,
1933 total_traffic
+=ip
->traffic
;
1934 total_direct
+=ip
->direct
;
1935 total_proxy
+=ip
->proxy
;
1936 total_upload
+=ip
->upload
;
1940 tmp_sum
+=ip
->traffic
;
1943 sum
->i
=active_classes
;
1944 insert(sum
,sums
,order_by
,i
);
1950 for_each(sharedip
,ips
) if(eq(ip
->name
, sharedip
->sharing
))
1952 append_log(sharedip
);
1956 fprintf(f
,"</tbody><thead><tr>\n\
1957 <th colspan=\"%d\" style=\"text-align: left\">%d CLASSES</th>", colspan
-7, i
);
1958 fprintf(f
,"<th style=\"text-align: right\">%Lu</th><th style=\"text-align: right\">%Lu</th>\n", total_traffic
, total_direct
);
1961 fprintf(f
,"<th style=\"text-align: right\">%Lu</th>\n", total_proxy
);
1963 fprintf(f
,"<th style=\"text-align: right\">%Lu</th>", total_upload
);
1964 fprintf(f
,"<th colspan=\"4\"><span style=\"color:red\">LIMIT %dx</span> <span style=\"color:brown\">LOW-PRIO %dx</span></th></tr>\n</thead></table>\n",limit_count
,prio_count
);
1967 if(active_classes
>10)
1969 int top20_count
=0,top20_perc1
=0;
1970 long long top20_perc2
=0;
1971 unsigned long long top20_sum
=0l;
1973 fputs("<a name=\"erp\"></a><p><table class=\"decorated last\"><caption>Enterprise Resource Planning (ERP)</caption>\n",f
);
1974 fputs("<thead><tr>\n\
1975 <th>Analytic category</th>\n\
1976 <th colspan=\"2\" style=\"text-align: center\">Active Classes</th>\n\
1977 <th colspan=\"2\" style=\"text-align: center\">Data transfers</th>\n\
1978 </tr></thead><tbody>\n",f
);
1980 if_exists(sum
,sums
,sum
->l
>=total_traffic
/4)
1982 fprintf(f
,"%s<td>Top 25%% of traffic</td>\n", tr_odd_even());
1983 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1984 <td style=\"text-align: right\">%d %%</td>\n\
1985 <td style=\"text-align: right\">%Lu MB</td>\n\
1986 <td style=\"text-align: right\">%Ld %%</td></tr>\n",
1987 sum
->i
, (100*sum
->i
+50)/active_classes
, sum
->l
, (100*sum
->l
+50)/total_traffic
);
1990 if_exists(sum
,sums
,sum
->i
==10)
1992 fprintf(f
,"%s<td>Top 10 downloaders</td>\n", tr_odd_even());
1993 fprintf(f
,"<td style=\"text-align: right\"><strong>10</strong></td>\n\
1994 <td style=\"text-align: right\">%d %%</td>\n\
1995 <td style=\"text-align: right\">%Lu MB</td>\n\
1996 <td style=\"text-align: right\">%Ld %%</td></tr>\n",
1997 (100*sum
->i
+50)/active_classes
, sum
->l
, (100*sum
->l
+50)/total_traffic
);
2000 if_exists(sum
,sums
,sum
->l
>=total_traffic
/2)
2002 fprintf(f
,"%s<td>Top 50%% of traffic</td>\n", tr_odd_even());
2003 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
2004 <td style=\"text-align: right\">%d %%</td>\n\
2005 <td style=\"text-align: right\">%Lu MB</td>\n\
2006 <td style=\"text-align: right\"><strong>%Ld %%</strong></td></tr>\n",
2007 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
2010 if_exists(sum
,sums
,sum
->l
>=4*total_traffic
/5)
2012 fprintf(f
,"%s<td>Top 80%% of traffic</td>\n", tr_odd_even());
2013 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
2014 <td style=\"text-align: right\">%d %%</td>\n\
2015 <td style=\"text-align: right\">%Lu MB</td>\n\
2016 <td style=\"text-align: right\"><strong>%Ld %%</strong></td></tr>\n",
2017 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
2020 if_exists(sum
,sums
,sum
->i
>=(active_classes
+1)/5)
2022 fprintf(f
,"%s<td>Top 20%% downloaders</td>\n", tr_odd_even());
2024 top20_perc1
=(100*sum
->i
+50)/active_classes
;
2026 top20_perc2
=(100*sum
->l
+50)/total_traffic
;
2027 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
2028 <td style=\"text-align: right\"><strong>%d %%</strong></td>\n\
2029 <td style=\"text-align: right\">%Lu MB</td>\n\
2030 <td style=\"text-align: right\">%Ld %%</td></tr>\n",
2031 top20_count
,top20_perc1
,top20_sum
,top20_perc2
);
2034 if_exists(sum
,sums
,sum
->i
>=(active_classes
+1)/4)
2036 fprintf(f
,"%s<td>Top 25%% downloaders</td>\n", tr_odd_even());
2037 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
2038 <td style=\"text-align: right\">%d %%</td>\n\
2039 <td style=\"text-align: right\">%Lu MB</td>\n\
2040 <td style=\"text-align: right\">%Ld %%</td></tr>\n",
2041 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
2044 if_exists(sum
,sums
,sum
->i
>=(active_classes
+1)/2)
2046 fprintf(f
,"%s<td>Top 50%% downloaders</td>\n", tr_odd_even());
2047 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
2048 <td style=\"text-align: right\"><strong>%d %%</strong></td>\n\
2049 <td style=\"text-align: right\">%Lu MB</td>\n\
2050 <td style=\"text-align: right\">%Ld %%</td></tr>\n",
2051 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
2054 if_exists(sum
,sums
,sum
->i
>=4*(active_classes
+1)/5)
2056 fprintf(f
,"%s<td>Top 80%% downloaders</td>\n", tr_odd_even());
2057 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
2058 <td style=\"text-align: right\">%d %%</td>\n\
2059 <td style=\"text-align: right\">%Lu MB</td>\n\
2060 <td style=\"text-align: right\">%Ld %%</td></tr></tbody>\n",
2061 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
2064 fprintf(f
,"<thead><tr><th><a class=\"blue\" target=\"_blank\" href=\"%sERP.log\">All users, all traffic</a></th>\n", log_url
);
2065 fprintf(f
,"<th style=\"text-align: right\">%d</th>\n\
2066 <th style=\"text-align: right\">100 %%</th>\n\
2067 <th style=\"text-align: right\">%Lu MB</th>\n\
2068 <th style=\"text-align: right\">100 %%</th></tr>\n",active_classes
,total_traffic
);
2069 fputs("</thead></table>\n", f
);
2071 /* write basic ERP data to log directory */
2075 sprintf(str
,"%s/ERP.log",log_dir
);
2076 iplog
=fopen(str
,"a");
2079 fprintf(iplog
,"%ld\t%d\t%d %%\t%Lu M\t%Ld %%\tACTIVE %d\tTRAFFIC %Lu M\tCLASSES %d\tFUP-LIMIT %d\tLOW-PRIO %d\t%s",
2080 time(NULL
), top20_count
, top20_perc1
, top20_sum
, top20_perc2
,
2081 active_classes
, total_traffic
, i
, limit_count
, prio_count
, d
); /* d = date*/
2091 fprintf(f
, stats_html_signature
, version
);
2102 printf("Statistics preview generated (-%c switch) - now exiting ...\n", swchar
);
2108 printf("%-22s %-15s mark\n","name","ip");
2111 printf("Writing %s ... ", classmap
);
2112 f
= fopen(classmap
, "w");
2118 /*-----------------------------------------------------------------*/
2119 puts("Generating iptables and tc classes ... ");
2120 /*-----------------------------------------------------------------*/
2122 for_each(ip
, ips
) if(ip
->mark
> 0)
2127 duplicate(ip
->addr
,buf
);
2128 buf
=hash_id(ip
->addr
,32-idxtable_bitmask1
);
2130 string(chain_forward
,6+strlen(buf
));
2131 strcpy(chain_forward
,"forw_");
2132 strcat(chain_forward
,buf
);
2134 string(chain_postrouting
,6+strlen(buf
));
2135 strcpy(chain_postrouting
,"post_");
2136 strcat(chain_postrouting
,buf
);
2142 chain_forward
="FORWARD";
2143 chain_postrouting
="POSTROUTING";
2147 printf("%-22s %-16s %04d ", ip
->name
, ip
->addr
, ip
->mark
);
2150 /* -------------------------------------------------------- mark download */
2152 sprintf(str
, "-A %s -d %s/32 -o %s -j %s%d",
2153 chain_postrouting
, ip
->addr
, lan
, mark_iptables
, ip
->mark
);
2154 /*sprintf(str,"-A %s -d %s/32 -o %s -j MARK --set-mark %d",chain_postrouting,ip->addr,lan,ip->mark);*/
2155 /* -m limit --limit 1/s */
2160 sprintf(str
, "-A %s -s %s -p tcp --sport %d -d %s/32 -o %s -j %s%d",
2161 chain_postrouting
, proxy_ip
, proxy_port
, ip
->addr
, lan
, mark_iptables
, ip
->mark
);
2162 /*sprintf(str,"-A %s -s %s -p tcp --sport %d -d %s/32 -o %s -j MARK --set-mark %d",chain_postrouting,proxy_ip,proxy_port,ip->addr,lan,ip->mark);*/
2166 sprintf(str
, "-A %s -d %s/32 -o %s -j ACCEPT",
2167 chain_postrouting
, ip
->addr
, lan
);
2170 /* -------------------------------------------------------- mark upload */
2171 sprintf(str
, "-A %s -s %s/32 -o %s -j %s%d",
2172 chain_forward
, ip
->addr
, wan
, mark_iptables
, ip
->mark
);
2173 /* sprintf(str,"-A %s -s %s/32 -o %s -j MARK --set-mark %d",chain_forward,ip->addr,wan,ip->mark);*/
2176 sprintf(str
, "-A %s -s %s/32 -o %s -j ACCEPT",
2177 chain_forward
, ip
->addr
, wan
);
2182 /* -------------------------------------------------------- download class */
2184 printf("(down: %dk-%dk ", ip
->min
, ip
->max
);
2187 sprintf(str
, "%s class add dev %s parent 1:%d classid 1:%d htb rate %dkbit ceil %dkbit burst %dk prio %d",
2188 tc
, lan
, ip
->group
, ip
->mark
,ip
->min
,ip
->max
, burst
, ip
->prio
);
2191 if(strcmpi(ip
->keyword
->leaf_discipline
, "none"))
2193 sprintf(str
, "%s qdisc add dev %s parent 1:%d handle %d %s",
2194 tc
, lan
, ip
->mark
, ip
->mark
, ip
->keyword
->leaf_discipline
); /*qos_leaf*/
2198 if(filter_type
== 1)
2200 sprintf(str
, "%s filter add dev %s parent 1:0 protocol ip handle %d fw flowid 1:%d",
2201 tc
, lan
, ip
->mark
, ip
->mark
);
2205 /* -------------------------------------------------------- upload class */
2207 printf("up: %dk-%dk)\n", (int)((ip
->min
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
),
2208 (int)((ip
->max
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
));
2211 sprintf(str
,"%s class add dev %s parent 1:%d classid 1:%d htb rate %dkbit ceil %dkbit burst %dk prio %d",
2212 tc
, wan
, ip
->group
, ip
->mark
,
2213 (int)((ip
->min
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
),
2214 (int)((ip
->max
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
), burst
, ip
->prio
);
2217 if(strcmpi(ip
->keyword
->leaf_discipline
, "none"))
2219 sprintf(str
, "%s qdisc add dev %s parent 1:%d handle %d %s",
2220 tc
, wan
, ip
->mark
, ip
->mark
, ip
->keyword
->leaf_discipline
); /*qos_leaf*/
2224 if(filter_type
== 1)
2226 sprintf(str
, "%s filter add dev %s parent 1:0 protocol ip handle %d fw flowid 1:%d",
2227 tc
, wan
, ip
->mark
, ip
->mark
);
2233 fprintf(f
, "%s %d\n", ip
->addr
, ip
->mark
);
2239 printf("(sharing %s)\n", ip
->sharing
);
2252 chain_forward
= "forw_common";
2253 chain_postrouting
= "post_common";
2257 chain_forward
= "FORWARD";
2258 chain_postrouting
= "POSTROUTING";
2260 /* -------------------------------- classify or reject free download */
2262 char *final_chain
= "DROP"; /* REJECT would be better, but it is impossible in mangle */
2265 final_chain
= "ACCEPT";
2271 sprintf(str
,"-A %s -s %s -p tcp --sport %d -o %s -j %s%d",
2272 chain_postrouting
,proxy_ip
,proxy_port
,lan
,mark_iptables
,3);
2275 sprintf(str
,"-A %s -s %s -p tcp --sport %d -o %s -j %s",
2276 chain_postrouting
,proxy_ip
,proxy_port
,lan
,final_chain
);
2281 sprintf(str
,"-A %s -o %s -j %s%d", chain_postrouting
, lan
, mark_iptables
, 3);
2284 sprintf(str
,"-A %s -o %s -j %s", chain_postrouting
, lan
, final_chain
);
2286 /* ------------------------------- classify or reject free upload */
2289 sprintf(str
,"-A %s -o %s -j %s%d", chain_forward
, wan
, mark_iptables
, 3);
2292 sprintf(str
,"-A %s -o %s -j %s", chain_forward
, wan
, final_chain
);
2296 if(free_min
) /* allocate free bandwith if it is not zero... */
2298 /*-----------------------------------------------------------------*/
2299 puts("Generating free bandwith classes ...");
2300 /*-----------------------------------------------------------------*/
2301 sprintf(str
, "%s class add dev %s parent 1:%d classid 1:3 htb rate %dkbit ceil %dkbit burst %dk prio %d",
2302 tc
, lan
, parent
, free_min
, free_max
,burst
, lowest_priority
);
2304 sprintf(str
, "%s class add dev %s parent 1:%d classid 1:3 htb rate %dkbit ceil %dkbit burst %dk prio %d",
2305 tc
, wan
, parent
, free_min
, free_max
, burst
, lowest_priority
);
2308 if(strcmpi(qos_leaf
, "none"))
2310 sprintf(str
,"%s qdisc add dev %s parent 1:3 handle 3 %s", tc
, lan
, qos_leaf
);
2313 sprintf(str
,"%s qdisc add dev %s parent 1:3 handle 3 %s", tc
, wan
, qos_leaf
);
2316 /* tc handle 1 fw flowid */
2317 sprintf(str
,"%s filter add dev %s parent 1:0 protocol ip handle 3 fw flowid 1:3", tc
, lan
);
2320 sprintf(str
,"%s filter add dev %s parent 1:0 protocol ip handle 3 fw flowid 1:3", tc
, wan
);
2323 printf("Total IP count: %d\n", i
);
2330 /* that's all folks, thank you for reading it all the way up to this point ;-) */
2331 /* bad luck C<<1 is not yet finished, I promise no sprintf() next time... */
This page took 1.737887 seconds and 4 git commands to generate.