| … | |
… | |
| 558 | AnyEvent::MP::Kernel::eval_on $node, $expr, port { &$cv }; |
558 | AnyEvent::MP::Kernel::eval_on $node, $expr, port { &$cv }; |
| 559 | mon $node, $cv; |
559 | mon $node, $cv; |
| 560 | |
560 | |
| 561 | my ($err, @res) = $cv->recv; |
561 | my ($err, @res) = $cv->recv; |
| 562 | |
562 | |
| 563 | die $err if length $err; |
563 | die "$err @res" if length $err; |
| 564 | |
564 | |
| 565 | print +(substr JSON::XS->new->encode (\@res), 1, -1), "\n"; |
565 | print +(substr JSON::XS->new->encode (\@res), 1, -1), "\n"; |
| 566 | } |
566 | } |
| 567 | |
567 | |
| 568 | sub docmd; |
568 | sub docmd; |
| … | |
… | |
| 615 | |
615 | |
| 616 | trace shift @ARGV; |
616 | trace shift @ARGV; |
| 617 | }, |
617 | }, |
| 618 | restart => sub { |
618 | restart => sub { |
| 619 | my $node = node_of shift @ARGV; |
619 | my $node = node_of shift @ARGV; |
| 620 | node_eval $node, "AnyEvent::Watchdog::Util::restart"; |
620 | node_eval $node, 'my $w; $w = AE::timer 0.5, 0, sub { undef $w; AnyEvent::Watchdog::Util::restart }; ()'; |
| 621 | }, |
621 | }, |
| 622 | |
622 | |
| 623 | setnodeid => sub { |
623 | setnodeid => sub { |
| 624 | @ARGV >= 1 |
624 | @ARGV >= 1 |
| 625 | or die "shared secret missing\n"; |
625 | or die "shared secret missing\n"; |
