File Coverage

blib/lib/Event/tcplisten.pm

Criterion	Covered	Total	%
statement	27	44	61.3
branch	0	12	0.0
condition	0	4	0.0
subroutine	9	11	81.8
pod	0	1	0.0
total	36	72	50.0

use strict;
package Event::tcplisten;
use Carp;
use Symbol;
use Socket;
use Fcntl;
use Event 0.50;
use Event::Watcher qw(R W T);
require Event::io;
use base 'Event::io';
use vars qw($VERSION);
$VERSION = '0.06';

'Event::Watcher'->register;

sub new {
    my $class = shift;
    my %arg = @_;

    my $port = delete $arg{port} || die "port required";
    my $cb = delete $arg{cb} || die "cb required";
    for (qw(fd poll)) { carp "$_ ignored" if delete $arg{$_}; }

    my $proto = getprotobyname('tcp');
    socket(my $sock = gensym, PF_INET, SOCK_STREAM, $proto)
	or die "socket: $!";
    setsockopt($sock, SOL_SOCKET, SO_REUSEADDR, pack('l', 1))
	or die "setsockopt: $!";
    bind($sock, sockaddr_in($port, INADDR_ANY)) or die "bind: $!";
    listen($sock, SOMAXCONN)                    or die "listen: $!";

    $class->SUPER::new(%arg, fd => $sock, poll => R, reentrant => 0,
		       max_cb_tm => 5, cb => sub {
			   my ($e) = @_;
			   my $w=$e->w;
			   my $sock = gensym;
			   accept $sock, $w->fd or return;
			   $cb->($w, $sock);
		       });
}

1;

__END__