how to use AnyEvent::Handle on the child of AnyEvent::Run (aka portable_socketpair)?

[Andrew Whatson]

Hi Fulko,

I think you need to turn on autoflush on STDOUT.  After putting $|=1,
I get the following output which seems correct:

parent tx 'first send'
parent rx: child started
parent rx: child rx: first send to child

parent rx: child timer
parent tx
parent rx: child rx: sent to child

parent rx: child timer
parent tx
parent rx: child timer
parent rx: child rx: sent to child

parent rx: child timer
parent tx
parent rx: child rx: sent to child

Regards,
Andrew Whatson

On 20 November 2013 06:03, Fulko Hew <fulko.hew at gmail.com> wrote:
> I'm trying to use AnyEvent:Run, but I need to make my child smarter.
> and make it an AnyEvent style process that uses 'event driven I/O'.
> But I can't seem to get anywhere, and I'm obviously missing... something.
>
> I'm attempting the test example below.
>
> What I see is the child successfully sending and the parent receiving.
> But I'm not getting the parent-to-child pat,  and I don't know if its a
> problem in parent or in the child, or I'm just doing it wrong.
>
> use strict;
> use warnings;
> use Socket;
> use AnyEvent;
> use AnyEvent::Run;
> use AnyEvent::Handle;
>
> sub send_msg_to_parent { print "$_[0]\n"; }
>
> sub child_proc {
>     my $child_hdl = new AnyEvent::Handle (
>         fh  => \*STDIN,
>         on_read => sub {
>                        my $hdl = shift;
>                        my $d = $hdl->{rbuf};
>                        $hdl->{rbuf} = '';
>                        send_msg_to_parent("child rx: $d");
>                        },
>     );
>     my $child_timer = AnyEvent->timer (  # send a watchdog msg
>         after       => 2,
>         interval    => 2,
>         cb          => sub {send_msg_to_parent("child timer"),
>     );
>     send_msg_to_parent("child started");
>     my $child_cv = AnyEvent->condvar;
>     $child_cv->wait;
> }
>
>
> my $child = AnyEvent::Run->new(
>     cmd     => sub { child_proc() },
>     on_read => sub {
>                    my $hdl = shift;
>                    my $d = $hdl->{rbuf};
>                    $hdl->{rbuf} = '';
>                    print "parent rx: $d";
>                    },
>     on_error    => sub { print "child died\n"; },
> );
> my $parent_timer = AnyEvent->timer (
>     after       => 3,
>     interval    => 3,
>     cb          => sub { $child->push_write("sent to child\n"); print
> "parent tx\n";},
> );
> $child->push_write("first send to child\n"); print "parent tx 'first
> send'\n";
> my $cv = AnyEvent->condvar;
> $cv->wait;
>
>
> _______________________________________________
> anyevent mailing list
> anyevent at lists.schmorp.de
> http://lists.schmorp.de/mailman/listinfo/anyevent