| … | |
… | |
| 391 | use Errno (); |
391 | use Errno (); |
| 392 | use Guard (); |
392 | use Guard (); |
| 393 | |
393 | |
| 394 | use AnyEvent; |
394 | use AnyEvent; |
| 395 | |
395 | |
| 396 | our $VERSION = 1.2; |
396 | our $VERSION = 1.21; |
| 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 | |
| 400 | The traditional way to call it. But it is way cooler to call it in the |
400 | The traditional way to call it. But it is way cooler to call it in the |
| 401 | following way: |
401 | following way: |
| … | |
… | |
| 629 | }; |
629 | }; |
| 630 | |
630 | |
| 631 | my $module = "AnyEvent::Fork::RPC::" . ($arg{async} ? "Async" : "Sync"); |
631 | my $module = "AnyEvent::Fork::RPC::" . ($arg{async} ? "Async" : "Sync"); |
| 632 | |
632 | |
| 633 | $self->require ($module) |
633 | $self->require ($module) |
| 634 | ->send_arg ($function, $arg{init}, $serialiser, $arg{done} || "CORE::exit") |
634 | ->send_arg ($function, $arg{init}, $serialiser, $arg{done} || "$module\::do_exit") |
| 635 | ->run ("$module\::run", sub { |
635 | ->run ("$module\::run", sub { |
| 636 | $fh = shift; |
636 | $fh = shift; |
| 637 | |
637 | |
| 638 | my ($id, $len); |
638 | my ($id, $len); |
| 639 | $rw = AE::io $fh, 0, sub { |
639 | $rw = AE::io $fh, 0, sub { |
