1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
package HTTP::Proxy::Engine::Threaded;
$HTTP::Proxy::Engine::Threaded::VERSION = '0.304';
use strict;
use HTTP::Proxy;
my $can_use_threads;
BEGIN {
$can_use_threads = eval 'use threads; 1';
}
# A massive hack of Engine::Fork to use the threads stuff
# Basically created to work under win32 so that the filters
# can share global caches among themselves
# Angelos Karageorgiou angelos@unix.gr
our @ISA = qw( HTTP::Proxy::Engine );
our %defaults = (
max_clients => 60,
);
__PACKAGE__->make_accessors( qw( kids select ), keys %defaults );
sub new {
die "This Perl not built to support threads"
if !$can_use_threads;
shift->SUPER::new(@_);
}
sub start {
my $self = shift;
$self->kids( [] );
$self->select( IO::Select->new( $self->proxy->daemon ) );
}
sub run {
my $self = shift;
my $proxy = $self->proxy;
my $kids = $self->kids;
# check for new connections
my @ready = $self->select->can_read(1);
for my $fh (@ready) { # there's only one, anyway
# single-process proxy (useful for debugging)
# accept the new connection
my $conn = $fh->accept;
my $child=threads->new(\&_worker,$proxy,$conn);
if ( !defined $child ) {
$conn->close;
$proxy->log( HTTP::Proxy::ERROR, "PROCESS", "Cannot spawn thread" );
next;
}
$child->detach();
}
}
sub stop {
my $self = shift;
my $kids = $self->kids;
# not needed
}
sub _worker {
my $proxy=shift;
my $conn=shift;
$proxy->serve_connections($conn);
$conn->close();
return;
}
1;
__END__
=head1 NAME
HTTP::Proxy::Engine::Threaded - A scoreboard-based HTTP::Proxy engine
=head1 SYNOPSIS
my $proxy = HTTP::Proxy->new( engine => 'Threaded' );
=head1 DESCRIPTION
This module provides a threaded engine to L<HTTP::Proxy>.
=head1 METHODS
The module defines the following methods, used by L<HTTP::Proxy> main loop:
=over 4
=item start()
Initialize the engine.
=item run()
Implements the forking logic: a new process is forked for each new
incoming TCP connection.
=item stop()
Reap remaining child processes.
=back
=head1 SEE ALSO
L<HTTP::Proxy>, L<HTTP::Proxy::Engine>.
=head1 AUTHORS
Angelos Karageorgiou C<< <angelos@unix.gr> >>. (Actual code)
Philippe "BooK" Bruhat, C<< <book@cpan.org> >>. (Documentation)
=head1 COPYRIGHT
Copyright 2010-2015, Philippe Bruhat.
=head1 LICENSE
This module is free software; you can redistribute it or modify it under
the same terms as Perl itself.
=cut
|
