| … | |
… | |
| 702 | EOF |
702 | EOF |
| 703 | my $json = JSON::XS->new->pretty->ascii; |
703 | my $json = JSON::XS->new->pretty->ascii; |
| 704 | my $pkg = "AnyEvent::MP::Kernel"; |
704 | my $pkg = "AnyEvent::MP::Kernel"; |
| 705 | my $cv = AE::cv; |
705 | my $cv = AE::cv; |
| 706 | my $echo = port { |
706 | my $echo = port { |
| 707 | print "\n ECHO<$AnyEvent::MP::Kernel::SRCNODE> ", $json->encode (\@_), "\n$node $pkg> "; |
707 | print "\nECHO<$AnyEvent::MP::Kernel::SRCNODE> ", $json->encode (\@_), "\n$node $pkg> "; |
| 708 | }; |
708 | }; |
| 709 | print "$node $pkg> "; |
709 | print "$node $pkg> "; |
| 710 | my $t = AE::io *STDIN, 0, sub { |
710 | my $t = AE::io *STDIN, 0, sub { |
| 711 | chomp (my $line = <STDIN>); |
711 | chomp (my $line = <STDIN>); |
| 712 | |
712 | |
| 713 | if ($line =~ s/^=//) { |
713 | if ($line =~ s/^=//) { |
| 714 | if (length $line) { |
714 | if (length $line) { |
| 715 | $node = $line; |
715 | $node = $line; |
| 716 | } else { |
716 | } else { |
| 717 | print +(join " ", AnyEvent::MP::Kernel::up_nodes), "\n"; |
717 | db_keys "'l" => sub { |
|
|
718 | print "\nnodes: ", (join " ", sort @{ $_[0] }), "\n$node $pkg> "; |
|
|
719 | }; |
| 718 | } |
720 | } |
| 719 | } elsif ($line =~ /^\s*package\s+(\S+)\s*;?\s*$/) { |
721 | } elsif ($line =~ /^\s*package\s+(\S+)\s*;?\s*$/) { |
| 720 | $pkg = $1; |
722 | $pkg = $1; |
| 721 | } elsif ($line =~ /\S/) { |
723 | } elsif ($line =~ /\S/) { |
| 722 | my $time = AE::time; |
724 | my $time = AE::time; |
