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.2 by root, Fri Aug 10 04:16:41 2001 UTC vs.
Revision 1.15 by root, Sun Aug 19 23:57:52 2001 UTC

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

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines