diff options
Diffstat (limited to 'TAO/tao/RTCORBA/RT_Protocols_Hooks.cpp')
-rw-r--r-- | TAO/tao/RTCORBA/RT_Protocols_Hooks.cpp | 68 |
1 files changed, 0 insertions, 68 deletions
diff --git a/TAO/tao/RTCORBA/RT_Protocols_Hooks.cpp b/TAO/tao/RTCORBA/RT_Protocols_Hooks.cpp index cf2123c5759..886b839e784 100644 --- a/TAO/tao/RTCORBA/RT_Protocols_Hooks.cpp +++ b/TAO/tao/RTCORBA/RT_Protocols_Hooks.cpp @@ -460,74 +460,6 @@ TAO_RT_Protocols_Hooks::get_dscp_codepoint (void) } void -TAO_RT_Protocols_Hooks::rt_service_context ( - TAO_Stub *stub, - TAO_Service_Context &service_context, - CORBA::Boolean restart) -{ - // If the restart flag is true, then this call for a - // reinvocation. We need not prepare the Service Context List once - // again. We can use the already existing one. - if (!restart) - { - TAO_RT_Stub *rt_stub = - dynamic_cast<TAO_RT_Stub *> (stub); - - if (!rt_stub) - throw CORBA::INTERNAL (); - - CORBA::Policy_var priority_model_policy = - rt_stub->get_cached_policy (TAO_CACHED_POLICY_PRIORITY_MODEL); - - if (!CORBA::is_nil (priority_model_policy.in ())) - { - RTCORBA::PriorityModelPolicy_var model_policy_ptr = - RTCORBA::PriorityModelPolicy::_narrow (priority_model_policy.in ()); - - TAO_PriorityModelPolicy *priority_model = - static_cast<TAO_PriorityModelPolicy *> (model_policy_ptr.in ()); - - if (priority_model->get_priority_model () == RTCORBA::CLIENT_PROPAGATED) - { - CORBA::Short client_priority = -1; - // Get client thread priority from 'Current' or if not set by implying one - // from the native thread priority via the mapping. - if (this->get_thread_CORBA_priority (client_priority) != -1 || - this->get_thread_implicit_CORBA_priority (client_priority) != -1) - { - // OK - } - else - { - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, "ERROR: TAO_RT_Protocols_Hooks::rt_service_context. " - "Unable to access RT CORBA Priority in client thread " - "accessing object with CLIENT_PROPAGATED priority model.\n")); - throw CORBA::DATA_CONVERSION (CORBA::OMGVMCID | 2, CORBA::COMPLETED_NO); - - } - - // Encapsulate the priority of the current thread into - // a service context. - TAO_OutputCDR cdr; - if ((cdr << ACE_OutputCDR::from_boolean (TAO_ENCAP_BYTE_ORDER) == 0) - || (cdr << client_priority) == 0) - { - throw CORBA::MARSHAL (); - } - - service_context.set_context (IOP::RTCorbaPriority, cdr); - } - } - else - { - // The Object does not contain PriorityModel policy in its IOR. - // We must be talking to a non-RT ORB. Do nothing. - } - } -} - -void TAO_RT_Protocols_Hooks::get_selector_hook ( CORBA::Policy *model_policy, CORBA::Boolean &is_client_propagated, |