diff options
| author | mcorino <mcorino@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2011-11-11 10:47:09 +0000 |
|---|---|---|
| committer | mcorino <mcorino@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2011-11-11 10:47:09 +0000 |
| commit | f959acdb7e2f737ec8cfac94b6956109682b8f17 (patch) | |
| tree | 042dceb21ed0cac65b77d8f2ac8c2c6232810737 /TAO/tao/CDR.cpp | |
| parent | e45953ea0519269689e04fc1b1832413db46369f (diff) | |
| download | ATCD-f959acdb7e2f737ec8cfac94b6956109682b8f17.tar.gz | |
Sun Nov 6 18:08:29 UTC 2011 Martin Corino <mcorino@remedy.nl>
* tao/CDR.cpp:
* tao/Exclusive_TMS.cpp:
* tao/GIOP_Message_Base.cpp:
* tao/IIOP_Transport.h:
* tao/LocateRequest_Invocation.cpp:
* tao/Message_Semantics.h:
* tao/Messaging/AMH_Response_Handler.cpp:
* tao/Messaging/Asynch_Invocation.cpp:
* tao/Strategies/COIOP_Transport.h:
* tao/Strategies/DIOP_Transport.h:
* tao/Strategies/SCIOP_Transport.h:
* tao/Strategies/SHMIOP_Transport.h:
* tao/Strategies/UIOP_Transport.h:
* tao/Synch_Invocation.cpp:
* tao/TAO_Server_Request.cpp:
* tao/Transport.cpp:
* tao/Transport.h:
* tao/Wait_On_Leader_Follower.cpp:
* tao/Wait_On_Leader_Follower.h:
* tao/Wait_On_Read.cpp:
* tao/Wait_On_Read.h:
* tao/Wait_Strategy.cpp:
* tao/Wait_Strategy.h:
Changes to make the RW client wait strategy (in combination with
the Exclusive transport muxing strategy) play nice with AMI.
The essence of the problem of RW not working with AMI was that
AMI requires transports to be registered with the reactor (so
reply events can be handled) which is what RW prevented for all
client transports.
The changes provide a means for RW to recognize transports for
Async client requests and register these with the reactor just
before sending the request and removing them from the reactor
again when the request has finished (reply received, timed out
or disconnected).
Diffstat (limited to 'TAO/tao/CDR.cpp')
| -rw-r--r-- | TAO/tao/CDR.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/TAO/tao/CDR.cpp b/TAO/tao/CDR.cpp index 668d4b7b557..3b56db02be5 100644 --- a/TAO/tao/CDR.cpp +++ b/TAO/tao/CDR.cpp @@ -68,7 +68,7 @@ TAO_OutputCDR::TAO_OutputCDR (size_t size, , more_fragments_ (false) , request_id_ (0) , stub_ (0) - , message_semantics_ (TAO_TWOWAY_REQUEST) + , message_semantics_ (TAO_Message_Semantics::TAO_TWOWAY_REQUEST) , timeout_ (0) { ACE_FUNCTION_TIMEPROBE (TAO_OUTPUT_CDR_CTOR1_ENTER); @@ -104,7 +104,7 @@ TAO_OutputCDR::TAO_OutputCDR (char *data, , more_fragments_ (false) , request_id_ (0) , stub_ (0) - , message_semantics_ (TAO_TWOWAY_REQUEST) + , message_semantics_ (TAO_Message_Semantics::TAO_TWOWAY_REQUEST) , timeout_ (0) { ACE_FUNCTION_TIMEPROBE (TAO_OUTPUT_CDR_CTOR2_ENTER); @@ -133,7 +133,7 @@ TAO_OutputCDR::TAO_OutputCDR (char *data, , more_fragments_ (false) , request_id_ (0) , stub_ (0) - , message_semantics_ (TAO_TWOWAY_REQUEST) + , message_semantics_ (TAO_Message_Semantics::TAO_TWOWAY_REQUEST) , timeout_ (0) { ACE_FUNCTION_TIMEPROBE (TAO_OUTPUT_CDR_CTOR3_ENTER); @@ -153,7 +153,7 @@ TAO_OutputCDR::TAO_OutputCDR (ACE_Message_Block *data, , more_fragments_ (false) , request_id_ (0) , stub_ (0) - , message_semantics_ (TAO_TWOWAY_REQUEST) + , message_semantics_ (TAO_Message_Semantics::TAO_TWOWAY_REQUEST) , timeout_ (0) { ACE_FUNCTION_TIMEPROBE (TAO_OUTPUT_CDR_CTOR4_ENTER); @@ -176,7 +176,7 @@ TAO_OutputCDR::TAO_OutputCDR (ACE_Data_Block *data_block, , more_fragments_ (false) , request_id_ (0) , stub_ (0) - , message_semantics_ (TAO_TWOWAY_REQUEST) + , message_semantics_ (TAO_Message_Semantics::TAO_TWOWAY_REQUEST) , timeout_ (0) { ACE_FUNCTION_TIMEPROBE (TAO_OUTPUT_CDR_CTOR5_ENTER); |