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
|
// This may look like C, but it's really -*- C++ -*-
// -*- C++ -*-
// ===================================================================
/**
* @file HTIOP_Transport.h
*
* $Id$
*
* @author Originally by Fred Kuhns <fredk@cs.wustl.edu>
* @author Modified by Balachandran Natarajan <bala@cs.wustl.edu>
*/
// ===================================================================
#ifndef TAO_HTIOP_TRANSPORT_H
#define TAO_HTIOP_TRANSPORT_H
#include /**/ "ace/pre.h"
#include "HTIOP_Export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "orbsvcs/HTIOPC.h"
#include "ace/HTBP/HTBP_Stream.h"
#include "tao/Transport.h"
#include "ace/Synch.h"
#include "ace/Svc_Handler.h"
//#include "HTIOP/HTIOPC.h"
// Forward decls.
class TAO_ORB_Core;
class TAO_Operation_Details;
class TAO_Pluggable_Messaging;
class TAO_Acceptor;
class TAO_Adapter;
# if defined (ACE_HAS_TEMPLATE_TYPEDEFS)
# define ACE_HTBP_STREAM ACE::HTBP::Stream
# else /* If TEMPLATES are broken in some form or another */
# define ACE_HTBP_STREAM ACE::HTBP::Stream, ACE::HTBP::Addr
#endif /* ACE_HAS_TEMPLATE_TYPEDEFS */
namespace TAO
{
namespace HTIOP
{
class Connection_Handler;
// Service Handler for this transport
typedef ACE_Svc_Handler<ACE_HTBP_STREAM, ACE_NULL_SYNCH>
SVC_HANDLER;
/**
* @class Transport
*
* @brief Specialization of the base Transport class to handle the
* HTIOP protocol.
*
*
*
*/
class HTIOP_Export Transport : public TAO_Transport
{
public:
/// Constructor.
Transport (Connection_Handler *handler,
TAO_ORB_Core *orb_core,
CORBA::Boolean flag);
/// Default destructor.
~Transport (void);
protected:
/** @name Overridden Template Methods
*
* Please check the documentation in "tao/Transport.h" for more
* details.
*/
//@{
virtual ACE_Event_Handler * event_handler_i (void);
virtual TAO_Connection_Handler * invalidate_event_handler_i (void);
/// Access the underlying messaging object
virtual TAO_Pluggable_Messaging *messaging_object (void);
virtual ssize_t send (iovec *iov, int iovcnt,
size_t &bytes_transferred,
const ACE_Time_Value *timeout = 0);
virtual ssize_t recv (char *buf,
size_t len,
const ACE_Time_Value *s = 0);
virtual int register_handler (void);
virtual int send_message_shared (TAO_Stub *stub,
int message_semantics,
const ACE_Message_Block *message_block,
ACE_Time_Value *max_wait_time);
public:
/// @@TODO: These methods IMHO should have more meaningful
/// names. The names seem to indicate nothing.
virtual int send_request (TAO_Stub *stub,
TAO_ORB_Core *orb_core,
TAO_OutputCDR &stream,
int message_semantics,
ACE_Time_Value *max_wait_time);
virtual int send_message (TAO_OutputCDR &stream,
TAO_Stub *stub = 0,
int message_semantics =
Transport::TAO_TWOWAY_REQUEST,
ACE_Time_Value *max_time_wait = 0);
// @@ This is probably not needed - Priyanka
// This is needed because we want to send additional information
// such as session id etc. in the header.
virtual int generate_request_header (TAO_Operation_Details &opdetails,
TAO_Target_Specification &spec,
TAO_OutputCDR &msg);
virtual int messaging_init (CORBA::Octet major,
CORBA::Octet minor);
virtual int tear_listen_point_list (TAO_InputCDR &cdr);
virtual TAO_Connection_Handler * connection_handler_i (void);
//@}
private:
/// Set the Bidirectional context info in the service context list
void set_bidir_context_info (TAO_Operation_Details &opdetails);
/// Add the listen points in <acceptor> to the <listen_point_list>
/// if this connection is in the same interface as that of the
/// endpoints in the <acceptor>
int get_listen_point (::HTIOP::ListenPointList &listen_point_list,
TAO_Acceptor *acceptor);
/// The connection service handler used for accessing lower layer
/// communication protocols.
Connection_Handler *connection_handler_;
/// Our messaging object.
TAO_Pluggable_Messaging *messaging_object_;
};
}
}
#if defined (__ACE_INLINE__)
#include "HTIOP_Transport.i"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TRANSPORT_H */
|
