[ViewVC] Diff of: cvs/cvsroot/Coro/myhttpd/httpd.pl

Comparing cvsroot/Coro/myhttpd/httpd.pl (file contents):
Revision 1.17 by root, Wed Aug 15 03:06:21 2001 UTC vs.
Revision 1.29 by root, Sat Aug 25 15:14:03 2001 UTC

…		…
9	# at least on my machine, this thingy serves files	9	# at least on my machine, this thingy serves files
10	# quite a bit faster than apache, ;)	10	# quite a bit faster than apache, ;)
11	# and quite a bit slower than thttpd :(	11	# and quite a bit slower than thttpd :(
12		12
13	$SIG{PIPE} = 'IGNORE';	13	$SIG{PIPE} = 'IGNORE';
14		14
		15	our $accesslog;
		16
		17	if ($ACCESS_LOG) {
		18	use IO::Handle;
		19	open $accesslog, ">>$ACCESS_LOG"
		20	or die "$ACCESS_LOG: $!";
		21	$accesslog->autoflush(1);
		22	}
		23
15	sub slog {	24	sub slog {
16	my $level = shift;	25	my $level = shift;
17	my $format = shift;	26	my $format = shift;
18	printf "---: $format\n", @_;	27	printf "---: $format\n", @_;
19	}	28	}
…		…
74	use Convert::Scalar 'weaken';	83	use Convert::Scalar 'weaken';
75	use Linux::AIO;	84	use Linux::AIO;
76		85
77	Linux::AIO::min_parallel $::AIO_PARALLEL;	86	Linux::AIO::min_parallel $::AIO_PARALLEL;
78		87
		88	my $aio_requests = new Coro::Semaphore $::AIO_PARALLEL * 4;
		89
79	Event->io(fd => Linux::AIO::poll_fileno,	90	Event->io(fd => Linux::AIO::poll_fileno,
80	poll => 'r', async => 1,	91	poll => 'r', async => 1,
81	cb => \&Linux::AIO::poll_cb );	92	cb => \&Linux::AIO::poll_cb);
82		93
83	Event->add_hooks(prepare => sub {
84	&Coro::cede;
85	});
86
87	our %conn; # $conn{ip}{fh} => connobj	94	our %conn; # $conn{ip}{self} => connobj
		95	our %uri; # $uri{ip}{uri}{self}
