/[Sack]/trunk/lib/Sack/Server.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /trunk/lib/Sack/Server.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 247 by dpavlin, Thu Nov 26 22:08:36 2009 UTC revision 248 by dpavlin, Thu Nov 26 22:18:19 2009 UTC
# Line 114  sub run_view { Line 114  sub run_view {
114          Sack::Merge->clean;          Sack::Merge->clean;
115          delete( $info->{view} );          delete( $info->{view} );
116          delete( $info->{merge} );          delete( $info->{merge} );
117            delete( $info->{shard} );
118          to_all { code => $code, view => $path };          to_all { code => $code, view => $path };
119  };  };
120    
# Line 325  while (1) { Line 326  while (1) {
326                                          my $added = Sack::Merge->add( $data->{out} ) if defined $data->{out};                                          my $added = Sack::Merge->add( $data->{out} ) if defined $data->{out};
327                                          $info->{merge}->{ $data->{view} }->{ $data->{port} } = $added;                                          $info->{merge}->{ $data->{view} }->{ $data->{port} } = $added;
328                                          $info->{view }->{ $data->{view} }->{ $data->{port} } = $data->{on_shard};                                          $info->{view }->{ $data->{view} }->{ $data->{port} } = $data->{on_shard};
329                                            # refresh shard allocation
330                                            $info->{shard}->{ $_ } = $data->{port} foreach keys %{ $data->{on_shard} };
331                                  } elsif ( exists $data->{port} ) {                                  } elsif ( exists $data->{port} ) {
332                                          push @responses, $data;                                          push @responses, $data;
333                                          warn "# ",dump($data),$/;                                          warn "# ",dump($data),$/;
Legend:
Removed from v.247  
changed lines
  Added in v.248
  ViewVC Help
Powered by ViewVC 1.1.26