/[meteor]/googlecode.com/svn/trunk/Meteor/Subscriber.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 /googlecode.com/svn/trunk/Meteor/Subscriber.pm

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

revision 32 by andrew.betts, Thu Dec 20 21:24:24 2007 UTC revision 35 by andrew.betts, Fri Jan 25 17:12:02 2008 UTC
# Line 89  sub pingPersistentConnections { Line 89  sub pingPersistentConnections {
89          my $msg=$::CONF{'PingMessage'};          my $msg=$::CONF{'PingMessage'};
90          my @cons=values %PersistentConnections;          my @cons=values %PersistentConnections;
91                    
92          map { $_->write($msg) } @cons;          map { $_->write($msg.chr(0)) } @cons;
93  }  }
94    
95  sub checkPersistentConnectionsForMaxTime {  sub checkPersistentConnectionsForMaxTime {
# Line 152  sub processLine { Line 152  sub processLine {
152                          my $channels={};                          my $channels={};
153                          my $channelName;                          my $channelName;
154                          my $offset;                          my $offset;
155                          foreach my $chandef (@channelData)                          foreach my $chandef (@channelData) {
156                          {                                  if($chandef=~/^([a-z0-9]+)(.(r|b|h)([0-9]*))?$/i) {
                                 if($chandef=~/^([a-z0-9]+)(.(r|b|h)([0-9]*))?$/)  
                                 {  
157                                          $channelName = $1;                                          $channelName = $1;
158                                          $channels->{$channelName}->{'startIndex'} = undef;                                          $channels->{$channelName}->{'startIndex'} = undef;
159                                          for ($3) {                                          if ($3) {
160                                                  $offset = $4;                                             $offset = $4;
161                                                  /r/ && do { $channels->{$channelName}->{'startIndex'} = $offset; last; };                                             if ($3 eq 'r') { $channels->{$channelName}->{'startIndex'} = $offset; }
162                                                  /b/ && do { $channels->{$channelName}->{'startIndex'} = -$offset; last; };                                             if ($3 eq 'b') { $channels->{$channelName}->{'startIndex'} = -$offset; }
163                                                  /h/ && do { $channels->{$channelName}->{'startIndex'} = 0; last; };                                             if ($3 eq 'h') { $channels->{$channelName}->{'startIndex'} = 0; }
164                                          }                                          }
165                                  }                                  }
166                          }                          }
# Line 274  sub emitHeader { Line 272  sub emitHeader {
272                  }                  }
273          /gex;          /gex;
274                    
275          $self->write($header);          $self->write($header.chr(0));
276  }  }
277    
278  sub sendMessage {  sub sendMessage {
# Line 284  sub sendMessage { Line 282  sub sendMessage {
282                    
283          $numMsgInThisBatch=1 unless(defined($numMsgInThisBatch));          $numMsgInThisBatch=1 unless(defined($numMsgInThisBatch));
284                    
285          $self->write($msg);          $self->write($msg.chr(0));
286                    
287          $::Statistics->{'messages_served'}+=$numMsgInThisBatch;          $::Statistics->{'messages_served'}+=$numMsgInThisBatch;
288                    

Legend:
Removed from v.32  
changed lines
  Added in v.35

  ViewVC Help
Powered by ViewVC 1.1.26