diff options
| author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1997-04-29 07:35:15 +0000 |
|---|---|---|
| committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1997-04-29 07:35:15 +0000 |
| commit | a0d46be91f88bc4409bd11ad6dbb29f9e8b55d37 (patch) | |
| tree | e341c6d9a261cf2b97604e3e7c08678d14f13ab0 /ace/Reactor.cpp | |
| parent | fed3712cbe0d829fad21151ba0fa2ad089fecdfd (diff) | |
| download | ATCD-a0d46be91f88bc4409bd11ad6dbb29f9e8b55d37.tar.gz | |
*** empty log message ***
Diffstat (limited to 'ace/Reactor.cpp')
| -rw-r--r-- | ace/Reactor.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ace/Reactor.cpp b/ace/Reactor.cpp index ed9c6d43014..d779fd57546 100644 --- a/ace/Reactor.cpp +++ b/ace/Reactor.cpp @@ -663,7 +663,7 @@ ACE_Reactor_Notify::handle_input (ACE_HANDLE handle) ssize_t n; int number_dispatched = 0; - while ((n = ACE::recv (handle, (char *) &buffer, sizeof buffer)) != -1) + while ((n = ACE::recv (handle, (char *) &buffer, sizeof buffer)) > 0) { // If eh == 0 then another thread is unblocking the ACE_Reactor // to update the ACE_Reactor's internal structures. Otherwise, @@ -705,7 +705,7 @@ ACE_Reactor_Notify::handle_input (ACE_HANDLE handle) // Reassign number_dispatched to -1 if things have gone seriously // wrong. - if (n == -1 && errno != EWOULDBLOCK) + if (n <= 0 && errno != EWOULDBLOCK) number_dispatched = -1; // Enqueue ourselves into the list of waiting threads. When we |