ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Coro/myhttpd/shell.pl
(Generate patch)

Comparing Coro/myhttpd/shell.pl (file contents):
Revision 1.8 by root, Sat Aug 11 19:59:20 2001 UTC vs.
Revision 1.12 by root, Wed Aug 15 03:06:22 2001 UTC

4use Coro::Handle; 4use Coro::Handle;
5use Coro::Socket; 5use Coro::Socket;
6use Event; 6use Event;
7use Time::HiRes 'time'; 7use Time::HiRes 'time';
8 8
9use Text::Abbrev;
10
9my $last_ts = time; 11my $last_ts = time;
12
13my %complete;
14my @commands = qw(quit squit refresh country restart block info print);
15
16abbrev \%complete, @commands;
10 17
11sub shell { 18sub shell {
12 my $fh = shift; 19 my $fh = shift;
13 20
14 while (defined (print $fh "cmd> "), $_ = <$fh>) { 21 while (defined (print $fh "cmd> "), $_ = <$fh>) {
15 s/\015?\012$//; 22 s/\015?\012$//;
16 chomp; 23 if (s/^(\S+)\s*// && (my $cmd = $complete{$1})) {
17 if (/^q/) { 24 if ($cmd eq "quit") {
25 print "bye bye.\n";#d#
26 last;
27 } elsif ($cmd eq "squit") {
18 Event::unloop; 28 Event::unloop;
19 } elsif (/^i/) { 29 last;
30 } elsif ($cmd eq "print") {
31 my @res = eval $_;
32 print $fh "eval: $@\n" if $@;
33 print $fh "RES = ", (join " : ", @res), "\n";
34 } elsif ($cmd eq "block") {
35 print "blocked '$_'\n";#d#
36 $conn::blocked{$_} = time + $::BLOCKTIME;
37 } elsif ($cmd eq "info") {
20 $::NOW = time+1e-6; 38 $::NOW = time+1e-6;
21 my @data; 39 my @data;
22 for (values %conn::conn) { 40 for (values %conn::conn) {
23 for (values %$_) { 41 for (values %$_) {
24 next unless $_; 42 next unless $_;
25 my $rate = sprintf "%.1f", $_->{written} / ($::NOW - $_->{time}); 43 my $rate = sprintf "%.1f", $_->{written} / ($::NOW - $_->{time});
26 push @data, "$_->{country}/$_->{remote_addr} $_->{written} $rate $_->{method} $_->{uri}\n"; 44 push @data, "$_->{country}/$_->{remote_addr} $_->{written} $rate $_->{method} $_->{uri}\n";
45 }
27 } 46 }
47 print $fh sort @data;
48 print $fh scalar@data, " ($::conns) connections\n";#d#
49 print $fh "$::written bytes written in the last ",$::NOW - $last_ts, " seconds\n";
50 printf $fh "(%.1f bytes/s)\n", $::written / ($::NOW - $last_ts);
51 ($last_ts, $::written) = ($::NOW, 0);
52 } elsif ($cmd eq "refresh") {
53 do "config.pl";
54 print $fh "config.pl: $@\n" if $@;
55 read_blocklist;
56 } elsif ($cmd eq "restart") {
57 $::RESTART = 1;
58 unloop;
59 print $fh "restarting, cu!\n";
60 last;
61 } elsif ($cmd eq "country") {
62 print $fh ip_request($_), "\n";
28 } 63 }
29 print $fh sort @data;
30 print $fh scalar@data, " connections\n";#d#
31 print $fh "$::written bytes written in the last ",$::NOW - $last_ts, " seconds\n";
32 printf $fh "(%.1f bytes/s)\n", $::written / ($::NOW - $last_ts);
33 ($last_ts, $::written) = ($::NOW, 0);
34 } elsif (/^ref/) {
35 read_blocklist;
36 } elsif (/^r/) {
37 $::RESTART = 1;
38 unloop;
39 print $fh "bye bye.\n";
40 last;
41 } elsif (/^co\S*\s+(\S+)/) {
42 print $fh ip_request($1), "\n";
43 } else { 64 } else {
44 print $fh "try quit, info, restart, refresh\n"; 65 print $fh "try one of @commands\n";
45 } 66 }
46 } 67 }
47} 68}
48 69
49# bind to tcp port 70# bind to tcp port

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines