diff options
| author | schmidt <douglascraigschmidt@users.noreply.github.com> | 2001-05-17 20:36:23 +0000 |
|---|---|---|
| committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 2001-05-17 20:36:23 +0000 |
| commit | 2757fbc609bbcd963b12198dfde06724cb65bf19 (patch) | |
| tree | 781fd5c851bf88aea7130990ad7cb897099bde76 /ace/WIN32_Asynch_IO.cpp | |
| parent | 60909a0acfca9505dc42df783774ab85bd8bc3fb (diff) | |
| download | ATCD-2757fbc609bbcd963b12198dfde06724cb65bf19.tar.gz | |
ChangeLogTag:Thu May 17 14:36:57 2001 Douglas C. Schmidt <schmidt@tango.doc.wustl.edu>
Diffstat (limited to 'ace/WIN32_Asynch_IO.cpp')
| -rw-r--r-- | ace/WIN32_Asynch_IO.cpp | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/ace/WIN32_Asynch_IO.cpp b/ace/WIN32_Asynch_IO.cpp index 434d9ecb734..3abfa651d21 100644 --- a/ace/WIN32_Asynch_IO.cpp +++ b/ace/WIN32_Asynch_IO.cpp @@ -1956,6 +1956,7 @@ ACE_WIN32_Asynch_Read_Dgram::recv (ACE_Message_Block *message_block, case ERROR_IO_PENDING: // The IO will complete proactively: the OVERLAPPED will still // get queued. + initiate_result = 0; break; default: @@ -1966,11 +1967,11 @@ ACE_WIN32_Asynch_Read_Dgram::recv (ACE_Message_Block *message_block, { ACE_DEBUG ((LM_ERROR, ACE_LIB_TEXT ("%p\n"), - ACE_LIB_TEXT ("ReadFile"))); + ACE_LIB_TEXT ("WSARecvFrom"))); } delete result; - + initiate_result = -1; break; } @@ -1982,6 +1983,7 @@ ACE_WIN32_Asynch_Read_Dgram::recv (ACE_Message_Block *message_block, // addr contains the peer address // flags was updated number_of_bytes_recvd = bytes_recvd; + initiate_result = 1; } return initiate_result; @@ -2236,6 +2238,7 @@ ACE_WIN32_Asynch_Write_Dgram::send (ACE_Message_Block *message_block, case ERROR_IO_PENDING: // The IO will complete proactively: the OVERLAPPED will still // get queued. + initiate_result = 0; break; default: @@ -2246,11 +2249,11 @@ ACE_WIN32_Asynch_Write_Dgram::send (ACE_Message_Block *message_block, { ACE_DEBUG ((LM_ERROR, ACE_LIB_TEXT ("%p\n"), - ACE_LIB_TEXT ("ReadFile"))); + ACE_LIB_TEXT ("WSASendTo"))); } delete result; - + initiate_result = -1; break; } @@ -2262,6 +2265,7 @@ ACE_WIN32_Asynch_Write_Dgram::send (ACE_Message_Block *message_block, // addr contains the peer address // flags was updated number_of_bytes_sent = bytes_sent; + initiate_result = 1; } return initiate_result; |