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
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// ace
//
// = FILENAME
// Svc_Handler.h
//
// = AUTHOR
// Doug Schmidt and Irfan Pyrarli.
//
// ============================================================================
#if !defined (ACE_SVC_HANDLER_H)
#define ACE_SVC_HANDLER_H
// Forward decls.
class ACE_Connection_Recycling_Strategy;
#include "ace/Synch_Options.h"
#include "ace/Task.h"
#include "ace/Service_Config.h"
#include "ace/Synch_T.h"
#include "ace/Dynamic.h"
#include "ace/Singleton.h"
template <ACE_PEER_STREAM_1, ACE_SYNCH_DECL>
class ACE_Svc_Handler : public ACE_Task<ACE_SYNCH_USE>
// = TITLE
// Defines the interface for a service that exchanges data with
// its connected peer.
//
// = DESCRIPTION
// This class provides a well-defined interface that the
// Acceptor and Connector pattern factories use as their target.
// Typically, client applications will subclass ACE_Svc_Handler
// and do all the interesting work in the subclass. One thing
// that the ACE_Svc_Handler does contain is a PEER_STREAM
// endpoint that is initialized by an ACE_Acceptor or
// ACE_Connector when a connection is established successfully.
// This endpoint is used to exchange data between a
// ACE_Svc_Handler and the peer it is connected with.
{
public:
// = Initialization and termination methods.
ACE_Svc_Handler (ACE_Thread_Manager * = 0,
ACE_Message_Queue<ACE_SYNCH_USE> * = 0,
ACE_Reactor * = ACE_Reactor::instance ());
virtual ~ACE_Svc_Handler (void);
virtual int open (void * = 0);
// Activate the client handler (called by the ACE_Acceptor or
// ACE_Connector).
virtual int close (u_long flags = 0);
// Object termination hook.
virtual int idle (u_long flags = 0);
// Call this method if you want to recycling the <Svc_Handler>
// instead of closing it. If the object does not have a recycler,
// it will be closed.
// = Dynamic linking hooks.
virtual int init (int argc, char *argv[]);
// Default version does no work and returns -1. Must be overloaded
// by application developer to do anything meaningful.
virtual int fini (void);
// Default version does no work and returns -1. Must be overloaded
// by application developer to do anything meaningful.
virtual int info (char **info_string, size_t length) const;
// Default version does no work and returns -1. Must be overloaded
// by application developer to do anything meaningful.
// = Demultiplexing hooks.
virtual int handle_close (ACE_HANDLE = ACE_INVALID_HANDLE,
ACE_Reactor_Mask = ACE_Event_Handler::ALL_EVENTS_MASK);
// Perform termination activities on the SVC_HANDLER. The default
// behavior is to close down the <peer_> (to avoid descriptor leaks)
// and to delete this (to avoid memory leaks)! If you don't want
// this behavior make sure you override this method...
virtual int handle_timeout (const ACE_Time_Value &time,
const void *);
// Default behavior when timeouts occur is to close down the
// <Svc_Handler> by calling <handle_close>.
virtual ACE_HANDLE get_handle (void) const;
// Get the underlying handle associated with the <peer_>.
virtual void set_handle (ACE_HANDLE);
// Set the underlying handle associated with the <peer_>.
ACE_PEER_STREAM &peer (void) const;
// Returns the underlying PEER_STREAM
// operator ACE_PEER_STREAM &();
// Returns the underlying PEER_STREAM (used by
// ACE_Acceptor::accept() and ACE_Connector::connect() factories).
virtual void destroy (void);
// Call this instead of <delete> to free up dynamically allocated
// <Svc_Handlers> (otherwise you will get memory leaks). This
// method knows whether or not the object was allocated dynamically,
// and can act accordingly (i.e., deleting it if it was allocated
// dynamically, otherwise ignoring it).
void *operator new (size_t n);
// Overloaded new operator. This is used to unobtrusively detect
// when a Svc_Handler is allocated dynamically.
void shutdown (void);
// Close down the descriptor and unregister from the Reactor
void dump (void) const;
// Dump the state of an object.
public:
void operator delete (void *);
// This really should be private so that users are forced to call
// destroy(). Unfortunately, the C++ standard doesn't allow there
// to be a public new and a private delete.
public:
// Note: The following methods are not suppose to be public. But
// because friendship is *not* inherited in C++, these methods have
// to be public.
// = Accessors to set/get the connection recycler.
virtual void recycler (ACE_Connection_Recycling_Strategy *recycler,
const void *recycling_act);
// Set the recycler and the <recycling_act> that is used during
// purging and caching.
virtual ACE_Connection_Recycling_Strategy *recycler (void) const;
// Get the recycler.
virtual int recycle (void * = 0);
// Upcall made by the recycler when it is about to recycle the
// connection. This gives the object a chance to prepare itself for
// recycling. Return 0 if the object is ready for recycling, -1 on
// failures.
private:
ACE_PEER_STREAM peer_;
// Maintain connection with client.
typedef ACE_TSS_Singleton<ACE_Dynamic, ACE_SYNCH_NULL_MUTEX> DYNAMIC;
// Point of access to the ACE_Dynamic singleton.
char dynamic_;
// Have we been dynamically created?
char closing_;
// Keeps track of whether we are in the process of closing (required
// to avoid circular calls to <handle_close>).
ACE_Connection_Recycling_Strategy *recycler_;
// Pointer to the connection recycler.
const void *recycling_act_;
// ACT to be used to when talking to the recycler.
};
#if defined (__ACE_INLINE__)
#include "ace/Svc_Handler.i"
#endif /* __ACE_INLINE__ */
#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
#include "ace/Svc_Handler.cpp"
#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */
#if defined (ACE_TEMPLATES_REQUIRE_PRAGMA)
#pragma implementation ("Svc_Handler.cpp")
#endif /* ACE_TEMPLATES_REQUIRE_PRAGMA */
#endif /* ACE_SVC_HANDLER_H */
|
