ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent-Fork-RPC/RPC.pm
(Generate patch)

Comparing AnyEvent-Fork-RPC/RPC.pm (file contents):
Revision 1.40 by root, Sat May 21 07:11:09 2016 UTC vs.
Revision 1.42 by root, Tue Mar 26 04:07:02 2019 UTC

… …
391use Errno (); 391use Errno ();
392use Guard (); 392use Guard ();
393 393
394use AnyEvent; 394use AnyEvent;
395 395
396our $VERSION = 1.22; 396our $VERSION = 1.23;
397 397
398=item my $rpc = AnyEvent::Fork::RPC::run $fork, $function, [key => value...] 398=item my $rpc = AnyEvent::Fork::RPC::run $fork, $function, [key => value...]
399 399
400The traditional way to call it. But it is way cooler to call it in the 400The traditional way to call it. But it is way cooler to call it in the
401following way: 401following way:
… …
661 my $module = "AnyEvent::Fork::RPC::" . ($arg{async} ? "Async" : "Sync"); 661 my $module = "AnyEvent::Fork::RPC::" . ($arg{async} ? "Async" : "Sync");
662 662
663 $self->require ($module) 663 $self->require ($module)
664 ->send_arg ($function, $arg{init}, $serialiser, $arg{done} || "$module\::do_exit") 664 ->send_arg ($function, $arg{init}, $serialiser, $arg{done} || "$module\::do_exit")
665 ->run ("$module\::run", sub { 665 ->run ("$module\::run", sub {
666 $fh = shift; 666 $fh = shift
667 or return $on_error->("connection failed");
667 668
668 my ($id, $len); 669 my ($id, $len);
669 $rw = AE::io $fh, 0, sub { 670 $rw = AE::io $fh, 0, sub {
670 $rlen = $rlen * 2 + 16 if $rlen - 128 < length $rbuf; 671 $rlen = $rlen * 2 + 16 if $rlen - 128 < length $rbuf;
671 $len = sysread $fh, $rbuf, $rlen - length $rbuf, length $rbuf; 672 $len = sysread $fh, $rbuf, $rlen - length $rbuf, length $rbuf;

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines