diff options
Diffstat (limited to 'ACE/ace/POSIX_Asynch_IO.cpp')
| -rw-r--r-- | ACE/ace/POSIX_Asynch_IO.cpp | 64 |
1 files changed, 32 insertions, 32 deletions
diff --git a/ACE/ace/POSIX_Asynch_IO.cpp b/ACE/ace/POSIX_Asynch_IO.cpp index 80b2ef218bc..13d02bf1f2f 100644 --- a/ACE/ace/POSIX_Asynch_IO.cpp +++ b/ACE/ace/POSIX_Asynch_IO.cpp @@ -97,7 +97,7 @@ ACE_POSIX_Asynch_Result::post_completion (ACE_Proactor_Impl *proactor_impl) ACE_POSIX_Proactor *posix_proactor = dynamic_cast<ACE_POSIX_Proactor *> (proactor_impl); if (posix_proactor == 0) - ACE_ERROR_RETURN ((LM_ERROR, "Dynamic cast to POSIX Proactor failed\n"), -1); + ACELIB_ERROR_RETURN ((LM_ERROR, "Dynamic cast to POSIX Proactor failed\n"), -1); // Post myself. return posix_proactor->post_completion (this); @@ -411,7 +411,7 @@ ACE_POSIX_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_POSIX_Asynch_Write_Stream::write:") ACE_TEXT ("Attempt to write 0 bytes\n")), @@ -522,7 +522,7 @@ ACE_POSIX_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_POSIX_Asynch_Read_File::read:") ACE_TEXT ("Attempt to read 0 bytes or no space in the message block\n")), @@ -649,7 +649,7 @@ ACE_POSIX_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_POSIX_Asynch_Write_File::write:") ACE_TEXT ("Attempt to write 0 bytes\n")), @@ -808,7 +808,7 @@ ACE_POSIX_Asynch_Accept::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_POSIX_Asynch_Accept::open:") ACE_TEXT("acceptor already open\n")), -1); @@ -849,7 +849,7 @@ ACE_POSIX_Asynch_Accept::accept (ACE_Message_Block &message_block, ACE_TRACE ("ACE_POSIX_Asynch_Accept::accept"); if (!this->flg_open_) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT("%N:%l:ACE_POSIX_Asynch_Accept::accept") ACE_TEXT("acceptor was not opened before\n")), -1); @@ -892,7 +892,7 @@ ACE_POSIX_Asynch_Accept::accept (ACE_Message_Block &message_block, ACE_MT (ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, ace_mon, this->lock_, -1)); if (this->result_queue_.enqueue_tail (result) == -1) { - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, ACE_TEXT ("ACE_POSIX_Asynch_Accept::accept: %p\n") ACE_TEXT ("enqueue_tail"))); delete result; // to avoid memory leak @@ -950,7 +950,7 @@ ACE_POSIX_Asynch_Accept::cancel_uncompleted (int flg_notify) result->set_error (ECANCELED); if (this->posix_proactor ()->post_completion (result) == -1) - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, ACE_TEXT("(%P | %t):%p\n"), ACE_TEXT("ACE_POSIX_Asynch_Accept::") ACE_TEXT("cancel_uncompleted") @@ -1077,7 +1077,7 @@ ACE_POSIX_Asynch_Accept::handle_input (ACE_HANDLE /* fd */) // Deregister this info pertaining to this accept call. if (this->result_queue_.dequeue_head (result) != 0) - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, ACE_TEXT("%N:%l:(%P | %t):%p\n"), ACE_TEXT("ACE_POSIX_Asynch_Accept::handle_input:") ACE_TEXT( " dequeueing failed"))); @@ -1107,7 +1107,7 @@ ACE_POSIX_Asynch_Accept::handle_input (ACE_HANDLE /* fd */) if (new_handle == ACE_INVALID_HANDLE) { result->set_error (errno); - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, ACE_TEXT("%N:%l:(%P | %t):%p\n"), ACE_TEXT("ACE_POSIX_Asynch_Accept::handle_input: ") ACE_TEXT("accept"))); @@ -1121,7 +1121,7 @@ ACE_POSIX_Asynch_Accept::handle_input (ACE_HANDLE /* fd */) // Notify the main process about this completion // Send the Result through the notification pipe. if (this->posix_proactor ()->post_completion (result) == -1) - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, ACE_TEXT("Error:(%P | %t):%p\n"), ACE_TEXT("ACE_POSIX_Asynch_Accept::handle_input: ") ACE_TEXT(" <post_completion> failed"))); @@ -1247,7 +1247,7 @@ ACE_POSIX_Asynch_Connect::connect (ACE_HANDLE connect_handle, ACE_TRACE ("ACE_POSIX_Asynch_Connect::connect"); if (this->flg_open_ == 0) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT("%N:%l:ACE_POSIX_Asynch_Connect::connect") ACE_TEXT("connector was not opened before\n")), -1); @@ -1281,7 +1281,7 @@ ACE_POSIX_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 ("%N:%l:%p\n"), ACE_TEXT ("ACE_POSIX_Asynch_Connect::connect:") ACE_TEXT ("bind"))); @@ -1327,7 +1327,7 @@ int ACE_POSIX_Asynch_Connect::post_result (ACE_POSIX_Asynch_Connect_Result * res if (this->posix_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_POSIX_Asynch_Connect::post_result: ") ACE_TEXT(" <post_completion> failed"))); @@ -1371,7 +1371,7 @@ ACE_POSIX_Asynch_Connect::connect_i (ACE_POSIX_Asynch_Connect_Result *result, if (handle == ACE_INVALID_HANDLE) { result->set_error (errno); - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT("ACE_POSIX_Asynch_Connect::connect_i: %p\n"), ACE_TEXT("socket")), @@ -1389,7 +1389,7 @@ ACE_POSIX_Asynch_Connect::connect_i (ACE_POSIX_Asynch_Connect_Result *result, sizeof one) == -1 ) { result->set_error (errno); - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT("ACE_POSIX_Asynch_Connect::connect_i: %p\n"), ACE_TEXT("setsockopt")), @@ -1405,7 +1405,7 @@ ACE_POSIX_Asynch_Connect::connect_i (ACE_POSIX_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_POSIX_Asynch_Connect::connect_i: %p\n"), ACE_TEXT("bind")), @@ -1417,7 +1417,7 @@ ACE_POSIX_Asynch_Connect::connect_i (ACE_POSIX_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_POSIX_Asynch_Connect::connect_i: %p\n") ACE_TEXT("set_flags")), @@ -1841,7 +1841,7 @@ ACE_POSIX_Asynch_Transmit_Handler::transmit (void) this->result_->file (), 0, 0) == -1) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, "ACE_Asynch_Transmit_Handler:read_file open failed\n"), -1); @@ -1850,7 +1850,7 @@ ACE_POSIX_Asynch_Transmit_Handler::transmit (void) this->result_->socket (), 0, 0) == -1) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, "ACE_Asynch_Transmit_Handler:write_stream open failed\n"), -1); @@ -1859,7 +1859,7 @@ ACE_POSIX_Asynch_Transmit_Handler::transmit (void) this->result_->header_and_trailer ()->header_bytes (), reinterpret_cast<void *> (&this->header_act_), 0) == -1) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, "Asynch_Transmit_Handler:transmitting header:write_stream failed\n"), -1); return 0; @@ -1876,7 +1876,7 @@ ACE_POSIX_Asynch_Transmit_Handler::handle_write_stream (const ACE_Asynch_Write_S { // Failure. - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, "Asynch_Transmit_File failed.\n")); ACE_SEH_TRY @@ -1900,7 +1900,7 @@ ACE_POSIX_Asynch_Transmit_Handler::handle_write_stream (const ACE_Asynch_Write_S size_t unsent_data = result.bytes_to_write () - result.bytes_transferred (); if (unsent_data != 0) { - ACE_DEBUG ((LM_DEBUG, + ACELIB_DEBUG ((LM_DEBUG, "%N:%l:Partial write to socket: Asynch_write called again\n")); // Duplicate the message block and retry remaining data @@ -1911,7 +1911,7 @@ ACE_POSIX_Asynch_Transmit_Handler::handle_write_stream (const ACE_Asynch_Write_S this->result_->signal_number ()) == -1) { // @@ Handle this error. - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, "Asynch_Transmit_Handler:write_stream failed\n")); return; } @@ -1953,13 +1953,13 @@ ACE_POSIX_Asynch_Transmit_Handler::handle_write_stream (const ACE_Asynch_Write_S // If header/data was sent, initiate the file data transmission. if (this->initiate_read_file () == -1) // @@ Handle this error. - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, "Error:Asynch_Transmit_Handler:read_file couldnt be initiated\n")); break; default: // @@ Handle this error. - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, "Error:ACE_Asynch_Transmit_Handler::handle_write_stream::Unexpected act\n")); } } @@ -2000,7 +2000,7 @@ ACE_POSIX_Asynch_Transmit_Handler::handle_read_file (const ACE_Asynch_Read_File: this->result_->signal_number ()) == -1) { // @@ Handle this error. - ACE_ERROR ((LM_ERROR, + ACELIB_ERROR ((LM_ERROR, "Error:ACE_Asynch_Transmit_File : write to the stream failed\n")); return; } @@ -2018,7 +2018,7 @@ ACE_POSIX_Asynch_Transmit_Handler::initiate_read_file (void) (void *)&this->trailer_act_, this->result_->priority (), this->result_->signal_number ()) == -1) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, "Error:Asynch_Transmit_Handler:write_stream writing trailer failed\n"), -1); return 0; @@ -2039,7 +2039,7 @@ ACE_POSIX_Asynch_Transmit_Handler::initiate_read_file (void) 0, // Act this->result_->priority (), this->result_->signal_number ()) == -1) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, "Error:Asynch_Transmit_Handler::read from file failed\n"), -1); return 0; @@ -2069,7 +2069,7 @@ ACE_POSIX_Asynch_Transmit_File::transmit_file (ACE_HANDLE file, ssize_t file_size = ACE_OS::filesize (file); if (file_size == -1) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT("Error:%N:%l:%p\n"), ACE_TEXT("POSIX_Asynch_Transmit_File:filesize failed")), -1); @@ -2078,7 +2078,7 @@ ACE_POSIX_Asynch_Transmit_File::transmit_file (ACE_HANDLE file, bytes_to_write = file_size; if (offset > (size_t) file_size) - ACE_ERROR_RETURN ((LM_ERROR, + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT("Error:%p\n"), ACE_TEXT("Asynch_Transmit_File:File size is less than offset")), -1); @@ -2378,7 +2378,7 @@ ACE_POSIX_Asynch_Write_Dgram::send (ACE_Message_Block *message_block, { size_t len = message_block->length (); if (len == 0) - ACE_ERROR_RETURN + ACELIB_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("ACE_POSIX_Asynch_Write_Stream::write:") ACE_TEXT ("Attempt to write 0 bytes\n")), |