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
|
// This may look like C, but it's really -*- C++ -*-
#if !defined (TAO_CONNECT_H)
# define TAO_CONNECT_H
// ============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// connect.h
//
// = AUTHOR
// Chris Cleeland
//
// ============================================================================
# include "ace/Reactor.h"
# include "ace/Acceptor.h"
# include "ace/SOCK_Acceptor.h"
# include "ace/Synch.h"
# include "ace/Svc_Handler.h"
// Forward Decls
class TAO_OA_Parameters;
typedef ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>
TAO_SVC_HANDLER;
class TAO_Client_Connection_Handler : public TAO_SVC_HANDLER
// = TITLE
// <Svc_Handler> used on the client side and returned by the
// <TAO_CONNECTOR>.
// @@ (CJC) Should this be in here or in the default_client.*?
{
public:
// = Intialization method.
TAO_Client_Connection_Handler (ACE_Thread_Manager * = 0);
// Do-nothing constructor.
// = <Connector> hook.
virtual int open (void *);
// Initialization hook.
};
class TAO_Server_Connection_Handler : public TAO_SVC_HANDLER
// = TITLE
// Handles requests on a single connection in a server.
{
public:
TAO_Server_Connection_Handler (ACE_Thread_Manager *t = ACE_Thread_Manager::instance ());
// Constructor.
virtual int open (void *);
// Called by the <Strategy_Acceptor> when the handler is completely
// connected. Argument is unused.
virtual int svc (void);
// Only used when the handler is turned into an active object by
// calling <activate>. This serves as the event loop in such cases.
TAO_OA_Parameters *params (void);
void params (TAO_OA_Parameters *p);
// = Template Methods Called by <handle_input>
enum RequestStatus
{
Error = -1,
Request, // A CORBA Request was received
LocateRequest // A CORBA LocateRequest was received
};
virtual RequestStatus recv_request (CDR &msg, CORBA::Environment &env);
// Extract a message from the stream associated with <peer()> and
// place it into <msg>. Return either <Request> or <LocateRequest>
// if success, <Error> with <errno> and <env> set if problems.
virtual int handle_message (CDR &msg, int &response_required,
CDR &response, CORBA::Environment &env);
// Handle processing of the request residing in <msg>, setting
// <response_required> to zero if the request is for a oneway or
// non-zero if for a two-way and <response> to any necessary
// response (including errors). In case of errors, -1 is returned
// and additional information carried in <env>.
virtual int handle_locate (CDR &msg, int &response_required,
CDR &response, CORBA::Environment &env);
// Handle processing of the location request residing in <msg>,
// setting <response_required> to one if no errors are encountered.
// The LocateRequestReply is placed into <response>. In case of
// errors, -1 is returned and additional information carried in
// <env>.
virtual void handle_request (TAO_GIOP_RequestHeader hdr,
CDR &request_body,
CDR &response,
TAO_Dispatch_Context *some_info,
CORBA::Environment &env);
// Once a request is found in a message, this finds the appropriate
// POA and dispatches it, then takes care to properly format any
// response.
virtual void send_response (CDR &response);
// Send <response> to the client on the other end.
protected:
// = Event Handler overloads
virtual int handle_input (ACE_HANDLE = ACE_INVALID_HANDLE);
// Reads a message from the <peer()>, dispatching and servicing it
// appropriately.
virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask);
// Perform appropriate closing of the connection.
TAO_OA_Parameters *params_;
};
typedef ACE_Strategy_Acceptor<TAO_Server_Connection_Handler, ACE_SOCK_ACCEPTOR>
TAO_ACCEPTOR;
#endif /* TAO_CONNECT_H */
|
