lib/CWMP/Server.pm

# Dobrica Pavlinusic, <dpavlin@rot13.org> 06/22/07 14:35:38 CEST
package CWMP::Server;

use strict;
use warnings;


use base qw/Class::Accessor/;
__PACKAGE__->mk_accessors( qw/
port
store_path
default_queue
debug
/ );

use CWMP::Session;

use Carp qw/confess/;
use Data::Dump qw/dump/;

=head1 NAME

CWMP::Server - description

=head1 METHODS

=head2 new

  my $server = CWMP::Server->new({
        port => 3333,
        store_path => 'state.db',
        default_queue => [ qw/GetRPCMethods GetParameterNames/ ],                                                           
        debug => 1
  });

Options:

=over 4

=item port

port to listen on

=item store_path

path to L<DBM::Deep> database file to preserve state

=item default_queue

commands which will be issued to every CPE on connect

=back

=cut

sub new {
        my $class = shift;
        my $self = $class->SUPER::new( @_ );

        warn "created ", __PACKAGE__, "(", dump( @_ ), ") object\n" if $self->debug;

        return $self;
}

=head2 run

  $server->run();

=cut

sub run {
        my $self = shift;

        my $listen = IO::Socket::INET->new(
                Listen    => 5,
#               LocalAddr => 'localhost',
                LocalPort => $self->port,
                Proto     => 'tcp',
                Blocking  => 1,
                ReuseAddr => 1,
        );

        warn "ACS waiting for request on port ", $self->port;

        $self->debug( 0 ) unless $self->debug;
        warn "## debug level: ", $self->debug, "\n" if $self->debug;

        warn $self->default_queue ? " queue ( " . join(",",@{$self->default_queue}) . " )" : "",
                "\n";

        while ( my $sock = $listen->accept ) {
                $sock->autoflush(1);

                my $session = CWMP::Session->new({
                        sock => $sock,
                        queue => $self->default_queue,
                        store_path => $self->store_path,
                        debug => $self->debug,
                }) || confess "can't create session";

                while ( $session->process_request ) {
                        warn "...another one bites the dust...\n";
                }

                warn "...returning to accepting new connections\n";
        }
}

1;
1	dpavlin	83	# Dobrica Pavlinusic, <dpavlin@rot13.org> 06/22/07 14:35:38 CEST
2			package CWMP::Server;
3
4			use strict;
5			use warnings;
6
7
8			use base qw/Class::Accessor/;
9			__PACKAGE__->mk_accessors( qw/
10			port
11			store_path
12			default_queue
13			debug
14			/ );
15
16			use CWMP::Session;
17
18			use Carp qw/confess/;
19			use Data::Dump qw/dump/;
20
21			=head1 NAME
22
23			CWMP::Server - description
24
25			=head1 METHODS
26
27			=head2 new
28
29			my $server = CWMP::Server->new({
30			port => 3333,
31			store_path => 'state.db',
32			default_queue => [ qw/GetRPCMethods GetParameterNames/ ],
33			debug => 1
34			});
35
36			Options:
37
38			=over 4
39
40			=item port
41
42			port to listen on
43
44			=item store_path
45
46			path to L<DBM::Deep> database file to preserve state
47
48			=item default_queue
49
50			commands which will be issued to every CPE on connect
51
52			=back
53
54			=cut
55
56			sub new {
57			my $class = shift;
58			my $self = $class->SUPER::new( @_ );
59
60			warn "created ", __PACKAGE__, "(", dump( @_ ), ") object\n" if $self->debug;
61
62			return $self;
63			}
64
65			=head2 run
66
67			$server->run();
68
69			=cut
70
71			sub run {
72			my $self = shift;
73
74			my $listen = IO::Socket::INET->new(
75			Listen => 5,
76			# LocalAddr => 'localhost',
77			LocalPort => $self->port,
78			Proto => 'tcp',
79			Blocking => 1,
80			ReuseAddr => 1,
81			);
82
83			warn "ACS waiting for request on port ", $self->port;
84
85			$self->debug( 0 ) unless $self->debug;
86			warn "## debug level: ", $self->debug, "\n" if $self->debug;
87
88			warn $self->default_queue ? " queue ( " . join(",",@{$self->default_queue}) . " )" : "",
89			"\n";
90
91			while ( my $sock = $listen->accept ) {
92			$sock->autoflush(1);
93
94			my $session = CWMP::Session->new({
95			sock => $sock,
96			queue => $self->default_queue,
97			store_path => $self->store_path,
98			debug => $self->debug,
99			}) \|\| confess "can't create session";
100
101			while ( $session->process_request ) {
102			warn "...another one bites the dust...\n";
103			}
104
105			warn "...returning to accepting new connections\n";
106			}
107			}
108
109			1;