/[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 13 by knops.gerd, Mon Apr 30 18:16:17 2007 UTC revision 17 by knops.gerd, Tue May 1 17:10:10 2007 UTC
# Line 132  sub processLine { Line 132  sub processLine {
132                          my $startIndex=undef;                          my $startIndex=undef;
133                          my $backtrack=undef;                          my $backtrack=undef;
134                          my $persist=1;                          my $persist=1;
                         my $anyPersist=0;  
135                          my $subscriberID=undef;                          my $subscriberID=undef;
136                          my $channels={};                          my $channels={};
137                          foreach my $formElement (@formData)                          foreach my $formElement (@formData)
# Line 151  sub processLine { Line 150  sub processLine {
150                                                                                                    
151                                                  $startIndex=-$backtrack if(!defined($startIndex) && defined($backtrack));                                                  $startIndex=-$backtrack if(!defined($startIndex) && defined($backtrack));
152                                                  $channels->{$channelName}->{'startIndex'}=$startIndex;                                                  $channels->{$channelName}->{'startIndex'}=$startIndex;
                                                 $channels->{$channelName}->{'persist'}=$persist;  
                                                 $anyPersist|=$persist;  
153                                                                                                    
154                                                  $startIndex=undef;                                                  $startIndex=undef;
155                                                  $backtrack=undef;                                                  $backtrack=undef;
                                                 $persist=1;  
156                                          }                                          }
157                                          $channelName=$1;                                          $channelName=$1;
158                                  }                                  }
# Line 210  sub processLine { Line 206  sub processLine {
206                                                                    
207                                  $startIndex=-$backtrack if(!defined($startIndex) && defined($backtrack));                                  $startIndex=-$backtrack if(!defined($startIndex) && defined($backtrack));
208                                  $channels->{$channelName}->{'startIndex'}=$startIndex;                                  $channels->{$channelName}->{'startIndex'}=$startIndex;
                                 $channels->{$channelName}->{'persist'}=$persist;  
                                 $anyPersist|=$persist;  
209                          }                          }
210                                                    
211                          delete($self->{'headerBuffer'});                          delete($self->{'headerBuffer'});
212                                                    
213                          if(defined($subscriberID) && $anyPersist)                          if(defined($subscriberID) && $persist)
214                          {                          {
215                                  $self->{'subscriberID'}=$subscriberID;                                  $self->{'subscriberID'}=$subscriberID;
216                                  $self->deleteSubscriberWithID($subscriberID);                                  $self->deleteSubscriberWithID($subscriberID);
# Line 227  sub processLine { Line 221  sub processLine {
221                          {                          {
222                                  $self->emitOKHeader();                                  $self->emitOKHeader();
223                                                                    
224                                  $self->setChannels($channels);                                  $self->setChannels($channels,$persist);
225                                                                    
226                                  $self->close(1) unless($anyPersist);                                  $self->close(1) unless($persist);
227                                                                    
228                                  return;                                  return;
229                          }                          }
# Line 253  sub processLine { Line 247  sub processLine {
247  sub setChannels {  sub setChannels {
248          my $self=shift;          my $self=shift;
249          my $channels=shift;          my $channels=shift;
250            my $persist=shift;
251                    
252          foreach my $channelName (keys %{$channels})          foreach my $channelName (keys %{$channels})
253          {          {
                 my $persist=$channels->{$channelName}->{'persist'};  
254                  my $startIndex=$channels->{$channelName}->{'startIndex'};                  my $startIndex=$channels->{$channelName}->{'startIndex'};
255                                    
256                  my $channel=Meteor::Channel->channelWithName($channelName);                  my $channel=Meteor::Channel->channelWithName($channelName);

Legend:
Removed from v.13  
changed lines
  Added in v.17

  ViewVC Help
Powered by ViewVC 1.1.26