Changeset 9664
- Timestamp:
- 12/13/09 03:48:34 (2 years ago)
- File:
-
- 1 edited
-
trunk/Padre-Plugin-Swarm/junkyard/relay.pl (modified) (5 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Padre-Plugin-Swarm/junkyard/relay.pl
r9120 r9664 8 8 use IO::Socket::Multicast; 9 9 use JSON::XS; 10 use Carp qw( cluck ); 11 10 12 $|++; 11 13 … … 40 42 ) or die $!; 41 43 42 $local_relay->push_write( json => {43 type => 'promote',44 service => 'relay',45 }46 );47 44 48 45 tcp_connect 'swarm.perlide.org' => 12000 , … … 53 50 54 51 my $runtime = AnyEvent->condvar; 52 our $swarm_ready = AnyEvent->condvar; 53 $swarm_ready->recv; 54 55 $local_relay->push_write( json => { 56 type => 'promote', 57 service => 'relay', 58 } 59 ); 60 61 55 62 $runtime->recv; 56 63 … … 98 105 } ); 99 106 $handle->on_read( \&swarm_read ); 107 $swarm_ready->send; 108 100 109 101 110 } … … 150 159 return; 151 160 } 161 162 warn ref $swarm , "Send message , " , $message->{type}; 152 163 $message->{_relay} = $swarm->{token}; 153 $swarm->push_write( json => $message ); 164 $swarm->push_write( json => $message ) 165 if ref $swarm; 154 166 }
Note: See TracChangeset
for help on using the changeset viewer.
