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 |
|
|
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 |
{ |
{ |
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 |
{ |
{ |