/[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 35 by andrew.betts, Fri Jan 25 17:12:02 2008 UTC revision 44 by knops.gerd, Sun Feb 3 23:53:55 2008 UTC
# Line 44  package Meteor::Subscriber; Line 44  package Meteor::Subscriber;
44                    
45          our %PersistentConnections=();          our %PersistentConnections=();
46          our $NumAcceptedConnections=0;          our $NumAcceptedConnections=0;
47        
48    
49  ###############################################################################  ###############################################################################
50  # Factory methods  # Factory methods
# Line 79  sub deleteSubscriberWithID { Line 80  sub deleteSubscriberWithID {
80                    
81          if(exists($PersistentConnections{$id}))          if(exists($PersistentConnections{$id}))
82          {          {
83                  $PersistentConnections{$id}->close(1);                  $PersistentConnections{$id}->close();
84          }          }
85  }  }
86    
# Line 89  sub pingPersistentConnections { Line 90  sub pingPersistentConnections {
90          my $msg=$::CONF{'PingMessage'};          my $msg=$::CONF{'PingMessage'};
91          my @cons=values %PersistentConnections;          my @cons=values %PersistentConnections;
92                    
93          map { $_->write($msg.chr(0)) } @cons;          map { $_->write($msg) } @cons;
94  }  }
95    
96  sub checkPersistentConnectionsForMaxTime {  sub checkPersistentConnectionsForMaxTime {
# Line 272  sub emitHeader { Line 273  sub emitHeader {
273                  }                  }
274          /gex;          /gex;
275                    
276          $self->write($header.chr(0));          $self->write($header);
277  }  }
278    
279  sub sendMessage {  sub sendMessage {
# Line 282  sub sendMessage { Line 283  sub sendMessage {
283                    
284          $numMsgInThisBatch=1 unless(defined($numMsgInThisBatch));          $numMsgInThisBatch=1 unless(defined($numMsgInThisBatch));
285                    
286          $self->write($msg.chr(0));          $self->write($msg);
287                    
288          $::Statistics->{'messages_served'}+=$numMsgInThisBatch;          $::Statistics->{'messages_served'}+=$numMsgInThisBatch;
289                    
# Line 343  sub close { Line 344  sub close {
344                  }                  }
345          }          }
346                    
         $::Statistics->{'current_subscribers'}--;  
           
347          $self->SUPER::close();          $self->SUPER::close();
348  }  }
349    
350    sub didClose {
351            
352            $::Statistics->{'current_subscribers'}--;
353    }
354    
355  sub checkForMaxTime {  sub checkForMaxTime {
356          my $self=shift;          my $self=shift;
357          my $time=shift;          my $time=shift;

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

  ViewVC Help
Powered by ViewVC 1.1.26