POE/net/server_socket.pl

#!/usr/bin/perl -w

use strict;
use Socket qw(inet_ntoa);
use POE qw( Wheel::SocketFactory  Wheel::ReadWrite
            Filter::Line          Driver::SysRW );
use constant PORT => 31008;

new POE::Session (
  _start => \&server_start,
  _stop  => \&server_stop,
);

$poe_kernel->run();
exit;


sub server_start {
  $_[HEAP]->{listener} = new POE::Wheel::SocketFactory
    ( BindPort     => PORT,
      Reuse        => 'yes',
      SuccessState => \&accept_new_client,
      FailureState => \&accept_failed
    );
  print "SERVER: Started listening on port ", PORT, ".\n";
}


sub server_stop {
  print "SERVER: Stopped.\n";
}


sub accept_new_client {
  my ($socket, $peeraddr, $peerport) = @_[ARG0 .. ARG2];
  $peeraddr = inet_ntoa($peeraddr);

  new POE::Session (
    _start => \&child_start,
    _stop  => \&child_stop,
    main   => [ 'child_input', 'child_done', 'child_error' ],
   [ $socket, $peeraddr, $peerport ],
  );
  print "SERVER: Got connection from $peeraddr:$peerport.\n";
}


sub accept_failed {
  my ($function, $error) = @_[ARG0, ARG2];

  delete $_[HEAP]->{listener};
  print "SERVER: call to $function() failed: $error.\n";
}


sub child_start {
  my ($heap, $socket) = @_[HEAP, ARG0];

  $heap->{readwrite} = new POE::Wheel::ReadWrite
    ( Handle => $socket,
      Driver => new POE::Driver::SysRW (),
      Filter => new POE::Filter::Line (),
      InputState   => 'child_input',
      ErrorState   => 'child_error',
    );
  $heap->{readwrite}->put( "Hello, client!" );

  $heap->{peername} = join ':', @_[ARG1, ARG2];
  print "CHILD: Connected to $heap->{peername}.\n";
}


sub child_stop {
  print "CHILD: Stopped.\n";
}


sub child_input {
  my $data = $_[ARG0];

  $data =~ tr{0-9+*/()-}{}cd;
  return unless length $data;
  my $result = eval $data;
  chomp $@;
  $_[HEAP]->{readwrite}->put( $@ || $result );
  print "CHILD: Got input from peer: \"$data\" = $result.\n";
}


sub child_done {
  delete $_[HEAP]->{readwrite};
  print "CHILD: disconnected from ", $_[HEAP]->{peername}, ".\n";
}


sub child_error {
  my ($function, $error) = @_[ARG0, ARG2];

  delete $_[HEAP]->{readwrite};
  print "CHILD: call to $function() failed: $error.\n" if $error;
}
1	#!/usr/bin/perl -w
2
3	use strict;
4	use Socket qw(inet_ntoa);
5	use POE qw( Wheel::SocketFactory Wheel::ReadWrite
6	Filter::Line Driver::SysRW );
7	use constant PORT => 31008;
8
9	new POE::Session (
10	_start => \&server_start,
11	_stop => \&server_stop,
12	);
13
14	$poe_kernel->run();
15	exit;
16
17
18	sub server_start {
19	$_[HEAP]->{listener} = new POE::Wheel::SocketFactory
20	( BindPort => PORT,
21	Reuse => 'yes',
22	SuccessState => \&accept_new_client,
23	FailureState => \&accept_failed
24	);
25	print "SERVER: Started listening on port ", PORT, ".\n";
26	}
27
28
29	sub server_stop {
30	print "SERVER: Stopped.\n";
31	}
32
33
34	sub accept_new_client {
35	my ($socket, $peeraddr, $peerport) = @_[ARG0 .. ARG2];
36	$peeraddr = inet_ntoa($peeraddr);
37
38	new POE::Session (
39	_start => \&child_start,
40	_stop => \&child_stop,
41	main => [ 'child_input', 'child_done', 'child_error' ],
42	[ $socket, $peeraddr, $peerport ],
43	);
44	print "SERVER: Got connection from $peeraddr:$peerport.\n";
45	}
46
47
48	sub accept_failed {
49	my ($function, $error) = @_[ARG0, ARG2];
50
51	delete $_[HEAP]->{listener};
52	print "SERVER: call to $function() failed: $error.\n";
53	}
54
55
56	sub child_start {
57	my ($heap, $socket) = @_[HEAP, ARG0];
58
59	$heap->{readwrite} = new POE::Wheel::ReadWrite
60	( Handle => $socket,
61	Driver => new POE::Driver::SysRW (),
62	Filter => new POE::Filter::Line (),
63	InputState => 'child_input',
64	ErrorState => 'child_error',
65	);
66	$heap->{readwrite}->put( "Hello, client!" );
67
68	$heap->{peername} = join ':', @_[ARG1, ARG2];
69	print "CHILD: Connected to $heap->{peername}.\n";
70	}
71
72
73	sub child_stop {
74	print "CHILD: Stopped.\n";
75	}
76
77
78	sub child_input {
79	my $data = $_[ARG0];
80
81	$data =~ tr{0-9+*/()-}{}cd;
82	return unless length $data;
83	my $result = eval $data;
84	chomp $@;
85	$_[HEAP]->{readwrite}->put( $@ \|\| $result );
86	print "CHILD: Got input from peer: \"$data\" = $result.\n";
87	}
88
89
90	sub child_done {
91	delete $_[HEAP]->{readwrite};
92	print "CHILD: disconnected from ", $_[HEAP]->{peername}, ".\n";
93	}
94
95
96	sub child_error {
97	my ($function, $error) = @_[ARG0, ARG2];
98
99	delete $_[HEAP]->{readwrite};
100	print "CHILD: call to $function() failed: $error.\n" if $error;
101	}
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26