Rocco,
Thanks for responding. I'm reading (re-reading) your message, trying to
digest. I'll play with it some tomorrow and see where I get.
Thanks again
Jay
----- Original Message -----
From: "Rocco Caputo" <[EMAIL PROTECTED]>
To: "Jay Strauss" <[EMAIL PROTECTED]>
Sent: Wednesday, December 31, 2003 8:55 PM
Subject: Re: How to avoid connect,disconnect,connect...in a package
> On Wed, Dec 31, 2003 at 03:37:45PM -0600, Jay Strauss wrote:
> > Hi,
> >
> > I'd like to build an object, which would connect (via
> > POE::Component::Client::TCP) to my POE server. I want the object to
keep
> > the connection open so that I could call the methods and perform useful
> > tasks without having to connect - disconnect within each of my objects
> > methods.
> >
> > Sorta like (pseudo code):
> >
> > package TWS;
> >
> > POE::Component::Client::TCP->new(...);
> >
> > sub quote {
> > # send @_ to the server
> > # process the data sent back by server
> > }
> >
> > sub order {
> > # send @_ to the server
> > }
> >
> > ### then in a nearby piece of code:
> > my $tws = TWS->new;
> > $tws->quote('IBM');
> > $tws->order(10,'IBM');
>
> It looks like you want quote() and order() to block until they're done.
> You can probably use the undocumented (and poorly tested)
> run_one_timeslice() method of POE::Kernel. Please let me know how it
> work for you.
>
> The idea is to create your single client, like this slightly modified
> version of your original client code.
>
> > POE::Component::Client::TCP->new(
> > ...
> > Args => [EMAIL PROTECTED],
> Alias => "client_connection",
> > Started => sub {..},
> > Connected => sub {
> > ...
> > $heap->{server}->put(\$stuff);
> > }
> > },
> >
> > ServerInput => sub {
>
> # If we've received an order, and we're waiting for an
> # order, then clear the semaphore. This will let the
> # run_one_timeslice() loop in TWS fall through.
>
> if ($got_an_order and $heap->{transaction} eq "order") {
> ${$heap->{semaphore}} = 0;
> $heap->{transaction} = "none";
> }
>
> > },
>
> # If something's been flushed to the server, and we're waiting
> # for a quote to be sent, then we can clear the semaphore.
> # The run_one_timeslice() loop in TWS will fall through.
>
> ServerFlushed => sub {
> my $heap = $_[HEAP];
> if ($heap->{transaction} eq "quote") {
> ${$heap->{semaphore}} = 0;
> $heap->{transaction} = "none";
> }
> },
>
> # Also new, and possibly too simplistic for real use.
> Disconnected => sub { $_[KERNEL]->yield("reconnect"),
>
> # Handle some custom events.
> InlineStates => {
> send_quote => sub {
> my ($heap, $semaphore, $stuff) = @_[HEAP, ARG0, ARG1];
> $heap->{server}->put($stuff);
> $heap->{semaphore} = $semaphore;
> $heap->{transaction} = "quote";
> },
>
> do_order => sub {
> my ($heap, $semaphore, $stuff) = @_[HEAP, ARG0, ARG1];
> $heap->{server}->put($stuff);
> $heap->{semaphore} = $semaphore;
> $heap->{transaction} = "order";
> }
> }
> > );
>
> Then your quote() and order() methods post events to "client_connection"
> and wait for completion.
>
> sub quote {
> my ($object, $stuff) = @_;
>
> my $semaphore = 1;
> $poe_kernel->post( client_connection => send_quote, \$semaphore,
$stuff );
> while ($semaphore) {
> $poe_kernel->run_one_timeslice();
> }
> }
>
> sub order {
> my ($object, $stuff) = @_;
>
> my $semaphore = 1;
> $poe_kernel->post( client_connection => do_order => \$semaphore,
$stuff);
> while ($semaphore) {
> $poe_kernel->run_one_timeslice();
> }
> }
>
> That's the theory anyway. None of this code is tested.
>
> --
> Rocco Caputo - [EMAIL PROTECTED] - http://poe.perl.org/
>
>
