Beefy Boxes and Bandwidth Generously Provided by pair Networks
Your skill will accomplish
what the force of many cannot
 
PerlMonks  

POE Help

by Big_Chicken (Initiate)
on Jul 06, 2004 at 16:51 UTC ( [id://372141]=perlquestion: print w/replies, xml ) Need Help??

Big_Chicken has asked for the wisdom of the Perl Monks concerning the following question:

Hi I have the below code from the POE site and have been playing with it to try and figure out how to get it to work just a little bit better for my needs. I am new to POE so I was wondering the following questsions:


1: When you disconnect from this program without doing a proper disconnect ie: pulling your network cable from the computer, I get an error stating "can not put on undefined value at line 117". Instead of this error how can I get it to gracefully kill that connection? Could I put a "or" goto the error subroutine after the put?


2: Is there any way I can change how much data POE reads at any one time dynamically so that I can play with the data and send it out to the client?


Thanks for your help!


#!/usr/bin/perl use warnings; use strict; $|=1; # Use POE and also the TCP server component. use POE qw(Component::Server::TCP); sub FEED_SERVER_PORT () { 2000 } sub CONSUMER_SERVER_PORT () { 8008 } # A helper to log things. You could also use POE::Component::Logger # to direct logging to a file or syslog. sub printlog { my $message_string = join ( "", @_ ); my $date_string = localtime(); print "$date_string $message_string\n"; } # A table of data consumers. Input from clients attached to the feed # server will be broadcast to every consumer listed in this table. my %clients; # The feed server. Whatever is sent to this server will be broadcast # to every consumer. POE::Component::Server::TCP->new ( Port => FEED_SERVER_PORT, # A server error occurred. Perform a graceless stop. Error => sub { my ( $syscall, $error_number, $error_message ) = @_[ ARG0 .. A +RG2 ]; warn ( "Couldn't start feed server: ", "$syscall error $error_number: $error_message" ); }, # Log that a client has connected to the feed server. ClientConnected => sub { my $client_id = $_[SESSION]->ID(); printlog("Feed connection $client_id started."); }, # Log that a client has disconnected from the feed server. ClientDisconnected => sub { my $client_id = $_[SESSION]->ID(); printlog("Feed connection $client_id stopped."); }, # Broadcast all feed input to any data consumers out there. This # posts a message to each client session, requesting that it send # the input to its client socket. ClientInput => sub { my ( $kernel, $input ) = @_[ KERNEL, ARG0 ]; foreach my $client_id ( keys %clients ) { $kernel->post( $client_id => send_message => $input ); } }, ); # The consumer server. Every consumer connection will receive what # was sent to each feed connection. POE::Component::Server::TCP->new ( Port => CONSUMER_SERVER_PORT, # A server error occurred. Perform a graceless stop. Error => sub { my ( $syscall, $error_number, $error_message ) = @_[ ARG0 .. A +RG2 ]; warn ( "Couldn't start consumer server: ", "$syscall error $error_number: $error_message" ); }, # Register new connections with the clients table, and log their # connections. ClientConnected => sub { my $client_id = $_[SESSION]->ID(); $clients{$client_id} = "alive"; printlog("Consuming connection $client_id started."); }, # Remove departing connections from the clients table, and log # their disconnections. ClientDisconnected => sub { my $client_id = $_[SESSION]->ID(); delete $clients{$client_id}; printlog("Consuming connection $client_id stopped."); }, # Ignore client input. Data consumers cannot talk back to their # feeds. ClientInput => sub { # Do nothing. }, # Custom event handlers go here. The "send_message" event # requests that we send something to the client. InlineStates => { send_message => sub { my ( $heap, $message ) = @_[ HEAP, ARG0 ]; $heap->{client}->put($message); }, }, ); # Run the servers until something stops them. printlog( "Feed server listening on port ", FEED_SERVER_PORT ); printlog( "Consumer server listening on port ", CONSUMER_SERVER_PORT ) +; $poe_kernel->run(); exit 0;

Replies are listed 'Best First'.
Re: POE Help
by RMGir (Prior) on Jul 07, 2004 at 12:49 UTC
    1: When you disconnect from this program without doing a proper disconnect ie: pulling your network cable from the computer, I get an error stating "can not put on undefined value at line 117". Instead of this error how can I get it to gracefully kill that connection? Could I put a "or" goto the error subroutine after the put?

    I'm guessing you get the error because the client's already been cleaned up somewhere. You could do

    $heap->{client}->put($message) if defined $heap->{client};
    I'm guessing cleanup is already in progress at that stage, so if you just avoid the put, the app would probably exit soon anyhow.

    If that doesn't do it, you can exit yourself if !defined $heap->{client}.

    2: Is there any way I can change how much data POE reads at any one time dynamically so that I can play with the data and send it out to the client?

    I think you can set a ClientInputFilter on your TCP server to "chunk" the data yourself, but I'm not sure. Check out POE::Filter::Block.


    Mike
      Well thanks for the help but it still crashes...

      I am beginning to hate POE. HELPPPPP please

        Please clarify. Are you still receiving "can not put on undefined value at line 117" when you replace that line with the one Mike suggested? Namely:

        $heap->{client}->put($message) if defined $heap->{client};

        I find this hard to believe, but stranger things have happened.

        -- Rocco Caputo - http://poe.perl.org/

      Thanks for the information. I took a look at the Filter::Block and see what it says about the data chunks.

Log In?
Username:
Password:

What's my password?
Create A New User
Domain Nodelet?
Node Status?
node history
Node Type: perlquestion [id://372141]
Approved by calin
help
Chatterbox?
and the web crawler heard nothing...

How do I use this?Last hourOther CB clients
Other Users?
Others avoiding work at the Monastery: (4)
As of 2024-03-29 05:48 GMT
Sections?
Information?
Find Nodes?
Leftovers?
    Voting Booth?

    No recent polls found