lib/AnyEvent/HTTPD/HTTPServer.pm

   1 package AnyEvent::HTTPD::HTTPServer;
   2 use strict;
   3 no warnings;
   4
   5 use IO::Socket::INET;
   6 use Object::Event;
   7 use AnyEvent::Handle;
   8 use AnyEvent::Socket;
   9
  10 use AnyEvent::HTTPD::HTTPConnection;
  11
  12 our @ISA = qw/Object::Event/;
  13
  14 =head1 NAME
  15
  16 AnyEvent::HTTPD::HTTPServer - A simple and plain http server
  17
  18 =head1 DESCRIPTION
  19
  20 This class handles incoming TCP connections for HTTP clients.
  21 It's used by L<AnyEvent::HTTPD> to do it's job.
  22
  23 It has no public interface yet.
  24
  25 =head1 COPYRIGHT & LICENSE
  26
  27 Copyright 2008 Robin Redeker, all rights reserved.
  28
  29 This program is free software; you can redistribute it and/or modify it
  30 under the same terms as Perl itself.
  31
  32 =cut
  33
  34 sub new {
  35    my $this  = shift;
  36    my $class = ref($this) || $this;
  37    my $self  = { @_ };
  38    bless $self, $class;
  39
  40    my $sock =
  41       $self->{sock} =
  42          IO::Socket::INET->new (
  43             Listen => 10,
  44             LocalPort => $self->{port},
  45             ReuseAddr => 1,
  46             Blocking => 0
  47          );
  48
  49    $sock or die "Couldn't create listening socket: $!";
  50
  51    tcp_server undef, $self->{port}, sub {
  52       my ($fh) = @_;
  53       unless ($fh) {
  54          $self->event (error => "couldn't accept client: $!");
  55          return;
  56       }
  57       $self->accept_connection ($fh);
  58    };
  59
  60    return $self
  61 }
  62
  63 sub accept_connection {
  64    my ($self, $fh) = @_;
  65
  66    my $htc = AnyEvent::HTTPD::HTTPConnection->new (fh => $fh);
  67    $self->{handles}->{$htc} = $htc;
  68
  69    $htc->reg_cb (disconnect => sub {
  70       delete $self->{handles}->{$_[0]};
  71       $self->event (disconnect => $_[0])
  72    });
  73
  74    $self->event (connect => $htc);
  75 }
  76
  77 1;