diff options
author | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-07-31 16:14:11 +0000 |
---|---|---|
committer | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-07-31 16:14:11 +0000 |
commit | 9c2ec3049a5634f1c916d792e81fc80edb669ea8 (patch) | |
tree | 0d634e179761581cadbffe852e7f9a9f049b5c6e /apps/JAWS3/jaws3/Synch_IO.cpp | |
parent | 6540653cf736840d5aad719c73a8e43a549080be (diff) | |
download | ATCD-9c2ec3049a5634f1c916d792e81fc80edb669ea8.tar.gz |
This commit was manufactured by cvs2svn to create tag 'TAO-1_4_2'.TAO-1_4_2
Diffstat (limited to 'apps/JAWS3/jaws3/Synch_IO.cpp')
-rw-r--r-- | apps/JAWS3/jaws3/Synch_IO.cpp | 265 |
1 files changed, 0 insertions, 265 deletions
diff --git a/apps/JAWS3/jaws3/Synch_IO.cpp b/apps/JAWS3/jaws3/Synch_IO.cpp deleted file mode 100644 index 69b0d92fd95..00000000000 --- a/apps/JAWS3/jaws3/Synch_IO.cpp +++ /dev/null @@ -1,265 +0,0 @@ -// $Id$ - -#include "ace/ACE.h" - -#ifndef JAWS_BUILD_DLL -#define JAWS_BUILD_DLL -#endif - -#include "jaws3/IO.h" -#include "jaws3/Synch_IO.h" -#include "jaws3/Event_Completer.h" - -static JAWS_Event_Result -JAWS_synch_send ( ACE_HANDLE handle - , ACE_Message_Block *mb - , const ACE_Time_Value *tv = 0 - ) -{ - JAWS_Event_Result io_result; - - ssize_t result = ACE::send_n (handle, mb->rd_ptr (), mb->length (), tv); - if (result < 0) - { - if (errno == ETIME) - { - JAWS_Event_Result tmp_io_result ( 0 - , JAWS_Event_Result::JE_ERROR - , JAWS_Event_Result::JE_SEND_TIMEOUT - ); - io_result = tmp_io_result; - } - else - { - JAWS_Event_Result tmp_io_result ( 0 - , JAWS_Event_Result::JE_ERROR - , JAWS_Event_Result::JE_SEND_FAIL - ); - io_result = tmp_io_result; - } - } - else if ((size_t) result < mb->length ()) - { - if (result > 0) - mb->rd_ptr (result); - - JAWS_Event_Result tmp_io_result ( result - , JAWS_Event_Result::JE_ERROR - , JAWS_Event_Result::JE_SEND_SHORT - ); - io_result = tmp_io_result; - } - else - { - if (result > 0) - mb->rd_ptr (result); - - JAWS_Event_Result tmp_io_result ( result - , JAWS_Event_Result::JE_OK - , JAWS_Event_Result::JE_SEND_OK - ); - io_result = tmp_io_result; - } - - return io_result; -} - -void -JAWS_Synch_IO::send ( ACE_HANDLE handle - , ACE_Message_Block *mb - , JAWS_Event_Completer *completer - , const ACE_Time_Value &tv - , void *act - ) -{ - JAWS_Event_Result io_result; - const ACE_Time_Value *tvp = 0; - - if (ACE_Time_Value::zero < tv) - tvp = &tv; - - io_result = JAWS_synch_send (handle, mb, tvp); - - if (completer) - completer->output_complete (io_result, act); -} - - -void -JAWS_Synch_IO::send ( ACE_HANDLE handle - , ACE_Message_Block *mb - , JAWS_Event_Completer *completer - , void *act - ) -{ - this->send (handle, mb, completer, ACE_Time_Value::zero, act); -} - - -void -JAWS_Synch_IO::recv ( ACE_HANDLE handle - , ACE_Message_Block *mb - , JAWS_Event_Completer *completer - , const ACE_Time_Value &tv - , void *act - ) -{ - JAWS_Event_Result io_result; - const ACE_Time_Value *tvp = 0; - - if (ACE_Time_Value::zero < tv) - tvp = &tv; - - ssize_t result = ACE::recv (handle, mb->wr_ptr (), mb->space (), tvp); - if (result < 0) - { - JAWS_Event_Result tmp_io_result ( 0 - , JAWS_Event_Result::JE_ERROR - , JAWS_Event_Result::JE_RECV_FAIL - ); - io_result = tmp_io_result; - } - else - { - if (result > 0) - mb->wr_ptr (result); - - JAWS_Event_Result tmp_io_result ( result - , JAWS_Event_Result::JE_OK - , JAWS_Event_Result::JE_RECV_OK - ); - io_result = tmp_io_result; - } - - if (completer) - completer->input_complete (io_result, act); -} - - -void -JAWS_Synch_IO::recv ( ACE_HANDLE handle - , ACE_Message_Block *mb - , JAWS_Event_Completer *completer - , void *act - ) -{ - this->recv (handle, mb, completer, ACE_Time_Value::zero, act); -} - - -void -JAWS_Synch_IO::transmit ( ACE_HANDLE handle - , ACE_HANDLE source - , JAWS_Event_Completer *completer - , const ACE_Time_Value &tv - , void *act - , ACE_Message_Block *header - , ACE_Message_Block *trailer - ) -{ - JAWS_Event_Result io_result; - const ACE_Time_Value *tvp = 0; - - if (ACE_Time_Value::zero < tv) - tvp = &tv; - - size_t bytes = 0; - - if (header) - { - io_result = JAWS_synch_send (handle, header, tvp); - bytes += io_result.bytes (); - if (io_result.status () != JAWS_Event_Result::JE_OK) - { - if (completer) - completer->input_complete (io_result, act); - - return; - } - } - - ACE_Message_Block buf (8 * 1024); - ssize_t len = 0; - while ((len = ACE::recv (source, buf.wr_ptr (), buf.space (), tvp)) >= 0) - { - if (len == 0) - break; - - buf.wr_ptr (len); - io_result = JAWS_synch_send (handle, & buf); - bytes += io_result.bytes (); - if (io_result.status () != JAWS_Event_Result::JE_OK) - { - JAWS_Event_Result tmp_io_result ( bytes - , JAWS_Event_Result::JE_ERROR - , JAWS_Event_Result::JE_SEND_SHORT - ); - - if (completer) - completer->input_complete (tmp_io_result, act); - - return; - } - - buf.crunch (); - } - - if (trailer) - { - io_result = JAWS_synch_send (handle, trailer, tvp); - bytes += io_result.bytes (); - if (io_result.status () != JAWS_Event_Result::JE_OK) - { - JAWS_Event_Result tmp_io_result ( bytes - , JAWS_Event_Result::JE_ERROR - , JAWS_Event_Result::JE_SEND_SHORT - ); - - if (completer) - completer->input_complete (tmp_io_result, act); - - return; - } - } - - if (len == 0) - { - JAWS_Event_Result tmp_io_result ( bytes - , JAWS_Event_Result::JE_OK - , JAWS_Event_Result::JE_SEND_OK - ); - io_result = tmp_io_result; - } - else - { - JAWS_Event_Result tmp_io_result ( bytes - , JAWS_Event_Result::JE_ERROR - , JAWS_Event_Result::JE_SEND_SHORT - ); - io_result = tmp_io_result; - } - - if (completer) - completer->input_complete (io_result, act); -} - - -void -JAWS_Synch_IO::transmit ( ACE_HANDLE handle - , ACE_HANDLE source - , JAWS_Event_Completer *completer - , void *act - , ACE_Message_Block *header - , ACE_Message_Block *trailer - ) -{ - this->transmit ( handle - , source - , completer - , ACE_Time_Value::zero - , act - , header - , trailer - ); -} - |