diff options
author | jai <jai@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2007-02-21 14:17:18 +0000 |
---|---|---|
committer | jai <jai@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2007-02-21 14:17:18 +0000 |
commit | dcf6635f901defed25f50fe6840610c232f83e29 (patch) | |
tree | 0b2186c467eb96473b96f5d0168aadcb5692eac8 /TAO/tao/RTPortableServer/RT_Servant_Dispatcher.cpp | |
parent | 51a7c0dfb03839d490bf61a250dcb3630d058e15 (diff) | |
download | ATCD-dcf6635f901defed25f50fe6840610c232f83e29.tar.gz |
ChangeLogTag: Wed Feb 21 14:15:38 UTC 2007 Jaiganesh B <jai.dre.vanderbilt.edu>
Diffstat (limited to 'TAO/tao/RTPortableServer/RT_Servant_Dispatcher.cpp')
-rw-r--r-- | TAO/tao/RTPortableServer/RT_Servant_Dispatcher.cpp | 21 |
1 files changed, 16 insertions, 5 deletions
diff --git a/TAO/tao/RTPortableServer/RT_Servant_Dispatcher.cpp b/TAO/tao/RTPortableServer/RT_Servant_Dispatcher.cpp index 39d16f890d9..94c77f10cc5 100644 --- a/TAO/tao/RTPortableServer/RT_Servant_Dispatcher.cpp +++ b/TAO/tao/RTPortableServer/RT_Servant_Dispatcher.cpp @@ -12,6 +12,8 @@ #include "tao/Connection_Handler.h" #include "tao/Service_Context.h" #include "tao/Protocols_Hooks.h" +#include "tao/Network_Priority_Protocols_Hooks.h" +#include "tao/PortableServer/Network_Priority_Hook.h" #include "tao/debug.h" #include "tao/CDR.h" @@ -247,16 +249,25 @@ TAO_RT_Servant_Dispatcher::pre_invoke_remote_request ( } } } + } - CORBA::Policy_var policy = - poa.policies ().get_cached_policy (TAO_CACHED_POLICY_RT_SERVER_PROTOCOL); + TAO_Network_Priority_Protocols_Hooks *nph = + poa.orb_core ().get_network_priority_protocols_hooks (); + if (nph != 0) + { + poa.network_priority_hook ()-> set_dscp_codepoint (req, poa); + } + else if (tph != 0) + { + CORBA::Policy_var policy = + poa.policies ().get_cached_policy ( + TAO_CACHED_POLICY_RT_SERVER_PROTOCOL); CORBA::Boolean set_server_network_priority = - tph->set_server_network_priority (req.transport ()->tag (), policy.in ()); - + tph->set_server_network_priority ( + req.transport ()->tag (), policy.in ()); TAO_Connection_Handler *connection_handler = req.transport ()->connection_handler (); - connection_handler->set_dscp_codepoint (set_server_network_priority); } } |