diff options
Diffstat (limited to 'ACE/ace/WIN32_Asynch_IO.cpp')
| -rw-r--r-- | ACE/ace/WIN32_Asynch_IO.cpp | 62 |
1 files changed, 31 insertions, 31 deletions
diff --git a/ACE/ace/WIN32_Asynch_IO.cpp b/ACE/ace/WIN32_Asynch_IO.cpp index 9d925b784b7..4a6c2641845 100644 --- a/ACE/ace/WIN32_Asynch_IO.cpp +++ b/ACE/ace/WIN32_Asynch_IO.cpp @@ -84,7 +84,7 @@ ACE_WIN32_Asynch_Result::post_completion (ACE_Proactor_Impl *proactor) ACE_WIN32_Proactor *win32_proactor = dynamic_cast<ACE_WIN32_Proactor *> (proactor); if (win32_proactor == 0) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("Dynamic cast to WIN32 Proactor failed\n")), -1); @@ -443,7 +443,7 @@ ACE_WIN32_Asynch_Read_Stream::readv (ACE_Message_Block &message_block, // OS should correctly process zero length buffers // if ( msg_space == 0 ) - // ACE_ERROR_RETURN ((LM_ERROR, + // ACELIB_ERROR_RETURN ((LM_ERROR, // ACE_TEXT ("ACE_WIN32_Asynch_Read_Stream::readv:") // ACE_TEXT ("No space in the message block\n")), // -1); @@ -486,7 +486,7 @@ ACE_WIN32_Asynch_Read_Stream::readv (ACE_Message_Block &message_block, bytes_to_read += iov[i].iov_len; if (bytes_to_read == 0) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Read_Stream::readv:") ACE_TEXT ("Attempt to read 0 bytes\n")), -1); @@ -542,7 +542,7 @@ ACE_WIN32_Asynch_Read_Stream::readv (ACE_Message_Block &message_block, if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("WSARecv"))); } @@ -608,7 +608,7 @@ ACE_WIN32_Asynch_Read_Stream::shared_read (ACE_WIN32_Asynch_Read_Stream_Result * if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("ReadFile"))); } @@ -824,7 +824,7 @@ ACE_WIN32_Asynch_Write_Stream::write (ACE_Message_Block &message_block, bytes_to_write = len ; if (bytes_to_write == 0) - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Write_Stream::write:") ACE_TEXT ("Attempt to write 0 bytes\n")), @@ -916,7 +916,7 @@ ACE_WIN32_Asynch_Write_Stream::writev (ACE_Message_Block &message_block, bytes_to_write += iov[i].iov_len; if ( bytes_to_write == 0 ) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Write_Stream::writev:") ACE_TEXT ("Attempt to write 0 bytes\n")), -1); @@ -969,7 +969,7 @@ ACE_WIN32_Asynch_Write_Stream::writev (ACE_Message_Block &message_block, if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("WSASend"))); } @@ -1051,7 +1051,7 @@ ACE_WIN32_Asynch_Write_Stream::shared_write (ACE_WIN32_Asynch_Write_Stream_Resul // queued. if (ACE::debug ()) - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("Initiating write"))); return -1; @@ -1282,7 +1282,7 @@ ACE_WIN32_Asynch_Read_File::read (ACE_Message_Block &message_block, bytes_to_read = space; if ( bytes_to_read == 0 ) - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Read_File::read:") ACE_TEXT ("Attempt to read 0 bytes or no space in the message block\n")), @@ -1343,7 +1343,7 @@ ACE_WIN32_Asynch_Read_File::readv (ACE_Message_Block &message_block, size_t msg_space = msg->space (); if (msg_space < page_size) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Read_File::readv:") ACE_TEXT ("Invalid message block size\n")), -1); @@ -1411,7 +1411,7 @@ ACE_WIN32_Asynch_Read_File::readv (ACE_Message_Block &message_block, if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("ReadFileScatter"))); } @@ -1683,7 +1683,7 @@ ACE_WIN32_Asynch_Write_File::write (ACE_Message_Block &message_block, bytes_to_write = len; if ( bytes_to_write == 0 ) - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Write_File::write:") ACE_TEXT ("Attempt to read 0 bytes\n")), @@ -1749,7 +1749,7 @@ ACE_WIN32_Asynch_Write_File::writev (ACE_Message_Block &message_block, if (msg_len < page_size && (msg->size () - (msg->rd_ptr () - msg->base ()) < page_size || // message block too small bytes_to_write - total_len > page_size ))// NOT last chunk - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Write_File::writev:") ACE_TEXT ("Invalid message block length\n")), -1); @@ -1816,7 +1816,7 @@ ACE_WIN32_Asynch_Write_File::writev (ACE_Message_Block &message_block, if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("WriteFileGather"))); } @@ -2077,7 +2077,7 @@ ACE_WIN32_Asynch_Accept::accept (ACE_Message_Block &message_block, size_t available_space = message_block.space (); size_t space_needed = bytes_to_read + 2 * address_size; if (available_space < space_needed) - ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("Buffer too small\n")), -1); + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("Buffer too small\n")), -1); // WIN Specific. @@ -2100,7 +2100,7 @@ ACE_WIN32_Asynch_Accept::accept (ACE_Message_Block &message_block, { if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("ACE_OS::socket"))); } @@ -2162,7 +2162,7 @@ ACE_WIN32_Asynch_Accept::accept (ACE_Message_Block &message_block, if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("AcceptEx"))); } @@ -2383,7 +2383,7 @@ ACE_WIN32_Asynch_Connect::open (const ACE_Handler::Proxy_Ptr &handler_proxy, // if we are already opened, // we could not create a new handler without closing the previous if (this->flg_open_) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%N:%l:ACE_WIN32_Asynch_Connect::open:") ACE_TEXT ("connector already open\n")), -1); @@ -2415,7 +2415,7 @@ ACE_WIN32_Asynch_Connect::connect (ACE_HANDLE connect_handle, ACE_TRACE ("ACE_WIN32_Asynch_Connect::connect"); if (!this->flg_open_) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%N:%l:ACE_WIN32_Asynch_Connect::connect") ACE_TEXT ("connector was not opened before\n")), -1); @@ -2449,7 +2449,7 @@ ACE_WIN32_Asynch_Connect::connect (ACE_HANDLE connect_handle, if (this->result_map_.bind (connect_handle, result) == -1) { - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Connect::connect: %p\n"), ACE_TEXT ("bind"))); result->set_error (EFAULT); @@ -2492,7 +2492,7 @@ int ACE_WIN32_Asynch_Connect::post_result (ACE_WIN32_Asynch_Connect_Result * res if (this->win32_proactor_ ->post_completion (result) == 0) return 0; - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, ACE_TEXT ("Error:(%P | %t):%p\n"), ACE_TEXT ("ACE_WIN32_Asynch_Connect::post_result: ") ACE_TEXT (" <post_completion> failed"))); @@ -2536,7 +2536,7 @@ ACE_WIN32_Asynch_Connect::connect_i (ACE_WIN32_Asynch_Connect_Result *result, if (handle == ACE_INVALID_HANDLE) { result->set_error (errno); - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Connect::connect_i: %p\n"), ACE_TEXT ("socket")), @@ -2554,7 +2554,7 @@ ACE_WIN32_Asynch_Connect::connect_i (ACE_WIN32_Asynch_Connect_Result *result, sizeof one) == -1) { result->set_error (errno); - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Connect::connect_i: %p\n"), ACE_TEXT ("setsockopt")), @@ -2569,7 +2569,7 @@ ACE_WIN32_Asynch_Connect::connect_i (ACE_WIN32_Asynch_Connect_Result *result, if (ACE_OS::bind (handle, laddr, size) == -1) { result->set_error (errno); - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Connect::connect_i: %p\n"), ACE_TEXT ("bind")), @@ -2581,7 +2581,7 @@ ACE_WIN32_Asynch_Connect::connect_i (ACE_WIN32_Asynch_Connect_Result *result, if (ACE::set_flags (handle, ACE_NONBLOCK) != 0) { result->set_error (errno); - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Connect::connect_i: %p\n"), ACE_TEXT ("set_flags")), @@ -3041,7 +3041,7 @@ ACE_WIN32_Asynch_Transmit_File::transmit_file (ACE_HANDLE file, if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("TransmitFile"))); } @@ -3311,7 +3311,7 @@ ACE_WIN32_Asynch_Read_Dgram::recv (ACE_Message_Block *message_block, // OS should correctly process zero length buffers // if ( msg_space == 0 ) - // ACE_ERROR_RETURN ((LM_ERROR, + // ACELIB_ERROR_RETURN ((LM_ERROR, // ACE_TEXT ("ACE_WIN32_Asynch_Read_Dgram::recv:") // ACE_TEXT ("No space in the message block\n")), // -1); @@ -3346,7 +3346,7 @@ ACE_WIN32_Asynch_Read_Dgram::recv (ACE_Message_Block *message_block, } if (bytes_to_read == 0) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_WIN32_Asynch_Read_Dgram::recv:") ACE_TEXT ("Attempt to read 0 bytes\n")), -1); @@ -3398,7 +3398,7 @@ ACE_WIN32_Asynch_Read_Dgram::recv (ACE_Message_Block *message_block, if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("WSARecvFrom"))); } @@ -3723,7 +3723,7 @@ ACE_WIN32_Asynch_Write_Dgram::send (ACE_Message_Block *message_block, if (ACE::debug ()) { - ACE_DEBUG ((LM_ERROR, + ACELIB_DEBUG ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("WSASendTo"))); } |