88	our %blocked;	96	our %blocked;
89	our %mimetype;	97	our %mimetype;
90		98
91	sub read_mimetypes {	99	sub read_mimetypes {
92	local *M;	100	local *M;
…		…
125	sub DESTROY {	133	sub DESTROY {
126	my $self = shift;	134	my $self = shift;
127		135
128	$::conns--;	136	$::conns--;
129		137
		138	$self->eoconn;
130	delete $conn{$self->{remote_addr}}{$self*1};	139	delete $conn{$self->{remote_addr}}{$self*1};
		140	}
		141
		142	# end of connection
		143	sub eoconn {
		144	my $self = shift;
131	delete $uri{$self->{remote_addr}}{$self->{uri}}{$self*1};	145	delete $uri{$self->{remote_addr}}{$self->{uri}}{$self*1};
132	}	146	}
133		147
134	sub slog {	148	sub slog {
135	my $self = shift;	149	my $self = shift;
136	main::slog($_[0], "$self->{remote_addr}> $_[1]");	150	main::slog($_[0], ($self->{remote_id} \|\| $self->{remote_addr}) ."> $_[1]");
137	}	151	}
138		152
139	sub response {	153	sub response {
140	my ($self, $code, $msg, $hdr, $content) = @_;	154	my ($self, $code, $msg, $hdr, $content) = @_;
141	my $res = "HTTP/1.1 $code $msg\015\012";	155	my $res = "HTTP/1.1 $code $msg\015\012";
142		156
143	#$res .= "Connection: close\015\012";	157	$self->{h}{connection} \|\|= $hdr->{Connection};
		158
144	$res .= "Date: ".(time2str $::NOW)."\015\012"; # slow? nah. :(	159	$res .= "Date: ".(time2str $::NOW)."\015\012"; # slow? nah. :(
145		160
146	while (my ($h, $v) = each %$hdr) {	161	while (my ($h, $v) = each %$hdr) {
147	$res .= "$h: $v\015\012"	162	$res .= "$h: $v\015\012"
148	}	163	}
149	$res .= "\015\012";	164	$res .= "\015\012";
150		165
151	$res .= $content if defined $content and $self->{method} ne "HEAD";	166	$res .= $content if defined $content and $self->{method} ne "HEAD";
152		167
153	print STDERR "$self->{remote_addr} \"$self->{uri}\" $code ".$hdr->{"Content-Length"}." \"$self->{h}{referer}\"\n";#d#	168	my $log = "$self->{remote_addr} \"$self->{uri}\" $code ".$hdr->{"Content-Length"}." \"$self->{h}{referer}\"\n";
		169
		170	print $accesslog $log if $accesslog;
		171	print STDERR $log;
154		172
155	$self->{written} +=	173	$self->{written} +=
156	print {$self->{fh}} $res;	174	print {$self->{fh}} $res;
157	}	175	}
158		176
…		…
175	sub err_blocked {	193	sub err_blocked {
176	my $self = shift;	194	my $self = shift;
177	my $ip = $self->{remote_addr};	195	my $ip = $self->{remote_addr};
178	my $time = time2str $blocked{$ip} = $::NOW + $::BLOCKTIME;	196	my $time = time2str $blocked{$ip} = $::NOW + $::BLOCKTIME;
179		197
180	Coro::Event::do_timer(after => 15);	198	Coro::Event::do_timer(after => 20*rand);
181		199
182	$self->err(401, "too many connections",	200	$self->err(401, "too many connections",
183	{	201	{
184	"Content-Type" => "text/html",	202	"Content-Type" => "text/html",
185	"Retry-After" => $::BLOCKTIME	203	"Retry-After" => $::BLOCKTIME,
		204	"Warning" => "Please do NOT retry, you have been blocked",
		205	"WWW-Authenticate" => "Basic realm=\"Please do NOT retry, you have been blocked\"",
		206	"Connection" => "close",
186	},	207	},
187	<<EOF);	208	<<EOF);
188	<html><p>	209	<html>
		210	<head>
		211	<title>Too many connections</title>
		212	</head>
		213	<body bgcolor="#ffffff" text="#000000" link="#0000ff" vlink="#000080" alink="#ff0000">
		214
189	You have been blocked because you opened too many connections. You	215	<p>You have been blocked because you opened too many connections. You
190	may retry at</p>	216	may retry at</p>
191		217
192	<p><blockquote>$time.</blockquote></p>	218	<p><blockquote>$time.</blockquote></p>
193		219
194	<p>Until then, each new access will renew the block. You might want to have a	220	<p>Until then, each new access will renew the block. You might want to have a
195	look at the <a href="http://www.goof.com/pcg/marc/animefaq.html">FAQ</a>.</p>	221	look at the <a href="http://www.goof.com/pcg/marc/animefaq.html#connectionlimit">FAQ</a>.</p>
196	</html>	222
		223	</body></html>
197	EOF	224	EOF
198	}	225	}
199		226
200	sub handle {	227	sub handle {
201	my $self = shift;	228	my $self = shift;
202	my $fh = $self->{fh};	229	my $fh = $self->{fh};
		230
		231	my $host;
203		232
204	$fh->timeout($::REQ_TIMEOUT);	233	$fh->timeout($::REQ_TIMEOUT);
205	while() {	234	while() {
206	$self->{reqs}++;	235	$self->{reqs}++;
207		236
…		…
242		271
243	$self->{method} = $1;	272	$self->{method} = $1;
244	$self->{uri} = $2;	273	$self->{uri} = $2;
245	$self->{version} = $3;	274	$self->{version} = $3;
246		275
247	$3 eq "1.0" or $3 eq "1.1"	276	$3 =~ /^1\./
248	or $self->err(506, "http protocol version $3 not supported");	277	or $self->err(506, "http protocol version $3 not supported");
249		278
250	# parse headers	279	# parse headers
251	{	280	{
252	my (%hdr, $h, $v);	281	my (%hdr, $h, $v);
…		…
264		293
265	$self->{h}{$h} = substr $v, 1	294	$self->{h}{$h} = substr $v, 1
266	while ($h, $v) = each %hdr;	295	while ($h, $v) = each %hdr;
267	}	296	}
268		297
		298	# find out server name and port
		299	if ($self->{uri} =~ s/^http:\/\/([^\/?#]*)//i) {
		300	$host = $1;
		301	} else {
		302	$host = $self->{h}{host};
		303	}
		304
		305	if (defined $host) {
269	$self->{server_port} = $self->{h}{host} =~ s/:([0-9]+)$// ? $1 : 80;	306	$self->{server_port} = $host =~ s/:([0-9]+)$// ? $1 : 80;
		307	} else {
		308	($self->{server_port}, $host)
		309	= unpack_sockaddr_in $self->{fh}->getsockname
		310	or $self->err(500, "unable to get socket name");
		311	$host = inet_ntoa $host;
		312	}
		313
		314	$self->{server_name} = $host;
		315
		316	# remote id should be unique per user
		317	$self->{remote_id} = $self->{remote_addr};
		318
		319	if (exists $self->{h}{"client-ip"}) {
		320	$self->{remote_id} .= "[".$self->{h}{"client-ip"}."]";
		321	} elsif (exists $self->{h}{"x-forwarded-for"}) {
		322	$self->{remote_id} .= "[".$self->{h}{"x-forwarded-for"}."]";
		323	}
270		324
271	weaken ($uri{$self->{remote_addr}}{$self->{uri}}{$self*1} = $self);	325	weaken ($uri{$self->{remote_addr}}{$self->{uri}}{$self*1} = $self);
272		326
		327	eval {
273	$self->map_uri;	328	$self->map_uri;
274	$self->respond;	329	$self->respond;
		330	};
275		331
		332	$self->eoconn;
		333
		334	die if $@ && !ref $@;
		335
276	last if $self->{h}{connection} =~ /close/ \|\| $self->{version} lt "1.1";	336	last if $self->{h}{connection} =~ /close/ \|\| $self->{version} < 1.1;
277		337
278	$self->slog(9, "persistant connection [".$self->{h}{"user-agent"}."][$self->{reqs}]");
279	$fh->timeout($::PER_TIMEOUT);	338	$fh->timeout($::PER_TIMEOUT);
280	}	339	}
281	}	340	}
282		341
283	# uri => path mapping	342	# uri => path mapping
284	sub map_uri {	343	sub map_uri {
285	my $self = shift;	344	my $self = shift;
286	my $host = $self->{h}{host} \|\| "default";	345	my $host = $self->{server_name};
287	my $uri = $self->{uri};	346	my $uri = $self->{uri};
288		347
289	# some massaging, also makes it more secure	348	# some massaging, also makes it more secure
290	$uri =~ s/%([0-9a-fA-F][0-9a-fA-F])/chr hex $1/ge;	349	$uri =~ s/%([0-9a-fA-F][0-9a-fA-F])/chr hex $1/ge;
291	$uri =~ s%//+%/%g;	350	$uri =~ s%//+%/%g;
…		…
301	$self->{path} = "$::DOCROOT/$host$uri";	360	$self->{path} = "$::DOCROOT/$host$uri";
302		361
303	$self->access_check;	362	$self->access_check;
304	}	363	}
305		364
306	sub server_address {
307	my $self = shift;
308	my ($port, $iaddr) = unpack_sockaddr_in $self->{fh}->getsockname
309	or $self->err(500, "unable to get socket name");
310	((inet_ntoa $iaddr), $port);
311	}
312
313	sub server_host {
314	my $self = shift;
315	if (exists $self->{h}{host}) {
316	return $self->{h}{host};
317	} else {
318	return (($self->server_address)[0]);
319	}
320	}
321
322	sub server_hostport {
323	my $self = shift;
324	my ($host, $port);
325	if (exists $self->{h}{host}) {
326	($host, $port) = ($self->{h}{host}, $self->{server_port});
327	} else {
328	($host, $port) = $self->server_address;
329	}
330	$port = $port == 80 ? "" : ":$port";
331	$host.$port;
332	}
333
334	sub _cgi {	365	sub _cgi {
335	my $self = shift;	366	my $self = shift;
336	my $path = shift;	367	my $path = shift;
337	my $fh;	368	my $fh;
338		369
339	# no two-way xxx supported	370	# no two-way xxx supported
340	if (0 == fork) {	371	if (0 == fork) {
341	open STDOUT, ">&".fileno($self->{fh});	372	open STDOUT, ">&".fileno($self->{fh});
342	if (chdir $::DOCROOT) {	373	if (chdir $::DOCROOT) {
343	$ENV{SERVER_SOFTWARE} = "thttpd-myhttpd"; # we are thttpd-alike	374	$ENV{SERVER_SOFTWARE} = "thttpd-myhttpd"; # we are thttpd-alike
344	$ENV{HTTP_HOST} = $self->server_host;	375	$ENV{HTTP_HOST} = $self->{server_name};
345	$ENV{HTTP_PORT} = $self->{server_host};	376	$ENV{HTTP_PORT} = $self->{server_port};
346	$ENV{SCRIPT_NAME} = $self->{name};	377	$ENV{SCRIPT_NAME} = $self->{name};
347	exec $path;	378	exec $path;
348	}	379	}
349	Coro::State::_exit(0);	380	Coro::State::_exit(0);
350	} else {	381	} else {
		382	die;
351	}	383	}
		384	}
		385
		386	sub server_hostport {
		387	$_[0]{server_port} == 80
		388	? $_[0]{server_name}
		389	: "$_[0]{server_name}:$_[0]{server_port}";
352	}	390	}
353		391
354	sub respond {	392	sub respond {
355	my $self = shift;	393	my $self = shift;
356	my $path = $self->{path};	394	my $path = $self->{path};
…		…
366		404
367	if (-d _ && -r _) {	405	if (-d _ && -r _) {
368	# directory	406	# directory
369	if ($path !~ /\/$/) {	407	if ($path !~ /\/$/) {
370	# create a redirect to get the trailing "/"	408	# create a redirect to get the trailing "/"
371	my $host = $self->server_hostport;	409	# we don't try to avoid the :80
372	$self->err(301, "moved permanently", { Location => "http://$host$self->{uri}/" });	410	$self->err(301, "moved permanently", { Location => "http://".$self->server_hostport."$self->{uri}/" });
373	} else {	411	} else {
374	$ims < $self->{stat}[9]	412	$ims < $self->{stat}[9]
375	or $self->err(304, "not modified");	413	or $self->err(304, "not modified");
376		414
377	if ($self->{method} eq "GET") {
378	if (-r "$path/index.html") {	415	if (-r "$path/index.html") {
379	$self->{path} .= "/index.html";	416	$self->{path} .= "/index.html";
380	$self->handle_file;	417	$self->handle_file;
381	} else {	418	} else {
382	$self->handle_dir;	419	$self->handle_dir;
383	}
384	}	420	}
385	}	421	}
386	} elsif (-f _ && -r _) {	422	} elsif (-f _ && -r _) {
387	-x _ and $self->err(403, "forbidden");	423	-x _ and $self->err(403, "forbidden");
388	$self->handle_file;	424	$self->handle_file;
…		…
421	($l, $h) = ($1, ($2 ne "" \|\| $2 >= $length) ? $2 : $length - 1);	457	($l, $h) = ($1, ($2 ne "" \|\| $2 >= $length) ? $2 : $length - 1);
422	} else {	458	} else {
423	($l, $h) = (0, $length - 1);	459	($l, $h) = (0, $length - 1);
424	goto ignore;	460	goto ignore;
425	}	461	}
426	goto satisfiable if $l >= 0 && $l < $length && $h >= 0 && $h > $l;	462	goto satisfiable if $l >= 0 && $l < $length && $h >= 0 && $h >= $l;
427	}	463	}
428	$hdr->{"Content-Range"} = "bytes */$length";	464	$hdr->{"Content-Range"} = "bytes */$length";
		465	$hdr->{"Content-Length"} = $length;
		466	$self->slog(9, "not satisfiable($self->{h}{range}\|".$self->{h}{"user-agent"}.")");
429	$self->err(416, "not satisfiable", $hdr);	467	$self->err(416, "not satisfiable", $hdr, "");
430		468
431	satisfiable:	469	satisfiable:
432	# check for segmented downloads	470	# check for segmented downloads
433	if ($l && $::NO_SEGMENTED) {	471	if ($l && $::NO_SEGMENTED) {
		472	my $delay = 60;
434	if (%{$uri{$self->{remote_addr}}{$self->{uri}}} > 1) {	473	while (%{$uri{$self->{remote_addr}}{$self->{uri}}} > 1) {
435	Coro::Event::do_timer(after => 15);	474	if ($delay <= 0) {
436
437	$self->err(400, "segmented downloads are not allowed");	475	$self->err(400, "segmented downloads are not allowed",
		476	{ "Content-Type" => "text/html", Connection => "close" }, <<EOF);
		477	<html>
		478	<head>
		479	<title>Segmented downloads are not allowed</title>
		480	</head>
		481	<body bgcolor="#ffffff" text="#000000" link="#0000ff" vlink="#000080" alink="#ff0000">
		482
		483	<p>Segmented downloads are not allowed on this server. Please refer to the
		484	<a href="http://www.goof.com/pcg/marc/animefaq.html#segmented_downloads">FAQ</a>.</p>
		485
		486	</body></html>
		487	EOF
		488	} else {
		489	Coro::Event::do_timer(after => 3); $delay -= 3;
		490	}
438	}	491	}
439	}	492	}
440		493
441	$hdr->{"Content-Range"} = "bytes $l-$h/$length";	494	$hdr->{"Content-Range"} = "bytes $l-$h/$length";
442	@code = (206, "partial content");	495	@code = (206, "partial content");
…		…
459	open $fh, "<", $self->{path}	512	open $fh, "<", $self->{path}
460	or die "$self->{path}: late open failure ($!)";	513	or die "$self->{path}: late open failure ($!)";
461		514
462	$h -= $l - 1;	515	$h -= $l - 1;
463		516
		517	if (0) {
		518	if ($l) {
		519	sysseek $fh, $l, 0;
		520	}
		521	}
		522
464	while ($h > 0) {	523	while ($h > 0) {
		524	if (0) {
		525	sysread $fh, $buf, $h > $::BUFSIZE ? $::BUFSIZE : $h
		526	or last;
		527	} else {
		528	undef $buf;
		529	$aio_requests->down;
465	aio_read($fh, $l, ($h > $::BUFSIZE ? $::BUFSIZE : $h),	530	aio_read($fh, $l, ($h > $::BUFSIZE ? $::BUFSIZE : $h),
466	$buf, 0, sub {	531	$buf, 0, sub {
467	$r = $_[0];	532	$r = $_[0];
468	$current->ready;	533	$current->ready;
469	});	534	});
470	&Coro::schedule;	535	&Coro::schedule;
		536	$aio_requests->up;
471	last unless $r;	537	last unless $r;
		538	}
472	my $w = $self->{fh}->syswrite($buf)	539	my $w = $self->{fh}->syswrite($buf)
473	or last;	540	or last;
474	$::written += $w;	541	$::written += $w;
475	$self->{written} += $w;	542	$self->{written} += $w;
476	$l += $r;	543	$l += $r;

Diff Legend

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

Comparing cvsroot/Coro/myhttpd/httpd.pl (file contents): Revision 1.17 by root, Wed Aug 15 03:06:21 2001 UTC vs. Revision 1.29 by root, Sat Aug 25 15:14:03 2001 UTC

Diff Legend

Comparing cvsroot/Coro/myhttpd/httpd.pl (file contents):
Revision 1.17 by root, Wed Aug 15 03:06:21 2001 UTC vs.
Revision 1.29 by root, Sat Aug 25 15:14:03 2001 UTC