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
|
// -*- C++ -*-
//=============================================================================
/**
* @file UIPMC_Transport.h
*
* $Id$
*
* @author Frank Hunleth <fhunleth@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_UIPMC_TRANSPORT_H
#define TAO_UIPMC_TRANSPORT_H
#include /**/ "ace/pre.h"
#include "orbsvcs/PortableGroup/portablegroup_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/Transport.h"
#include "ace/SOCK_Stream.h"
#include "ace/Svc_Handler.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
// Forward decls.
class TAO_UIPMC_Connection_Handler;
class TAO_ORB_Core;
class TAO_Operation_Details;
class TAO_Pluggable_Messaging;
class TAO_Acceptor;
// Service Handler for this transport
typedef ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>
TAO_UIPMC_SVC_HANDLER;
#if defined ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION_EXPORT
template class TAO_PortableGroup_Export ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>;
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION_EXPORT */
/**
* @class TAO_UIPMC_Transport
*
* @brief Specialization of the base TAO_Transport class to handle the
* MIOP protocol.
*/
class TAO_PortableGroup_Export TAO_UIPMC_Transport : public TAO_Transport
{
public:
/// Constructor.
TAO_UIPMC_Transport (TAO_UIPMC_Connection_Handler *handler,
TAO_ORB_Core *orb_core,
CORBA::Boolean flag);
/// Default destructor.
~TAO_UIPMC_Transport (void);
/// Look for the documentation in Transport.h.
virtual int handle_input (TAO_Resume_Handle &rh,
ACE_Time_Value *max_wait_time = 0,
int block = 0);
protected:
/** @name Overridden Template Methods
*
* These are implementations of template methods declared by TAO_Transport.
*/
//@{
virtual ACE_Event_Handler * event_handler_i (void);
virtual TAO_Connection_Handler *connection_handler_i (void);
virtual TAO_Pluggable_Messaging *messaging_object (void);
/// Write the complete Message_Block chain to the connection.
virtual ssize_t send (iovec *iov, int iovcnt,
size_t &bytes_transferred,
const ACE_Time_Value *max_wait_time);
/// Read len bytes from into buf.
virtual ssize_t recv (char *buf,
size_t len,
const ACE_Time_Value *s = 0);
virtual int register_handler (void);
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 = TAO_Transport::TAO_TWOWAY_REQUEST,
ACE_Time_Value *max_time_wait = 0);
/// Initialising the messaging object
virtual int messaging_init (CORBA::Octet major,
CORBA::Octet minor);
//@}
private:
/// Process the message that we have read.
int process_message (void);
/// Construct and write a unique ID to the MIOP header.
void write_unique_id (TAO_OutputCDR &miop_hdr, unsigned long unique);
private:
/// The connection service handler used for accessing lower layer
/// communication protocols.
TAO_UIPMC_Connection_Handler *connection_handler_;
/// Our messaging object.
TAO_Pluggable_Messaging *messaging_object_;
};
TAO_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif /* TAO_UIPMC_TRANSPORT_H */
|
