… | |
… | |
86 | |
86 | |
87 | our $VERSION = '0.02'; |
87 | our $VERSION = '0.02'; |
88 | our @EXPORT = qw( |
88 | our @EXPORT = qw( |
89 | NODE $NODE $PORT snd rcv _any_ |
89 | NODE $NODE $PORT snd rcv _any_ |
90 | create_port create_port_on |
90 | create_port create_port_on |
|
|
91 | create_miniport |
91 | become_slave become_public |
92 | become_slave become_public |
92 | ); |
93 | ); |
93 | |
94 | |
94 | =item NODE / $NODE |
95 | =item NODE / $NODE |
95 | |
96 | |
… | |
… | |
166 | sub create_miniport(&) { |
167 | sub create_miniport(&) { |
167 | my $cb = shift; |
168 | my $cb = shift; |
168 | my $id = "$AnyEvent::MP::Base::UNIQ." . ++$AnyEvent::MP::Base::ID; |
169 | my $id = "$AnyEvent::MP::Base::UNIQ." . ++$AnyEvent::MP::Base::ID; |
169 | |
170 | |
170 | $AnyEvent::MP::Base::PORT{$id} = sub { |
171 | $AnyEvent::MP::Base::PORT{$id} = sub { |
|
|
172 | # unshift @_, "$NODE#$id"; |
171 | &$cb |
173 | &$cb |
172 | and delete $AnyEvent::MP::Base::PORT{$id}; |
174 | and delete $AnyEvent::MP::Base::PORT{$id}; |
173 | }; |
175 | }; |
174 | |
176 | |
175 | "$NODE#$id" |
177 | "$NODE#$id" |