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++ -*-
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// GIOP_Message_Connectors.h
//
// = DESCRIPTION
// Interface for the client side of the GIOP classes
//
// = AUTHOR
// Balachandran Natarajan <bala@cs.wustl.edu>
//
// ============================================================================
#ifndef _TAO_GIOP_MESSAGE_CONNECTORS_
#define _TAO_GIOP_MESSAGE_CONNECTORS_
#include "tao/GIOP_Message_Base.h"
class TAO_Export TAO_GIOP_Message_Connectors:
public TAO_GIOP_Message_Base
{
// = TITLE
// TAO_GIOP_Message_Connectors
// = DESCRIPTION
// This class provides methods and code for the connector specific
// functionality of GIOP.The motivation for this class is to hold
// common code between different versions of GIOP in a single
// class.
int process_connector_messages (TAO_Transport *transport,
TAO_ORB_Core *orb_core,
TAO_InputCDR &input,
CORBA::Octet message_type);
// Processes the messages from the connectors so that they can be
// passed on to the appropriate states.
protected:
virtual CORBA::Boolean
write_request_header (const IOP::ServiceContextList& svc_ctx,
CORBA::ULong request_id,
CORBA::Octet response_flags,
TAO_Target_Specification &spec,
const char* opname,
TAO_OutputCDR &msg);
// Write the GIOP request header.
int parse_reply (TAO_Message_State_Factory &mesg_state,
TAO_Pluggable_Connector_Params ¶ms,
CORBA::ULong &reply_status);
// Parse the reply message from the server
private:
virtual CORBA::Boolean
write_locate_request_header (CORBA::ULong request_id,
TAO_Target_Specification &spec,
TAO_OutputCDR &msg) = 0;
// Need not be here. But just for the sake of documentaion.
int validate_version (TAO_GIOP_Message_State *state);
CORBA::Octet major_version (void) = 0;
CORBA::Octet minor_version (void) = 0;
// Virtual methods that will be implemented by the version specific
// class. There may be a feeling that this declaration may not be
// required, but some of the code in the class look for this method
};
//////////////////////////////////////////////////
// Version specific classes of GIOP
//////////////////////////////////////////////////
class TAO_Export TAO_GIOP_Message_Connector_11:
public TAO_GIOP_Message_Connectors
{
// = TITLE
// TAO_GIOP_Message_Connector_11
// = DESCRIPTION
// This class provides methods methods that implements the GIOP
// (1.1) specific stuff.
public:
private:
virtual CORBA::Boolean
write_request_header (const IOP::ServiceContextList& svc_ctx,
CORBA::ULong request_id,
CORBA::Octet response_flags,
TAO_Target_Specification &spec,
const char* opname,
TAO_OutputCDR &msg);
// Write the request header in to <msg>
CORBA::Boolean
write_locate_request_header (CORBA::ULong request_id,
TAO_Target_Specification &spec,
TAO_OutputCDR &msg);
// Write the locate request header in to the <msg>
int parse_reply (TAO_Message_State_Factory &mesg_state,
TAO_Pluggable_Connector_Params ¶ms,
CORBA::ULong &reply_status);
// Parse the reply messages from the server
CORBA::Octet major_version (void);
CORBA::Octet minor_version (void);
// Our minor and major versions
};
class TAO_Export TAO_GIOP_Message_Connector_10:
public TAO_GIOP_Message_Connector_11
{
// = TITLE
// TAO_GIOP_Message_Connector_10
// = DESCRIPTION
// This class is deribed from the 1.1 version of GIOP. At presnt
// this only returns the right version number
public:
private:
CORBA::Octet minor_version (void);
};
#if defined (__ACE_INLINE__)
# include "tao/GIOP_Message_Connectors.i"
#endif /* __ACE_INLINE__ */
#endif /*_TAO_GIOP_MESSAGE_CONNECTORS_*/
|
