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

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

revision 24 by knops.gerd, Thu Dec 14 16:29:42 2006 UTC revision 25 by knops.gerd, Sun May 20 19:40:53 2007 UTC
# Line 96  sub newFromServer { Line 96  sub newFromServer {
96          #          #
97          my $self=shift->new();          my $self=shift->new();
98                    
99            $::Statistics->{'total_requests'}++;
100            
101          my $server=shift;          my $server=shift;
102          my $socket=$server->conSocket();          my $socket=$server->conSocket();
103                    
# Line 180  sub checkHandleBits { Line 182  sub checkHandleBits {
182                  my $bytesRead=sysread($socket->{'handle'},$buffer,$MAX_READ_SIZE);                  my $bytesRead=sysread($socket->{'handle'},$buffer,$MAX_READ_SIZE);
183                  if(defined($bytesRead) && $bytesRead>0)                  if(defined($bytesRead) && $bytesRead>0)
184                  {                  {
185                            $::Statistics->{'total_inbound_bytes'}+=$bytesRead;
186                          $self->{'readBuffer'}.=$buffer;                          $self->{'readBuffer'}.=$buffer;
187                          while($self->{'readBuffer'}=~s/^([^\r\n]*)\r?\n//)                          while($self->{'readBuffer'}=~s/^([^\r\n]*)\r?\n//)
188                          {                          {
# Line 218  sub checkHandleBits { Line 221  sub checkHandleBits {
221                                    
222                  if(defined($bytesWritten) && $bytesWritten>0)                  if(defined($bytesWritten) && $bytesWritten>0)
223                  {                  {
224                            $::Statistics->{'total_outbound_bytes'}+=$bytesWritten;
225                          $self->{'writeBuffer'}=substr($self->{'writeBuffer'},$bytesWritten);                          $self->{'writeBuffer'}=substr($self->{'writeBuffer'},$bytesWritten);
226                          if(length($self->{'writeBuffer'})==0)                          if(length($self->{'writeBuffer'})==0)
227                          {                          {

Legend:
Removed from v.24  
changed lines
  Added in v.25

  ViewVC Help
Powered by ViewVC 1.1.26