1565 |
to_deflate := []; |
to_deflate := []; |
1566 |
to_deflate_len := 0 |
to_deflate_len := 0 |
1567 |
|
|
1568 |
let to_deflate conn = |
let _to_deflate conn = |
1569 |
if not (List.memq conn !to_deflate) then |
if not (List.memq conn !to_deflate) then |
1570 |
to_deflate := conn :: !to_deflate; |
to_deflate := conn :: !to_deflate; |
1571 |
if !to_deflate_len > 1000000 then |
if !to_deflate_len > 1000000 then |
1605 |
| Some (_,_, _,wbuf) -> |
| Some (_,_, _,wbuf) -> |
1606 |
|
|
1607 |
to_deflate_len := !to_deflate_len + len; |
to_deflate_len := !to_deflate_len + len; |
1608 |
to_deflate t; |
_to_deflate t; |
1609 |
buf_add t wbuf s pos len |
buf_add t wbuf s pos len |
1610 |
|
|
1611 |
(*************************************************************************) |
(*************************************************************************) |
1845 |
Heap.add_memstat "tcpBufferedSocket" (fun level buf -> |
Heap.add_memstat "tcpBufferedSocket" (fun level buf -> |
1846 |
Printf.bprintf buf " %d latencies\n" (Hashtbl.length latencies); |
Printf.bprintf buf " %d latencies\n" (Hashtbl.length latencies); |
1847 |
Printf.bprintf buf " %d entries in net_stats\n" (Hashtbl.length net_stats); |
Printf.bprintf buf " %d entries in net_stats\n" (Hashtbl.length net_stats); |
1848 |
|
Printf.bprintf buf " String.length big_buffer: %d\n" (String.length big_buffer); |
1849 |
|
Printf.bprintf buf " connection_managers: %d\n" (List.length !connection_managers); |
1850 |
|
Printf.bprintf buf " read_bandwidth_controlers: %d\n" (List.length !read_bandwidth_controlers); |
1851 |
|
Printf.bprintf buf " write_bandwidth_controlers: %d\n" (List.length !write_bandwidth_controlers); |
1852 |
|
Printf.bprintf buf " to_deflate: %d\n" (List.length !to_deflate); |
1853 |
); |
); |
1854 |
add_infinite_timer 1.0 proc_net_timer |
add_infinite_timer 1.0 proc_net_timer |
1855 |
|
|