diff options
| author | schmidt <douglascraigschmidt@users.noreply.github.com> | 2001-05-17 15:40:34 +0000 |
|---|---|---|
| committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 2001-05-17 15:40:34 +0000 |
| commit | b4e0cc55aeddc025bedf0147a08e1a07c6441c43 (patch) | |
| tree | f8d7ea9c7ce5a7d12886e9aeab540f9ad97f6ec4 /ace/POSIX_Asynch_IO.cpp | |
| parent | a911e6f23b7be8ca2f155e82ab0259afd8e417e3 (diff) | |
| download | ATCD-b4e0cc55aeddc025bedf0147a08e1a07c6441c43.tar.gz | |
ChangeLogTag:Thu May 17 10:16:03 2001 Douglas C. Schmidt <schmidt@tango.doc.wustl.edu>
Diffstat (limited to 'ace/POSIX_Asynch_IO.cpp')
| -rw-r--r-- | ace/POSIX_Asynch_IO.cpp | 72 |
1 files changed, 30 insertions, 42 deletions
diff --git a/ace/POSIX_Asynch_IO.cpp b/ace/POSIX_Asynch_IO.cpp index 838d340dc0a..d9bf7416b7e 100644 --- a/ace/POSIX_Asynch_IO.cpp +++ b/ace/POSIX_Asynch_IO.cpp @@ -3562,26 +3562,21 @@ ACE_POSIX_AIOCB_Asynch_Read_Dgram::recv (ACE_Message_Block *message_block, int priority, int signal_number) { - - - - // Create the Asynch_Result. ACE_POSIX_Asynch_Read_Dgram_Result *result = 0; ACE_NEW_RETURN (result, ACE_POSIX_Asynch_Read_Dgram_Result (*this->handler_, - this->handle_, - message_block, - num_bytes_to_read, - flags, - protocol_family, - act, - this->posix_aiocb_proactor_->get_handle (), - priority, - signal_number), - -1); + this->handle_, + message_block, + num_bytes_to_read, + flags, + protocol_family, + act, + this->posix_aiocb_proactor_->get_handle (), + priority, + signal_number), + -1); - result->aio_sigevent.sigev_notify = SIGEV_NONE; // try start read @@ -3627,52 +3622,45 @@ ACE_POSIX_SIG_Asynch_Read_Dgram::~ACE_POSIX_SIG_Asynch_Read_Dgram (void) ssize_t ACE_POSIX_SIG_Asynch_Read_Dgram::recv (ACE_Message_Block *message_block, u_long num_bytes_to_read, - size_t &number_of_bytes_recvd, int flags, int protocol_family, const void *act, int priority, int signal_number) { - - - - // Create the Asynch_Result. ACE_POSIX_Asynch_Read_Dgram_Result *result = 0; ACE_NEW_RETURN (result, ACE_POSIX_Asynch_Read_Dgram_Result (*this->handler_, - this->handle_, - message_block, - num_bytes_to_read, - flags, - protocol_family, - act, - this->posix_sig_proactor_->get_handle (), - priority, - signal_number), - -1); + this->handle_, + message_block, + num_bytes_to_read, + flags, + protocol_family, + act, + this->posix_sig_proactor_->get_handle (), + priority, + signal_number), + -1); - // do the scatter/gather recv + // Do the scatter/gather recv. size_t bytes_recvd = 0; int initiate_result = aio_read (result); - if(initiate_result==-1) - { - - ACE_ERROR_RETURN ((LM_ERROR, - "Error:%N%l:%p\n", - "Asynch_Read_Stream: aio_read queueing failed"), - -1); - } + + if (initiate_result == -1) + ACE_ERROR_RETURN ((LM_ERROR, + "Error:%N%l:%p\n", + "Asynch_Read_Stream: aio_read queueing failed"), + -1); return initiate_result; } int ACE_POSIX_SIG_Asynch_Read_Dgram::open (ACE_Handler &handler, - ACE_HANDLE handle, - const void *completion_key, - ACE_Proactor *proactor) + ACE_HANDLE handle, + const void *completion_key, + ACE_Proactor *proactor) { return ACE_POSIX_SIG_Asynch_Operation::open (handler, handle, |