59e2759d421023f2219a156c6993a5f1619cd215
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-2008 Michael Polak (xChaos) */
6 /* iptables-restore support Copyright(C) 2007-2008 ludva */
7 /* Credit: CZFree.Net,Martin Devera,Netdave,Aquarius,Gandalf */
8 /* - - - - - - - - - - - - - - - - - - - - - - - - - - - - - */
10 /* Modified by: xChaos, 20120516
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-d";
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 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 */
61 char *json
= "/var/www/traffic.json"; /* hall of fame - json version */
62 char *cmdlog
= "/var/log/prometheuslog"; /* command log filename */
63 char *log_dir
= "/var/www/logs/"; /* log directory pathname, ended with slash */
64 char *log_url
= "/logs/"; /* log directory relative URI prefix (partial URL) */
65 char *html_log_dir
= "/var/www/logs/html/";
67 char *jquery_url
= "http://code.jquery.com/jquery-latest.js";
68 char *lms_url
= "/lms/?m=customerinfo&id=";
69 int use_jquery_popups
= 1;
70 int row_odd_even
= 0; /*<tr class="odd/even"> */
73 const char *tr_odd_even(void)
75 row_odd_even
= 1 - row_odd_even
;
78 return "<tr class=\"even\">\n";
82 return "<tr class=\"odd\">\n";
86 /* ======= Help screen is hopefuly self-documenting part of code :-) ======= */
90 puts("Command line switches:\n\
92 -?, --help this help screen\n\
93 -v, --version show Version number of this utility and exit\n\
94 -c filename force alternative /etc/prometheus.Conf filename\n\
95 -h filename force alternative /etc/Hosts filename (overrides hosts keyword)\n\
96 -f just Flush iptables and tc classes and exit (stop shaping)\n\
97 -9 emergency iptables flush (do not read data transfer statistics)\n\
98 -p just generate Preview of data transfer statistics and exit\n\
99 -d Dry run (preview tc and iptables commands on stdout)\n\
100 -r Run (reset all statistics and start shaping)\n\
101 -n run Now (start shaping without delay - overrides qos-free-delay keyword)\n\
102 -l Mmm YYYY generate HTML summary of traffic Logs (Mmm=Jan-Dec or Year, YYYY=year)\n\
103 -m generate HTML summary of traffic logs for yesterday's Month\n\
104 -y generate HTML summary of traffic logs for yesterday's Year\n");
105 /* not yet implemented:
106 -s start shaping! (keep data transfer statistics - but apply shaping)\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("log-filename",cmdlog
);
444 option("credit-filename",credit
);
445 option("classmap-filename",classmap
);
446 ioption("credit-enable",enable_credit
);
447 option("log-traffic-directory",log_dir
);
448 option("log-traffic-html-directory",html_log_dir
);
449 option("log-traffic-url-path",log_url
);
450 option("jquery-url",jquery_url
);
451 option("lms-url",lms_url
);
452 ioption("use-jquery-popups",use_jquery_popups
);
453 option("qos-free-zone",qos_free_zone
);
454 ioption("qos-free-delay",qos_free_delay
);
455 ioption("qos-proxy-enable",qos_proxy
);
456 option("qos-proxy-ip",proxy_ip
);
457 option("htb-leaf-discipline",qos_leaf
);
458 ioption("qos-proxy-port",proxy_port
);
459 ioption("free-rate",free_min
);
460 ioption("free-ceil",free_max
);
461 ioption("htb-burst",burst
);
462 ioption("htb-burst-main",burst_main
);
463 ioption("htb-burst-group",burst_group
);
464 ioption("htb-nesting-limit",max_nesting
);
465 ioption("htb-r2q",htb_r2q
);
466 ioption("magic-include-upload",include_upload
);
467 ioption("magic-treshold",magic_treshold
);
468 option("filter-type", cnf
);
469 /* not yet implemented:
470 ioption("magic-fixed-packets",fixed_packets);
471 ioption("magic-relative-packets",packet_limit);
476 perror(config_filename
);
477 puts("Warning - using built-in defaults instead ...");
482 /* leaf discipline for keywords */
483 for_each(keyword
,keywords
)
485 if(!strcmpi(keyword
->leaf_discipline
, ""))
487 keyword
->leaf_discipline
= qos_leaf
;
491 if(strcmpi(cnf
, "mark"))
495 mark_iptables
= "CLASSIFY --set-class 1:";
501 mark_iptables
= "MARK --set-mark ";
504 /* are supplied values meaningful ?*/
507 puts("Illegal value of LAN or WAN bandwidth: 0 kbps.");
508 reject_config_and_exit(config_filename
);
512 /* ===================== traffic analyser - uses iptables ================ */
514 void get_traffic_statistics(void)
519 textfile(Pipe
,str
) *line
,*lines
=NULL
;
523 sprintf(cmd
,"%s -L -v -x -n -t mangle",iptables
);
535 int col
, accept
=0,proxyflag
=0,valid
=1,setchainname
=0,commonflag
=0;
536 unsigned long long traffic
=0;
537 unsigned long pkts
=0;
538 char *ipaddr
=NULL
,*ptr
;
540 /* debug puts(line->str); */
541 valid_columns(ptr
,line
->str
,' ',col
)
542 if(valid
) switch(col
)
544 case 1: if(eq(ptr
,"Chain"))
548 else if(eq(ptr
,"pkts"))
554 sscanf(ptr
,"%lu",&pkts
);
557 case 2: if(setchainname
)
559 if(!strncmp(ptr
,"post_",5) || eq(ptr
,"POSTROUTING"))
565 if(!strncmp(ptr
,"forw_",5) || eq(ptr
,"FORWARD"))
570 if(eq(ptr
,"post_common") || eq(ptr
,"forw_common"))
577 sscanf(ptr
,"%Lu",&traffic
);
582 case 3: if((strncmp(ptr
,"post_",5) && strncmp(ptr
,"forw_",5)) || commonflag
)
586 /*if(filter_type==1) accept=eq(ptr,"MARK"); else accept=eq(ptr,"CLASSIFY");*/
588 case 8: if(downloadflag
)
590 if(strstr(proxy_ip
,ptr
))
600 case 9: if(downloadflag
)ipaddr
=ptr
;break;
603 if(accept
&& traffic
>0 && ipaddr
)
609 else if(!downloadflag
)
613 printf("IP %s: %Lu M (%ld pkts)\n", ipaddr
, traffic
, pkts
);
615 if_exists(ip
,ips
,eq(ip
->addr
,ipaddr
));
620 if(eq(ip
->addr
,"0.0.0.0/0"))
622 ip
->name
="(unregistered)";
624 ip
->max
=ip
->desired
=free_max
;
636 ip
->traffic
+=traffic
;
638 ip
->direct
=ip
->traffic
-ip
->upload
-ip
->proxy
;
647 ip
->traffic
+=traffic
;
651 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
);
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
;
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\" 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\" 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 <td colspan=\"4\" style=\"text-align: left\">Total:</td>\
944 <td style=\"text-align: right\"><strong>%ld GB</strong></td>\
945 <td style=\"text-align: right\"><strong>%Ld kb/s</strong></td></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><td style=\"text-align: right\">%d %%</td><td style=\"text-align: right\">%ld G</td><td style=\"text-align: right\">%d %%</td></tr>\n",iplog
->i
,(100*iplog
->i
+50)/i
,iplog
->l
,(int)((100*iplog
->l
+50)/total
));
965 if_exists(iplog
,iplogs
,iplog
->i
==10)
967 fprintf(f
,"%s<td>Top 10 downloaders</td>\n", tr_odd_even());
968 fprintf(f
,"<td style=\"text-align: right\"><strong>10</strong></td>\n\
969 <td style=\"text-align: right\">%d %%</td>\n\
970 <td style=\"text-align: right\">%ld G</td>\n\
971 <td style=\"text-align: right\">%d %%</td></tr>\n",
972 (100*iplog
->i
+50)/i
,iplog
->l
,(int)((100*iplog
->l
+50)/total
));
975 if_exists(iplog
,iplogs
,iplog
->l
>=total
/2)
977 fprintf(f
,"%s<td>Top 50%% of traffic</td>\n", tr_odd_even());
978 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
979 <td style=\"text-align: right\">%d %%</td>\n\
980 <td style=\"text-align: right\">%ld G</td>\n\
981 <td style=\"text-align: right\"><strong>%d %%</strong></td></tr>\n",
982 iplog
->i
,(100*iplog
->i
+50)/i
,iplog
->l
,(int)((100*iplog
->l
+50)/total
));
985 if_exists(iplog
,iplogs
,iplog
->l
>=4*total
/5)
987 fprintf(f
,"%s<td>Top 80%% of traffic</td>\n",tr_odd_even());
988 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
989 <td style=\"text-align: right\">%d %%</td>\n\
990 <td style=\"text-align: right\">%ld G</td>\n\
991 <td style=\"text-align: right\"><strong>%d %%</strong></td></tr>\n",
992 iplog
->i
,(100*iplog
->i
+50)/i
,iplog
->l
,(int)((100*iplog
->l
+50)/total
));
995 if_exists (iplog
,iplogs
,iplog
->i
>=i
/5)
997 fprintf(f
,"%s<td>Top 20%% downloaders</td>\n",tr_odd_even());
998 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
999 <td style=\"text-align: right\"><strong>%d %%</strong></td>\n\
1000 <td style=\"text-align: right\">%ld G</td>\n\
1001 <td style=\"text-align: right\">%d %%</td></tr>\n",
1002 iplog
->i
,(100*iplog
->i
+50)/i
,iplog
->l
,(int)((100*iplog
->l
+50)/total
));
1005 if_exists(iplog
,iplogs
,iplog
->i
>=i
/4)
1007 fprintf(f
,"%s<td>Top 25%% downloaders</td>\n", tr_odd_even());
1008 fprintf(f
,"<td style=\"text-align: right\">%d</td><td style=\"text-align: right\">%d %%</td><td style=\"text-align: right\">%ld G</td><td style=\"text-align: right\">%d %%</td></tr>\n",iplog
->i
,(100*iplog
->i
+50)/i
,iplog
->l
,(int)((100*iplog
->l
+50)/total
));
1011 if_exists(iplog
,iplogs
,iplog
->i
>=i
/2)
1013 fprintf(f
,"%s<td>Top 50%% downloaders</td>\n",tr_odd_even());
1014 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1015 <td style=\"text-align: right\"><strong>%d %%</strong></td>\n\
1016 <td style=\"text-align: right\">%ld G</td><td style=\"text-align: right\">%d %%</td></tr>\n",iplog
->i
,(100*iplog
->i
+50)/i
,iplog
->l
,(int)((100*iplog
->l
+50)/total
));
1019 if_exists(iplog
,iplogs
,iplog
->i
>=4*i
/5)
1021 fprintf(f
,"%s<td>Top 80%% downloaders</td>\n",tr_odd_even());
1022 fprintf(f
,"<td style=\"text-align: right\">%d</td><td style=\"text-align: right\">%d %%</td><td style=\"text-align: right\">%ld G</td><td style=\"text-align: right\">%d %%</td></tr>\n",iplog
->i
,(100*iplog
->i
+50)/i
,iplog
->l
,(int)((100*iplog
->l
+50)/total
));
1025 fprintf(f
,"</tbody><thead><tr>\n\
1026 <th>All users, all traffic</th>\n\
1027 <th style=\"text-align: right\">%d</th>\n\
1028 <th style=\"text-align: right\">100 %%</th>\n\
1029 <th style=\"text-align: right\">%ld G</th>\n\
1030 <th style=\"text-align: right\">100 %%</th></tr>\n",i
-1,total
);
1031 fputs("</thead></table>\n", f
);
1034 fprintf(f
, stats_html_signature
, version
);
1044 void append_log(struct IP
*self
) /*using global variables*/
1049 date(d
); /* this is typical cll1.h macro - prints current date */
1051 sprintf(str
,"%s/%s.log", log_dir
, self
->name
);
1055 fprintf(f
,"%ld\t%s\t%Lu\t%Lu\t%Lu\t%Lu\t%d\t%d\t%d\t%d\t%s",
1056 time(NULL
), self
->name
, self
->traffic
, self
->direct
, self
->proxy
,
1057 self
->upload
, self
->min
, self
->max
, self
->desired
, self
->lmsid
, d
); /* d = date*/
1067 /*-----------------------------------------------------------------*/
1068 /* Are you looking for int main(int argc, char **argv) ? :-)) */
1069 /*-----------------------------------------------------------------*/
1075 char *str
, *ptr
, *d
;
1077 int class_count
=0,ip_count
=0;
1079 int just_flush
=FALSE
;
1081 int just_preview
=FALSE
; /* preview - generate just stats */
1082 int just_logs
=FALSE
; /* just parse logs */
1086 char *chain_forward
, *chain_postrouting
;
1087 char *althosts
=NULL
;
1090 Prometheus QoS - \"fair-per-IP\" Quality of Service setup utility.\n\
1091 Version %s - Copyright (C)2005-2012 Michael Polak (xChaos)\n\
1092 iptables-restore & burst tunning & classify modification by Ludva\n\
1093 Credit: CZFree.Net, Martin Devera, Netdave, Aquarius, Gandalf\n\n",version
);
1095 /*----- Boring... we have to check command line options first: ----*/
1099 argument("-c") { nextargument(config
); }
1100 argument("-h") { nextargument(althosts
);}
1101 argument("-d") { run
=TRUE
; dry_run
=TRUE
; }
1102 argument("-f") { run
=TRUE
; just_flush
=TRUE
; }
1103 argument("-9") { run
=TRUE
; just_flush
=9; }
1104 argument("-p") { run
=TRUE
; just_preview
=TRUE
; }
1105 argument("-r") { run
=TRUE
; }
1106 argument("-n") { run
=TRUE
; nodelay
=TRUE
; }
1107 argument("-l") { just_logs
=TRUE
; }
1108 argument("-m") { just_logs
=TRUE
; }
1109 argument("-y") { just_logs
=TRUE
; }
1110 argument("-?") { help(); exit(0); }
1111 argument("--help") { help(); exit(0); }
1112 argument("-v") { exit(0); }
1113 argument("--version") { exit(0); }
1118 puts("*** THIS IS JUST DRY RUN ! ***\n");
1121 date(d
); /* this is typical cll1.h macro - prints current date */
1123 /*-----------------------------------------------------------------*/
1124 printf("Parsing configuration file %s ...\n", config
);
1125 /*-----------------------------------------------------------------*/
1130 parse_ip_log(argc
,argv
);
1146 /*-----------------------------------------------------------------*/
1147 puts("Parsing iptables verbose output ...");
1148 /*-----------------------------------------------------------------*/
1149 get_traffic_statistics();
1152 /*-----------------------------------------------------------------*/
1153 printf("Parsing class defintion file %s ...\n", hosts
);
1154 /*-----------------------------------------------------------------*/
1155 int groupidx
= FIRSTGROUPID
;
1160 if(*str
<'0' || *str
>'9')
1162 /* any line starting with non-number is comment ...*/
1166 //Does this IP share QoS class with some other ?
1167 substring
=strstr(str
,"sharing-");
1170 substring
+=8; //"sharing-"
1173 ip
->sharing
=substring
;
1174 ip
->keyword
=defaultkeyword
; /* settings for default keyword */
1175 while(*substring
&& *substring
!='\n')
1183 //Do we have to create new QoS class for this IP ?
1185 if_exists(keyword
,keywords
,(substring
=strstr(str
,keyword
->key
)))
1189 ip
->keyword
=keyword
;
1190 keyword
->ip_count
++;
1191 ip
->prio
=keyword
->default_prio
;
1192 substring
+=strlen(keyword
->key
)+1;
1194 while(*ptr
&& *ptr
!='-')
1201 ip
->max
= ip
->desired
=atoi(ptr
+1);
1203 ip
->min
= atoi(substring
);
1206 printf(" %s: Illegal value of minimum bandwidth 0 kbps, using %d kb/s\n",
1210 if(ip
->max
<= ip
->min
)
1213 ip
->max
= ip
->min
+ip
->keyword
->reserve_min
;
1217 ip
->max
-= ip
->keyword
->reserve_max
;
1223 ip
->mark
=FIRSTIPCLASS
+1+class_count
++;
1225 if_exists(group
,groups
,group
->min
==ip
->min
)
1228 group
->desired
+= ip
->min
;
1229 ip
->group
= group
->id
;
1233 create(group
,Group
);
1234 group
->min
= ip
->min
;
1235 group
->id
= groupidx
++;
1236 ip
->group
= group
->id
;
1238 if(group
->min
<8) group
->min
=8;
1239 /* Warning - this is maybe because of primitive tc namespace, can be fixed */
1240 /* it is because class IDs are derived from min. bandwidth. - xCh */
1241 //if(group->min>MAX_GUARANTED_KBPS) group->min=MAX_GUARANTED_KBPS;
1244 group
->desired
=ip
->min
;
1245 insert(group
,groups
,desc_order_by
,min
);
1257 /*-----------------------------------------------------------------*/
1258 /* cll1.h - let's allocate brand new character buffer... */
1259 /*-----------------------------------------------------------------*/
1262 /*-----------------------------------------------------------------*/
1263 puts("Resolving shared connections ...");
1264 /*-----------------------------------------------------------------*/
1265 for_each(ip
,ips
) if(ip
->sharing
)
1267 for_each(sharedip
,ips
) if(eq(sharedip
->name
,ip
->sharing
))
1269 sharedip
->traffic
+=ip
->traffic
;
1271 ip
->mark
=sharedip
->mark
;
1272 ip
->lmsid
=sharedip
->lmsid
;
1277 printf("Unresolved shared connection: %s %s sharing-%s\n",
1278 ip
->addr
, ip
->name
, ip
->sharing
);
1282 if(enable_credit
&& just_flush
<9)
1284 /*-----------------------------------------------------------------*/
1285 printf("Parsing credit file %s ...\n", credit
);
1286 /*-----------------------------------------------------------------*/
1289 ptr
=parse_datafile_line(_
);
1292 if_exists(ip
,ips
,eq(ip
->addr
,_
))
1294 sscanf(ptr
,"%Lu",&(ip
->credit
));
1303 /*-----------------------------------------------------------------*/
1304 puts("Initializing iptables and tc classes ...");
1305 /*-----------------------------------------------------------------*/
1307 iptables_file
=fopen(iptablesfile
,"w");
1308 if(iptables_file
== NULL
)
1310 puts("Cannot open iptablesfile!");
1314 log_file
=fopen(cmdlog
,"w");
1315 if(log_file
== NULL
)
1317 puts("Cannot open logfile!");
1321 save_line(iptablespreamble
);
1324 sprintf(str
,"%s qdisc del dev %s root 2>/dev/null",tc
,lan
);
1327 sprintf(str
,"%s qdisc del dev %s root 2>/dev/null",tc
,wan
);
1330 iptables_file
=fopen(iptablesfile
,"w");
1331 save_line(iptablespreamble
);
1333 if(qos_free_zone
&& *qos_free_zone
!='0')
1337 sprintf(str
,"-A FORWARD -d %s -o %s -j ACCEPT", qos_free_zone
, wan
);
1342 save_line(":post_noproxy - [0:0]");
1343 sprintf(str
,"-A POSTROUTING -p ! tcp -o %s -j post_noproxy", lan
);
1345 sprintf(str
,"-A POSTROUTING -s ! %s -o %s -j post_noproxy", proxy_ip
, lan
);
1347 sprintf(str
,"-A POSTROUTING -s %s -p tcp --sport ! %d -o %s -j post_noproxy", proxy_ip
, proxy_port
, lan
);
1350 chain
="post_noproxy";
1354 chain
="POSTROUTING";
1357 sprintf(str
,"-A %s -s %s -o %s -j ACCEPT", chain
, qos_free_zone
, lan
);
1361 if(ip_count
>idxtable_treshold1
&& !just_flush
)
1363 int idxcount
=0, bitmask
=32-idxtable_bitmask1
; /* default net mask: 255.255.255.240 */
1365 /*-----------------------------------------------------------------*/
1366 printf("Detected %d addresses - indexing iptables rules to improve performance...\n",ip_count
);
1367 /*-----------------------------------------------------------------*/
1369 save_line(":post_common - [0:0]");
1370 save_line(":forw_common - [0:0]");
1372 for_each(ip
,ips
) if(ip
->addr
&& *(ip
->addr
) && !eq(ip
->addr
,"0.0.0.0/0"))
1374 buf
=hash_id(ip
->addr
,bitmask
);
1375 if_exists(idx
,idxs
,eq(idx
->id
,buf
))
1384 idx
->bitmask
=bitmask
;
1392 /* brutal perfomance optimalization */
1393 while(idxcount
>idxtable_treshold2
&& bitmask
>2*idxtable_bitmask2
)
1395 bitmask
-=idxtable_bitmask2
;
1398 for_each(idx
,idxs
) if(idx
->parent
== NULL
)
1400 buf
=hash_id(idx
->addr
,bitmask
);
1401 if_exists(metaindex
,idxs
,eq(metaindex
->id
,buf
))
1403 metaindex
->children
++;
1407 create(metaindex
,Index
);
1408 metaindex
->addr
=idx
->addr
;
1410 metaindex
->bitmask
=bitmask
;
1411 metaindex
->parent
=NULL
;
1412 metaindex
->children
=0;
1414 push(metaindex
,idxs
);
1416 idx
->parent
=metaindex
;
1420 /* this should slightly optimize throughout ... */
1421 sort(idx
,idxs
,desc_order_by
,children
);
1422 sort(idx
,idxs
,order_by
,bitmask
);
1427 subnet
=subnet_id(idx
->addr
,idx
->bitmask
);
1428 printf("%d: %s/%d\n",
1429 ++i
, subnet
, idx
->bitmask
);
1431 sprintf(str
,":post_%s - [0:0]", idx
->id
);
1434 sprintf(str
,":forw_%s - [0:0]", idx
->id
);
1439 string(buf
,strlen(idx
->parent
->id
)+6);
1440 sprintf(buf
,"post_%s",idx
->parent
->id
);
1447 sprintf(str
,"-A %s -d %s/%d -o %s -j post_%s", buf
, subnet
, idx
->bitmask
, lan
, idx
->id
);
1450 sprintf(str
,"-A %s -d %s/%d -o %s -j post_common", buf
, subnet
, idx
->bitmask
, lan
);
1455 string(buf
,strlen(idx
->parent
->id
)+6);
1456 sprintf(buf
,"forw_%s",idx
->parent
->id
);
1463 sprintf(str
,"-A %s -s %s/%d -o %s -j forw_%s", buf
, subnet
, idx
->bitmask
, wan
, idx
->id
);
1466 sprintf(str
,"-A %s -s %s/%d -o %s -j forw_common", buf
, subnet
, idx
->bitmask
, wan
);
1469 printf("Total indexed iptables chains created: %d\n", i
);
1471 sprintf(str
,"-A FORWARD -o %s -j forw_common", wan
);
1474 sprintf(str
,"-A POSTROUTING -o %s -j post_common", lan
);
1482 fclose(iptables_file
);
1487 puts("Just flushed iptables and tc classes - now exiting ...");
1493 if(!dry_run
&& !nodelay
&& qos_free_delay
)
1495 printf("Flushed iptables and tc classes - now sleeping for %d seconds...\n",qos_free_delay
);
1496 sleep(qos_free_delay
);
1499 sprintf(str
,"%s qdisc add dev %s root handle 1: htb r2q %d default 1",
1503 sprintf(str
, "%s class add dev %s parent 1: classid 1:2 htb rate %s ceil %s burst %dk prio %d",
1504 tc
,lan
,lan_medium
,lan_medium
,burst_main
,highest_priority
);
1507 sprintf(str
, "%s class add dev %s parent 1:2 classid 1:1 htb rate %Ldkbit ceil %Ldkbit burst %dk prio %d",
1508 tc
,lan
,line
,line
,burst_main
,highest_priority
);
1511 sprintf(str
,"%s qdisc add dev %s root handle 1: htb r2q %d default 1",tc
,wan
,htb_r2q
);
1514 sprintf(str
, "%s class add dev %s parent 1: classid 1:2 htb rate %s ceil %s burst %dk prio %d",
1515 tc
,wan
,wan_medium
,wan_medium
,burst_main
,highest_priority
);
1518 sprintf(str
, "%s class add dev %s parent 1:2 classid 1:1 htb rate %Ldkbit ceil %Ldkbit burst %dk prio %d",
1519 tc
,wan
,up
,up
,burst_main
,highest_priority
);
1523 /*-----------------------------------------------------------------*/
1524 puts("Locating heavy downloaders and generating root classes ...");
1525 /*-----------------------------------------------------------------*/
1526 sort(ip
,ips
,desc_order_by
,traffic
);
1528 /*-----------------------------------------------------------------*/
1529 /* sub-scope - local variables */
1531 long long int rate
= line
;
1532 long long int max
= line
;
1533 int group_count
= 0;
1534 FILE *credit_file
= NULL
;
1536 if(!just_preview
&& !dry_run
&& enable_credit
)
1538 credit_file
= fopen(credit
,"w");
1541 for_each(group
,groups
)
1546 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",
1547 tc
, lan
, parent
, group
->id
, rate
, max
, burst_group
, highest_priority
+1, group
->desired
);
1551 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",
1552 tc
, wan
, parent
, group
->id
, rate
*up
/line
, max
*up
/line
, burst_group
, highest_priority
+1, group
->desired
);
1556 if(group_count
++ < max_nesting
)
1561 rate
-= digital_divide
*group
->min
;
1562 if(rate
< group
->min
)
1567 /*shaping of aggresive downloaders, with credit file support */
1570 int group_rate
= group
->min
, priority_sequence
= lowest_priority
;
1572 for_each(ip
, ips
) if(ip
->min
== group
->min
&& ip
->max
> ip
->min
)
1574 if( ip
->keyword
->data_limit
&& !ip
->fixedprio
1575 && ( ip
->traffic
>ip
->credit
1576 + (ip
->min
*ip
->keyword
->data_limit
+(ip
->keyword
->fixed_limit
<<20))) )
1578 if(group_rate
<ip
->max
)
1582 group_rate
+=magic_treshold
;
1583 ip
->prio
=lowest_priority
;
1584 if(ip
->prio
<highest_priority
+2)
1586 ip
->prio
=highest_priority
+2;
1591 if( ip
->keyword
->data_prio
1593 && ( ip
->traffic
>ip
->credit
1594 + (ip
->min
*ip
->keyword
->data_prio
+(ip
->keyword
->fixed_prio
<<20))) )
1596 ip
->prio
=priority_sequence
--;
1597 if(ip
->prio
<highest_priority
+1)
1599 ip
->prio
=highest_priority
+1;
1605 unsigned long long lcredit
=0;
1607 if((ip
->min
*ip
->keyword
->data_limit
+(ip
->keyword
->fixed_limit
<<20))>ip
->traffic
)
1609 lcredit
=(ip
->min
*ip
->keyword
->data_limit
+(ip
->keyword
->fixed_limit
<<20))-ip
->traffic
;
1611 fprintf(credit_file
,"%s %Lu\n",ip
->addr
,lcredit
);
1619 fclose(credit_file
);
1625 f
=fopen(preview
,"w");
1628 else if(!dry_run
&& !just_flush
)
1630 /*-----------------------------------------------------------------*/
1631 printf("Writing daily statistics %s ... ", json
);
1632 /*-----------------------------------------------------------------*/
1644 if(ip
->traffic
|| ip
->direct
|| ip
->proxy
|| ip
->upload
)
1646 fprintf(f
, "%d:{\"ip\":%s, \"total\":%Lu, \"down\":%Lu, \"proxy\":%Lu, \"up\":%Lu}\n",
1647 ip
->lmsid
, ip
->addr
, ip
->traffic
, ip
->direct
, ip
->proxy
, ip
->upload
);
1668 /*-----------------------------------------------------------------*/
1669 printf("Sorting data and generating statistics page %s ...\n", ptr
);
1670 /*-----------------------------------------------------------------*/
1672 if(use_jquery_popups
)
1674 fprintf(f
,"<script type=\"text/javascript\" src=\"%s\"></script>\n", jquery_url
);
1676 fputs("<table class=\"decorated last\">\n\
1677 <caption>Bandwidth classes</caption>\n\
1679 <th style=\"text-align: right\">#</th>\n\
1680 <th style=\"text-align: right\">group</th>\n\
1681 <th style=\"text-align: right\">IPs</th>\n\
1682 <th style=\"text-align: right\">requested</th>\n",f
);
1683 fprintf(f
,"<th colspan=\"%d\">data limits</th>\n", keywordcount
);
1684 fputs("</tr></thead><tbody>\n",f
);
1687 for_each(group
, groups
)
1690 printf("%d kb/s group: %d bandwidth requested: %d kb/s\n",group
->min
,group
->count
,group
->desired
);
1692 fprintf(f
, "%s<td style=\"text-align: right\">%d</td><td style=\"text-align: right\">%d kb/s</td>",
1693 tr_odd_even(), count
, group
->min
);
1694 fprintf(f
, "<td style=\"text-align: right\">%d</td><td style=\"text-align: right\">%d kb/s</td>",
1695 group
->count
, group
->desired
);
1697 for_each(keyword
, keywords
) if(keyword
->ip_count
)
1699 fprintf(f
,"<td style=\"text-align: right\"><span style=\"color:#%s\">%d MB</span></td>",
1700 keyword
->html_color
, group
->min
*keyword
->data_limit
);
1702 i
+= group
->desired
;
1703 total
+= group
->count
;
1707 printf("Total groups: %d Total bandwidth requested: %d kb/s\nAGGREGATION: 1/%d\n",
1710 fprintf(f
,"</tr></tbody>\n\
1712 <th colspan=\"2\" style=\"text-align: left\">Line %Ld kb/s</td>",line
);
1713 fprintf(f
,"<th style=\"text-align: right\">%d</td><th style=\"text-align: right\">%d kb/s</td>",total
,i
);
1715 for_each(keyword
, keywords
) if(keyword
->ip_count
)
1717 fprintf(f
,"<th style=\"text-align: right\">%d IPs</th>",keyword
->ip_count
);
1719 fprintf(f
,"</tr><tr><th colspan=\"4\">Aggregation 1/%d</th>\n", (int)(0.5+i
/line
));
1720 fprintf(f
,"<th colspan=\"%d\">%d traffic classes</th></tr>\n", keywordcount
, total
);
1722 fputs("</thead></table>\n",f
);
1724 else if(!dry_run
&& !just_flush
)
1732 unsigned long long total_traffic
=0, total_direct
=0, total_proxy
=0, total_upload
=0, tmp_sum
=0;
1733 int active_classes
=0;
1735 struct Sum
{unsigned long long l
; int i
; list(Sum
);} *sum
,*sums
=NULL
;
1736 int limit_count
=0, prio_count
=0;
1744 fprintf(f
,"<p><table class=\"decorated last\">\n<caption>%s",title
);
1745 fprintf(f
," (%s)</caption>\n", d
);
1746 fputs("<thead><tr>\n<th colspan=\"3\"> </th>\n",f
);
1747 fputs("<th style=\"text-align: right\">credit</th>\n\
1748 <th style=\"text-align: right\">FUP</th>\n\
1749 <th style=\"text-align: right\">total</th>\n\
1750 <th style=\"text-align: right\">down</th>\n",f
);
1753 fputs("<th style=\"text-align: right\">proxy</th>\n",f
);
1755 fputs("<th style=\"text-align: right\">up</th>\n\
1756 <th style=\"text-align: right\">min</th>\n\
1757 <th style=\"text-align: right\">max</th>\n\
1758 <th style=\"text-align: right\">limit</th>\n\
1761 <th style=\"text-align: right\">#</th>\n\
1762 <th>hostname [+sharing]</th>\n\
1763 <th style=\"text-align: right\">LMS</th>\n\
1764 <th style=\"text-align: right\">MB</th>\n\
1765 <th style=\"text-align: right\">MB</th>\n\
1766 <th style=\"text-align: right\">MB</th>\n\
1767 <th style=\"text-align: right\">MB</th>\n\
1768 <th style=\"text-align: right\">MB</th>\n\
1769 <th style=\"text-align: right\">kb/s</th>\n\
1770 <th style=\"text-align: right\">kb/s</th>\n\
1771 <th style=\"text-align: right\">kb/s</th>\n\
1773 </tr></thead><tbody>\n",f
);
1776 for_each(ip
,ips
) if(!use_jquery_popups
|| !ip
->sharing
)
1778 char *f1
="", *f2
="";
1781 if(ip
->max
< ip
->desired
)
1783 f1
="<span style=\"color:red\">";
1787 else if(ip
->prio
> highest_priority
+1)
1789 f1
="<span style=\"color:brown\">";
1795 printf("%03d. %-22s %10Lu (%d/%d)\n",i
,ip
->name
, ip
->traffic
, ip
->min
, ip
->max
);
1797 /* hostnames -------------------------------------- */
1798 fprintf(f
,"%s<td style=\"text-align: right\"><a name=\"%s\"></a>%d</td><td><a class=\"blue\" href=\"%s%s.log\">%s</a>\n",
1799 tr_odd_even(), ip
->name
, i
, log_url
, ip
->name
, ip
->name
);
1801 if(use_jquery_popups
)
1803 fprintf(f
,"<span id=\"sharing_%d\" style=\"display:none\">",i
);
1805 for_each(sharedip
, ips
) if(eq(ip
->name
, sharedip
->sharing
))
1807 fprintf(f
,"<br /><a class=\"blue\" href=\"%s%s.log\">%s</a>\n", log_url
, sharedip
->name
, sharedip
->name
);
1810 fputs("</span>\n",f
);
1813 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>",
1814 i
, i
, i
, popup_button
);
1818 /* ----------------------------------------------- */
1822 fputs("<td style=\"text-align: right\">",f
);
1825 fprintf(f
,"<a class=\"blue\" href=\"%s%d\">%04d</a>\n", lms_url
, ip
->lmsid
, ip
->lmsid
);
1827 else if(ip
->lmsid
== 0)
1833 fprintf(f
,"<td style=\"text-align: right\">%Lu</td>\n", ip
->credit
);
1834 fprintf(f
,"<td style=\"text-align: right\"><span style=\"color:#%s\">%Lu</span></td>",
1835 ip
->keyword
->html_color
,
1836 ip
->credit
+(ip
->min
*ip
->keyword
->data_limit
+(ip
->keyword
->fixed_limit
<<20)));
1837 fprintf(f
,"<td style=\"text-align: right\">%s%Lu%s", f1
, ip
->traffic
, f2
);
1839 /* download --------------------------------------- */
1840 fprintf(f
,"</td><td style=\"text-align: right\">%Lu", ip
->direct
);
1841 if(use_jquery_popups
)
1843 fprintf(f
,"<span id=\"download_%d\" style=\"display:none\">",i
);
1844 for_each(sharedip
, ips
) if(eq(ip
->name
, sharedip
->sharing
))
1846 fprintf(f
,"<br />%Lu", sharedip
->direct
);
1848 fputs("</span>\n",f
);
1851 /* ----------------------------------------------- */
1855 fprintf(f
,"<td style=\"text-align: right\">%Lu</td>\n", ip
->proxy
);
1857 /* upload ---------------------------------------- */
1858 fprintf(f
,"<td style=\"text-align: right\">%Lu", ip
->upload
);
1859 if(use_jquery_popups
)
1861 fprintf(f
,"<span id=\"upload_%d\" style=\"display:none\">",i
);
1862 for_each(sharedip
,ips
) if(eq(ip
->name
, sharedip
->sharing
))
1864 fprintf(f
,"<br />%Lu", sharedip
->upload
);
1867 append_log(sharedip
);
1870 fputs("</span>\n",f
);
1873 /* ----------------------------------------------- */
1875 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1876 <td style=\"text-align: right\">%d</td>\n\
1877 <td style=\"text-align: right\">%s%d%s</td>\n\
1878 <td>%s%d%s</td></tr>\n",
1879 ip
->min
, ip
->desired
,
1883 total_traffic
+=ip
->traffic
;
1884 total_direct
+=ip
->direct
;
1885 total_proxy
+=ip
->proxy
;
1886 total_upload
+=ip
->upload
;
1890 tmp_sum
+=ip
->traffic
;
1893 sum
->i
=active_classes
;
1894 insert(sum
,sums
,order_by
,i
);
1902 fprintf(f
,"</tbody><thead><tr>\n\
1903 <th colspan=\"%d\" style=\"text-align: left\">%d CLASSES</th>", colspan
-7, i
);
1904 fprintf(f
,"<th style=\"text-align: right\">%Lu</th><th style=\"text-align: right\">%Lu</th>\n", total_traffic
, total_direct
);
1907 fprintf(f
,"<th style=\"text-align: right\">%Lu</th>\n", total_proxy
);
1909 fprintf(f
,"<th style=\"text-align: right\">%Lu</th>", total_upload
);
1910 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
);
1913 if(active_classes
>10)
1915 int top20_count
=0,top20_perc1
=0;
1916 long long top20_perc2
=0;
1917 unsigned long long top20_sum
=0l;
1919 fputs("<a name=\"erp\"></a><p><table class=\"decorated last\"><caption>Enterprise Resource Planning (ERP)</caption>\n",f
);
1920 fputs("<thead><tr>\n\
1921 <th>Analytic category</th>\n\
1922 <th colspan=\"2\" style=\"text-align: center\">Active Classes</th>\n\
1923 <th colspan=\"2\" style=\"text-align: center\">Data transfers</th>\n\
1924 </tr></thead><tbody>\n",f
);
1926 if_exists(sum
,sums
,sum
->l
>=total_traffic
/4)
1928 fprintf(f
,"%s<td>Top 25%% of traffic</td>\n", tr_odd_even());
1929 fprintf(f
,"<td style=\"text-align: right\">%d</td><td style=\"text-align: right\">%d %%</td><td style=\"text-align: right\">%Lu M</td><td style=\"text-align: right\">%Ld %%</td></tr>\n",sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
1932 if_exists(sum
,sums
,sum
->i
==10)
1934 fprintf(f
,"%s<td>Top 10 downloaders</td>\n", tr_odd_even());
1935 fprintf(f
,"<td style=\"text-align: right\"><strong>10</strong></td>\n\
1936 <td style=\"text-align: right\">%d %%</td>\n\
1937 <td style=\"text-align: right\">%Lu MB</td>\n\
1938 <td style=\"text-align: right\">%Ld %%</td></tr>\n",
1939 (100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
1942 if_exists(sum
,sums
,sum
->l
>=total_traffic
/2)
1944 fprintf(f
,"%s<td>Top 50%% of traffic</td>\n", tr_odd_even());
1945 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1946 <td style=\"text-align: right\">%d %%</td>\n\
1947 <td style=\"text-align: right\">%Lu MB</td>\n\
1948 <td style=\"text-align: right\"><strong>%Ld %%</strong></td></tr>\n",
1949 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
1952 if_exists(sum
,sums
,sum
->l
>=4*total_traffic
/5)
1954 fprintf(f
,"%s<td>Top 80%% of traffic</td>\n", tr_odd_even());
1955 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1956 <td style=\"text-align: right\">%d %%</td>\n\
1957 <td style=\"text-align: right\">%Lu MB</td>\n\
1958 <td style=\"text-align: right\"><strong>%Ld %%</strong></td></tr>\n",
1959 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
1962 if_exists(sum
,sums
,sum
->i
>=(active_classes
+1)/5)
1964 fprintf(f
,"%s<td>Top 20%% downloaders</td>\n", tr_odd_even());
1966 top20_perc1
=(100*sum
->i
+50)/active_classes
;
1968 top20_perc2
=(100*sum
->l
+50)/total_traffic
;
1969 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1970 <td style=\"text-align: right\"><strong>%d %%</strong></td>\n\
1971 <td style=\"text-align: right\">%Lu MB</td>\n\
1972 <td style=\"text-align: right\">%Ld %%</td></tr>\n",
1973 top20_count
,top20_perc1
,top20_sum
,top20_perc2
);
1976 if_exists(sum
,sums
,sum
->i
>=(active_classes
+1)/4)
1978 fprintf(f
,"%s<td>Top 25%% downloaders</td>\n", tr_odd_even());
1979 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1980 <td style=\"text-align: right\">%d %%</td>\n\
1981 <td style=\"text-align: right\">%Lu MB</td>\n\
1982 <td style=\"text-align: right\">%Ld %%</td></tr>\n",
1983 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
1986 if_exists(sum
,sums
,sum
->i
>=(active_classes
+1)/2)
1988 fprintf(f
,"%s<td>Top 50%% downloaders</td>\n", tr_odd_even());
1989 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
1990 <td style=\"text-align: right\"><strong>%d %%</strong></td>\n\
1991 <td style=\"text-align: right\">%Lu MB</td>\n\
1992 <td style=\"text-align: right\">%Ld %%</td></tr>\n",
1993 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
1996 if_exists(sum
,sums
,sum
->i
>=4*(active_classes
+1)/5)
1998 fprintf(f
,"%s<td>Top 80%% downloaders</td>\n", tr_odd_even());
1999 fprintf(f
,"<td style=\"text-align: right\">%d</td>\n\
2000 <td style=\"text-align: right\">%d %%</td>\n\
2001 <td style=\"text-align: right\">%Lu MB</td>\n\
2002 <td style=\"text-align: right\">%Ld %%</td></tr></tbody>\n",
2003 sum
->i
,(100*sum
->i
+50)/active_classes
,sum
->l
,(100*sum
->l
+50)/total_traffic
);
2006 fprintf(f
,"<tr><thead><th><a class=\"blue\" href=\"%sERP.log\">All users, all traffic</a></th>\n", log_url
);
2007 fprintf(f
,"<th style=\"text-align: right\">%d</th>\n\
2008 <th style=\"text-align: right\">100 %%</th>\n\
2009 <th style=\"text-align: right\">%Lu M</th>\n\
2010 <th style=\"text-align: right\">100 %%</th></tr>\n",active_classes
,total_traffic
);
2011 fputs("</thead></table>\n", f
);
2013 /* write basic ERP data to log directory */
2017 sprintf(str
,"%s/ERP.log",log_dir
);
2018 iplog
=fopen(str
,"a");
2021 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",
2022 time(NULL
), top20_count
, top20_perc1
, top20_sum
, top20_perc2
,
2023 active_classes
, total_traffic
, i
, limit_count
, prio_count
, d
); /* d = date*/
2033 fprintf(f
, stats_html_signature
, version
);
2039 puts("Statistics preview generated (-p switch) - now exiting ...");
2045 printf("%-22s %-15s mark\n","name","ip");
2048 printf("Writing %s ... ", classmap
);
2049 f
= fopen(classmap
, "w");
2055 /*-----------------------------------------------------------------*/
2056 puts("Generating iptables and tc classes ... ");
2057 /*-----------------------------------------------------------------*/
2059 for_each(ip
, ips
) if(ip
->mark
> 0)
2064 duplicate(ip
->addr
,buf
);
2065 buf
=hash_id(ip
->addr
,32-idxtable_bitmask1
);
2067 string(chain_forward
,6+strlen(buf
));
2068 strcpy(chain_forward
,"forw_");
2069 strcat(chain_forward
,buf
);
2071 string(chain_postrouting
,6+strlen(buf
));
2072 strcpy(chain_postrouting
,"post_");
2073 strcat(chain_postrouting
,buf
);
2079 chain_forward
="FORWARD";
2080 chain_postrouting
="POSTROUTING";
2084 printf("%-22s %-16s %04d ", ip
->name
, ip
->addr
, ip
->mark
);
2087 /* -------------------------------------------------------- mark download */
2089 sprintf(str
, "-A %s -d %s/32 -o %s -j %s%d",
2090 chain_postrouting
, ip
->addr
, lan
, mark_iptables
, ip
->mark
);
2091 /*sprintf(str,"-A %s -d %s/32 -o %s -j MARK --set-mark %d",chain_postrouting,ip->addr,lan,ip->mark);*/
2092 /* -m limit --limit 1/s */
2097 sprintf(str
, "-A %s -s %s -p tcp --sport %d -d %s/32 -o %s -j %s%d",
2098 chain_postrouting
, proxy_ip
, proxy_port
, ip
->addr
, lan
, mark_iptables
, ip
->mark
);
2099 /*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);*/
2103 sprintf(str
, "-A %s -d %s/32 -o %s -j ACCEPT",
2104 chain_postrouting
, ip
->addr
, lan
);
2107 /* -------------------------------------------------------- mark upload */
2108 sprintf(str
, "-A %s -s %s/32 -o %s -j %s%d",
2109 chain_forward
, ip
->addr
, wan
, mark_iptables
, ip
->mark
);
2110 /* sprintf(str,"-A %s -s %s/32 -o %s -j MARK --set-mark %d",chain_forward,ip->addr,wan,ip->mark);*/
2113 sprintf(str
, "-A %s -s %s/32 -o %s -j ACCEPT",
2114 chain_forward
, ip
->addr
, wan
);
2119 /* -------------------------------------------------------- download class */
2121 printf("(down: %dk-%dk ", ip
->min
, ip
->max
);
2124 sprintf(str
, "%s class add dev %s parent 1:%d classid 1:%d htb rate %dkbit ceil %dkbit burst %dk prio %d",
2125 tc
, lan
, ip
->group
, ip
->mark
,ip
->min
,ip
->max
, burst
, ip
->prio
);
2128 if(strcmpi(ip
->keyword
->leaf_discipline
, "none"))
2130 sprintf(str
, "%s qdisc add dev %s parent 1:%d handle %d %s",
2131 tc
, lan
, ip
->mark
, ip
->mark
, ip
->keyword
->leaf_discipline
); /*qos_leaf*/
2135 if(filter_type
== 1)
2137 sprintf(str
, "%s filter add dev %s parent 1:0 protocol ip handle %d fw flowid 1:%d",
2138 tc
, lan
, ip
->mark
, ip
->mark
);
2142 /* -------------------------------------------------------- upload class */
2144 printf("up: %dk-%dk)\n", (int)((ip
->min
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
),
2145 (int)((ip
->max
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
));
2148 sprintf(str
,"%s class add dev %s parent 1:%d classid 1:%d htb rate %dkbit ceil %dkbit burst %dk prio %d",
2149 tc
, wan
, ip
->group
, ip
->mark
,
2150 (int)((ip
->min
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
),
2151 (int)((ip
->max
/ip
->keyword
->asymetry_ratio
)-ip
->keyword
->asymetry_fixed
), burst
, ip
->prio
);
2154 if(strcmpi(ip
->keyword
->leaf_discipline
, "none"))
2156 sprintf(str
, "%s qdisc add dev %s parent 1:%d handle %d %s",
2157 tc
, wan
, ip
->mark
, ip
->mark
, ip
->keyword
->leaf_discipline
); /*qos_leaf*/
2161 if(filter_type
== 1)
2163 sprintf(str
, "%s filter add dev %s parent 1:0 protocol ip handle %d fw flowid 1:%d",
2164 tc
, wan
, ip
->mark
, ip
->mark
);
2170 fprintf(f
, "%s %d", ip
->addr
, ip
->mark
);
2176 printf("(sharing %s)\n", ip
->sharing
);
2189 chain_forward
= "forw_common";
2190 chain_postrouting
= "post_common";
2194 chain_forward
= "FORWARD";
2195 chain_postrouting
= "POSTROUTING";
2197 /* -------------------------------- classify or reject free download */
2199 char *final_chain
= "DROP"; /* REJECT would be better, but it is impossible in mangle */
2202 final_chain
= "ACCEPT";
2208 sprintf(str
,"-A %s -s %s -p tcp --sport %d -o %s -j %s%d",
2209 chain_postrouting
,proxy_ip
,proxy_port
,lan
,mark_iptables
,3);
2212 sprintf(str
,"-A %s -s %s -p tcp --sport %d -o %s -j %s",
2213 chain_postrouting
,proxy_ip
,proxy_port
,lan
,final_chain
);
2218 sprintf(str
,"-A %s -o %s -j %s%d", chain_postrouting
, lan
, mark_iptables
, 3);
2221 sprintf(str
,"-A %s -o %s -j %s", chain_postrouting
, lan
, final_chain
);
2223 /* ------------------------------- classify or reject free upload */
2226 sprintf(str
,"-A %s -o %s -j %s%d", chain_forward
, wan
, mark_iptables
, 3);
2229 sprintf(str
,"-A %s -o %s -j %s", chain_forward
, wan
, final_chain
);
2233 if(free_min
) /* allocate free bandwith if it is not zero... */
2235 /*-----------------------------------------------------------------*/
2236 puts("Generating free bandwith classes ...");
2237 /*-----------------------------------------------------------------*/
2238 sprintf(str
, "%s class add dev %s parent 1:%d classid 1:3 htb rate %dkbit ceil %dkbit burst %dk prio %d",
2239 tc
, lan
, parent
, free_min
, free_max
,burst
, lowest_priority
);
2241 sprintf(str
, "%s class add dev %s parent 1:%d classid 1:3 htb rate %dkbit ceil %dkbit burst %dk prio %d",
2242 tc
, wan
, parent
, free_min
, free_max
, burst
, lowest_priority
);
2245 if(strcmpi(qos_leaf
, "none"))
2247 sprintf(str
,"%s qdisc add dev %s parent 1:3 handle 3 %s", tc
, lan
, qos_leaf
);
2250 sprintf(str
,"%s qdisc add dev %s parent 1:3 handle 3 %s", tc
, wan
, qos_leaf
);
2253 /* tc handle 1 fw flowid */
2254 sprintf(str
,"%s filter add dev %s parent 1:0 protocol ip handle 3 fw flowid 1:3", tc
, lan
);
2257 sprintf(str
,"%s filter add dev %s parent 1:0 protocol ip handle 3 fw flowid 1:3", tc
, wan
);
2260 printf("Total IP count: %d\n", i
);
2267 /* that's all folks, thank you for reading it all the way up to this point ;-) */
2268 /* bad luck C<<1 is not yet finished, I promise no sprintf() next time... */
This page took 1.322283 seconds and 4 git commands to generate.