diff options
| author | Ossama Othman <ossama-othman@users.noreply.github.com> | 2005-02-01 04:52:36 +0000 |
|---|---|---|
| committer | Ossama Othman <ossama-othman@users.noreply.github.com> | 2005-02-01 04:52:36 +0000 |
| commit | ad845e5d3a28ebd1417327120e1fc15c7af340a4 (patch) | |
| tree | b909c994dfb4d53850e26ac3e50628dd4f6986a8 | |
| parent | be30e2cae28f3fc28131a6a0320f5d09e06cdb06 (diff) | |
| download | ATCD-ad845e5d3a28ebd1417327120e1fc15c7af340a4.tar.gz | |
ChangeLogTag:Mon Jan 31 20:48:04 2005 Ossama Othman <ossama@dre.vanderbilt.edu>
| -rw-r--r-- | tests/Proactor_Test.cpp | 16 | ||||
| -rw-r--r-- | tests/Proactor_Test_IPV6.cpp | 16 |
2 files changed, 16 insertions, 16 deletions
diff --git a/tests/Proactor_Test.cpp b/tests/Proactor_Test.cpp index baac57216ba..9ec8cb123d8 100644 --- a/tests/Proactor_Test.cpp +++ b/tests/Proactor_Test.cpp @@ -1571,13 +1571,13 @@ Client::handle_write_stream (const ACE_Asynch_Write_Stream::Result &result) if (result.error () == 0 && result.bytes_transferred () > 0) { this->total_snd_ += result.bytes_transferred (); - if (this->total_snd_ >= xfer_limit) - { - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("(%t) Client %d sent %d, limit %d\n"), - this->id_, this->total_snd_, xfer_limit)); - this->close (); - } + if (this->total_snd_ >= xfer_limit) + { + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("(%t) Client %d sent %d, limit %d\n"), + this->id_, this->total_snd_, xfer_limit)); + this->close (); + } if (duplex != 0) // full duplex, continue write { if ((this->total_snd_- this->total_rcv_) < 1024*32 ) //flow control @@ -1809,7 +1809,7 @@ parse_args (int argc, ACE_TCHAR *argv[]) case 'x': // xfer limit xfer_limit = static_cast<size_t> (ACE_OS::atoi (get_opt.opt_arg ())); if (xfer_limit == 0) - xfer_limit = 1; // Bare minimum. + xfer_limit = 1; // Bare minimum. break; case 'b': // both client and server both = 1; diff --git a/tests/Proactor_Test_IPV6.cpp b/tests/Proactor_Test_IPV6.cpp index 0e716bac701..565aa749107 100644 --- a/tests/Proactor_Test_IPV6.cpp +++ b/tests/Proactor_Test_IPV6.cpp @@ -1611,13 +1611,13 @@ Client::handle_write_stream (const ACE_Asynch_Write_Stream::Result &result) if (result.error () == 0 && result.bytes_transferred () > 0) { this->total_snd_ += result.bytes_transferred (); - if (this->total_snd_ >= xfer_limit) - { - ACE_DEBUG ((LM_DEBUG, - ACE_TEXT ("(%t) Client %d sent %d, limit %d\n"), - this->id_, this->total_snd_, xfer_limit)); - this->close (); - } + if (this->total_snd_ >= xfer_limit) + { + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("(%t) Client %d sent %d, limit %d\n"), + this->id_, this->total_snd_, xfer_limit)); + this->close (); + } if (duplex != 0) // full duplex, continue write { if ((this->total_snd_- this->total_rcv_) < 1024*32 ) //flow control @@ -1853,7 +1853,7 @@ parse_args (int argc, ACE_TCHAR *argv[]) case 'x': // xfer limit xfer_limit = static_cast<size_t> (ACE_OS::atoi (get_opt.opt_arg ())); if (xfer_limit == 0) - xfer_limit = 1; // Bare minimum. + xfer_limit = 1; // Bare minimum. break; case 'b': // both client and server both = 1; |