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
|
// This may look like C, but it's really -*- C++ -*-
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// SHMIOP_Acceptor.h
//
// = DESCRIPTION
// SHMIOP specific acceptor processing
//
// = AUTHOR
// Nanbor Wang
//
// ============================================================================
#ifndef TAO_SHMIOP_ACCEPTOR_H
#define TAO_SHMIOP_ACCEPTOR_H
#include "ace/pre.h"
#include "tao/corbafwd.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (TAO_HAS_SHMIOP) && (TAO_HAS_SHMIOP != 0)
#include "tao/Pluggable.h"
#include "tao/SHMIOP_Connect.h"
#include "tao/Acceptor_Impl.h"
#include "ace/Acceptor.h"
#include "ace/MEM_Acceptor.h"
// TAO SHMIOP_Acceptor concrete call defination
class TAO_Export TAO_SHMIOP_Acceptor : public TAO_Acceptor
{
// = TITLE
// TAO_SHMIOP_Acceptor
//
// = DESCRIPTION
// The IIOP-specific bridge class for the concrete acceptor.
//
public:
TAO_SHMIOP_Acceptor (CORBA::Boolean flag = 0);
// Constructor.
~TAO_SHMIOP_Acceptor (void);
// Destructor.
typedef ACE_Strategy_Acceptor<TAO_SHMIOP_Server_Connection_Handler, ACE_MEM_ACCEPTOR> TAO_SHMIOP_BASE_ACCEPTOR;
typedef TAO_Creation_Strategy<TAO_SHMIOP_Server_Connection_Handler> TAO_SHMIOP_CREATION_STRATEGY;
typedef TAO_Concurrency_Strategy<TAO_SHMIOP_Server_Connection_Handler> TAO_SHMIOP_CONCURRENCY_STRATEGY;
typedef TAO_Accept_Strategy<TAO_SHMIOP_Server_Connection_Handler, ACE_MEM_ACCEPTOR> TAO_SHMIOP_ACCEPT_STRATEGY;
// = The TAO_Acceptor methods, check the documentation in
// Pluggable.h for details.
virtual int open (TAO_ORB_Core *orb_core,
int version_major,
int version_minor,
const char *port,
const char *options = 0);
virtual int open_default (TAO_ORB_Core *orb_core,
int version_major,
int version_minor,
const char *options = 0);
virtual int close (void);
virtual int create_mprofile (const TAO_ObjectKey &object_key,
TAO_MProfile &mprofile);
virtual int is_collocated (const TAO_Endpoint* endpoint);
virtual CORBA::ULong endpoint_count (void);
virtual int object_key (IOP::TaggedProfile &profile,
TAO_ObjectKey &key);
private:
int open_i (TAO_ORB_Core* orb_core);
// Implement the common part of the open*() methods.
virtual int parse_options (const char *options);
// Parse protocol specific options.
int create_rt_mprofile (const TAO_ObjectKey &object_key,
TAO_MProfile &mprofile);
// Rather than creating a separate profile for each endpoint, this
// version of <create_mprofile> method adds all endpoints to a
// single SHMIOP profile, i.e., <mprofile> will not contain more than
// one SHMIOP_Profile, no matter how many acceptors there are.
int create_profile (const TAO_ObjectKey &object_key,
TAO_MProfile &mprofile);
// Create a SHMIOP profile representing this acceptor. Factors out
// common functionality of <create_mprofile> and <create_rt_mprofile>.
protected:
ACE_CString host_;
// Cache the information about the endpoint serviced by this
// acceptor.
// @@ TODO there may in fact be multiple hostnames for this
// endpoint. For example it the IP address is INADDR_ANY
// (0.0.0.0) then there will be possibly a different hostname for
// each interface.
ACE_MEM_Addr address_;
// A local endpoint.
TAO_GIOP_Version version_;
// The GIOP version for this endpoint
TAO_ORB_Core *orb_core_;
// ORB Core.
private:
TAO_SHMIOP_BASE_ACCEPTOR base_acceptor_;
// the concrete acceptor, as a pointer to it's base class.
TAO_SHMIOP_CREATION_STRATEGY *creation_strategy_;
TAO_SHMIOP_CONCURRENCY_STRATEGY *concurrency_strategy_;
TAO_SHMIOP_ACCEPT_STRATEGY *accept_strategy_;
// Acceptor strategies.
ACE_TCHAR *mmap_file_prefix_;
// Determine the prefix (include path name) of the mmap file.
off_t mmap_size_;
// Determine the minimum size of mmap file. This dictate the
// maximum size of a CORBA method invocation.
CORBA::Boolean lite_flag_;
// Should we use GIOP lite??
};
#if defined(__ACE_INLINE__)
#include "tao/SHMIOP_Acceptor.i"
#endif /* __ACE_INLINE__ */
#endif /* TAO_HAS_SHMIOP && TAO_HAS_SHMIOP != 0 */
#include "ace/post.h"
#endif /* TAO_SHMIOP_ACCEPTOR_H */
|
