-
Notifications
You must be signed in to change notification settings - Fork 214
/
EV.pm
60 lines (49 loc) · 1.24 KB
/
EV.pm
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
package Plack::Server::FCGI::EV;
use strict;
use warnings;
use Plack::Util;
use EV;
use FCGI::EV;
use Plack::Server::FCGI::EV::Handler;
use Data::Dumper;
sub new {
my ( $class, %args ) = @_;
my $self = bless {}, $class;
$self->{host} = delete $args{host} || undef;
$self->{port} = delete $args{port} || undef;
$self;
}
sub register_service {
my ($self, $app) = @_;
my $sock = IO::Socket::INET->new(
LocalAddr => $self->{host},
LocalPort => $self->{port},
ReuseAddr => 1,
Proto => 'tcp',
Listen => 10,
Blocking => 0,
) or die "cannot open fcgi server";
$ENV{SERVER_PORT} = $self->{port},
$ENV{SERVER_NAME} = $self->{host},
# warn Dumper \%ENV;
# warn $sock;
my $handler_class = 'Plack::Server::FCGI::EV::Handler';
$handler_class->psgi_app($app);
my $w = EV::io $sock, EV::READ, sub {
my $client = $sock->accept;
# warn $client;
exit unless $client;
$client->blocking(0);
# warn $client;
FCGI::EV->new( $client, $handler_class );
};
$self->{_sock} = $sock;
$self->{_guard} = $w;
return $self;
}
sub run {
my $self = shift;
$self->register_service(@_);
EV::loop;
}
1;