blob: 14aa78305979f8f9e7807c9b4ab40423cfa01f07 (
plain)
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
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Connection_Handler.h
*
* $Id$
*
* @author Bala Natarajan <bala@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_CONNECTION_HANDLER_H
#define TAO_CONNECTION_HANDLER_H
#include "ace/pre.h"
#include "ace/SOCK.h"
#include "tao/Transport.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined(_MSC_VER)
#if (_MSC_VER >= 1200)
#pragma warning(push)
#endif /* _MSC_VER >= 1200 */
#pragma warning(disable:4250)
#endif /* _MSC_VER */
class TAO_ORB_Core;
class TAO_ORB_Core_TSS_Resources;
class ACE_Reactor;
class ACE_Event_Handler;
/**
* @class TAO_Connection_Handler
*
* @brief TAO_Connection_Handler
*
* This class is an abstraction for the connection handlers. The
* connections handler in every protocol can derive from this
* class as well as the ACE_Svc_Handler specialised for the
* right protocol. This way, most of the common code for the
* different protocls would be in this implementation. Further,
* this class wold be of immense use in storing the handlers in
* the Cache for TAO. This would help in purging entries which
* is generally accompanied by closing the open handles and
* deleting memory associated with the handlers.
*/
class TAO_Export TAO_Connection_Handler
{
// Note: This class has NOT abstracted the GIOP specific
// details. It is just to be safe so that, we can reuse this
// class for any messaging protocol underneath. This way we need
// not touch the Cache setup even when using other protocols (I
// mean messaging).
public:
/// Constructor
TAO_Connection_Handler (void);
/// Constructor
TAO_Connection_Handler (TAO_ORB_Core *orb_core);
/// Destructor
virtual ~TAO_Connection_Handler (void);
/// Get and set method for the flag that indicates whether the
/// handler has been registered with the reactor or not.
// CORBA::Boolean is_registered (void);
// void is_registered (CORBA::Boolean);
/// Return the underlying transport object
TAO_Transport *transport (void);
/// Set the underlying transport object
void transport (TAO_Transport* transport);
/// Get the underlying handle
virtual ACE_HANDLE fetch_handle (void) = 0;
protected:
/// Return our TAO_ORB_Core pointer
TAO_ORB_Core *orb_core (void);
/// Return our TSS Resources pointer
TAO_ORB_Core_TSS_Resources* tss_resources (void);
/// Set options on the socket
int set_socket_option (ACE_SOCK &sock,
int snd_size,
int rcv_size);
/// This method is invoked from the svc () method of the Svc_Handler
/// Object.
int svc_i (void);
/// Need to be implemented by the underlying protocol objects
virtual int handle_input_i (ACE_HANDLE = ACE_INVALID_HANDLE,
ACE_Time_Value *max_wait_time = 0) = 0;
private:
/// Pointer to the TAO_ORB_Core
TAO_ORB_Core *orb_core_;
/// Transport object reference
TAO_Transport* transport_;
/// Cached tss resources of the ORB that activated this object.
TAO_ORB_Core_TSS_Resources *tss_resources_;
/// Are we registered with the reactor?
// CORBA::Boolean is_registered_;
};
#if defined (__ACE_INLINE__)
#include "tao/Connection_Handler.inl"
#endif /* __ACE_INLINE__ */
#include "ace/post.h"
#endif /*TAO_CONNECTION_HANDLER_H*/
|
