1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
// -*- C++ -*-
// ===================================================================
/**
* @file RT_Protocols_Hooks.h
*
* $Id$
*
* @author Priyanka Gontla <pgontla@ece.uci.edu>
*
*/
// ===================================================================
#ifndef TAO_RT_PROTOCOLS_HOOKS_H
#define TAO_RT_PROTOCOLS_HOOKS_H
#include "ace/pre.h"
#include "tao/Protocols_Hooks.h"
#include "Priority_Mapping_Manager.h"
#include "ace/Service_Config.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class TAO_RTCORBA_Export TAO_RT_Protocols_Hooks : public TAO_Protocols_Hooks
{
public:
/// constructor
TAO_RT_Protocols_Hooks (void);
/// destructor
virtual ~TAO_RT_Protocols_Hooks (void);
/// Initialize the protocols hooks instance.
virtual void init_hooks (TAO_ORB_Core *orb_core,
CORBA::Environment &ACE_TRY_ENV);
/// Invoke the client_protocols hook if present.
/**
* The timeout hook is used to determine if the client_protocols policy is
* set and with what value. If the ORB is compiled without support
* for RTCORBA this feature does not take effect
* \param tcp_properties returns the Protocol List set
*/
virtual int call_client_protocols_hook (
int &send_buffer_size,
int &recv_buffer_size,
int &no_delay,
const char *protocol_type);
/// Define the Client_Protocols_TCP_Hook signature
typedef int (*Client_Protocols_Hook) (TAO_ORB_Core *,
int &send_buffer_size,
int &recv_buffer_size,
int &no_delay,
const char *);
static void set_client_protocols_hook (Client_Protocols_Hook hook);
/// The hook to be set for the ClientProtocolPolicy.
static Client_Protocols_Hook client_protocols_hook_;
/// Invoke the server_protocols hook if present.
/**
* The timeout hook is used to determine if the client_protocols policy is
* set and with what value. If the ORB is compiled without support
* for RTCORBA this feature does not take effect
* \param tcp_properties returns the Protocol List set
*/
virtual int call_server_protocols_hook (int &send_buffer_size,
int &recv_buffer_size,
int &no_delay,
const char *protocol_type);
/// Define the Server_Protocols_Hook signature
typedef int (*Server_Protocols_Hook) (TAO_ORB_Core *,
int &,
int &,
int &,
const char *);
static void set_server_protocols_hook (Server_Protocols_Hook hook);
// static void set_server_protocols_uiop_hook (Server_Protocols_UIOP_Hook hook);
/// The hook to be set for the ServerProtocolPolicy.
static Server_Protocols_Hook server_protocols_hook_;
virtual void rt_service_context (TAO_Stub *stub,
TAO_Service_Context &service_context,
CORBA::Boolean restart,
CORBA::Environment &ACE_TRY_ENV);
virtual void add_rt_service_context_hook (TAO_Service_Context &service_context,
CORBA::Policy *model_policy,
CORBA::Short &client_priority,
CORBA::Environment &ACE_TRY_ENV);
virtual void get_selector_hook (CORBA::Policy *model_policy,
CORBA::Boolean
&is_client_propagated,
CORBA::Short &server_priority);
virtual void get_selector_bands_policy_hook (
CORBA::Policy *bands_policy,
CORBA::Short &min_priority,
CORBA::Short &max_priority,
CORBA::Short &p,
int &in_range);
/**
* Accessor and modifier to the current thread priority, used to
* implement the RTCORBA::Current interface, but it is faster for
* some critical components.
*/
//@{
virtual int get_thread_priority (CORBA::Short &priority,
CORBA::Environment &ACE_TRY_ENV);
virtual int set_thread_priority (CORBA::Short priority,
CORBA::Environment &ACE_TRY_ENV);
//@}
/// 1. Sets ORB-level policy defaults for this ORB. Currently sets
/// default RTCORBA policies: ClientProtocolPolicy.
virtual int set_default_policies (CORBA::Environment &ACE_TRY_ENV);
int set_default_server_protocol_policy (TAO_Acceptor_Registry &acceptor_registry,
CORBA::Environment &ACE_TRY_ENV);
protected:
TAO_ORB_Core *orb_core_;
// Save a reference to the priority mapping manager.
TAO_Priority_Mapping_Manager_var mapping_manager_;
};
#if defined (__ACE_INLINE__)
#include "RT_Protocols_Hooks.i"
#endif /* __ACE_INLINE__ */
ACE_STATIC_SVC_DECLARE_EXPORT (TAO_RTCORBA, TAO_RT_Protocols_Hooks)
ACE_FACTORY_DECLARE (TAO_RTCORBA, TAO_RT_Protocols_Hooks)
ACE_STATIC_SVC_REQUIRE(TAO_RT_Protocols_Hooks)
#include "ace/post.h"
#endif /* TAO_RT_PROTOCOLS_HOOKS_H */
|
