summaryrefslogtreecommitdiff
path: root/TAO/tao/RTPortableServer/RT_Servant_Dispatcher.cpp
diff options
context:
space:
mode:
authorjai <jai@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2007-02-21 14:17:18 +0000
committerjai <jai@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2007-02-21 14:17:18 +0000
commitdcf6635f901defed25f50fe6840610c232f83e29 (patch)
tree0b2186c467eb96473b96f5d0168aadcb5692eac8 /TAO/tao/RTPortableServer/RT_Servant_Dispatcher.cpp
parent51a7c0dfb03839d490bf61a250dcb3630d058e15 (diff)
downloadATCD-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.cpp21
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);
}
}