blob: eb5de7d3751a8cad46cc78f5ee1c7f5808b18953 (
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
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
|
// -*- C++ -*-
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// GIOP_Message.h
//
// = DESCRIPTION
// GIOP utility definitions
//
// = AUTHOR
// Chris Cleeland <cleeland@cs.wustl.edu>
// Carlos O' Ryan <coryan@uci.edu>
//
// ============================================================================
#ifndef TAO_GIOP_MESSAGE_STATE_H
#define TAO_GIOP_MESSAGE_STATE_H
#include "ace/pre.h"
#include "tao/Pluggable_Messaging.h"
// @@ Bala more missing #pragma once
class TAO_Export TAO_GIOP_Version
{
// = TITLE
// Major and Minor version number of the Inter-ORB Protocol.
public:
CORBA::Octet major;
// Major version number
CORBA::Octet minor;
// Minor version number
TAO_GIOP_Version (const TAO_GIOP_Version &src);
// Copy constructor
TAO_GIOP_Version (CORBA::Octet maj = TAO_DEF_GIOP_MAJOR,
CORBA::Octet min = TAO_DEF_GIOP_MINOR);
// Default constructor.
~TAO_GIOP_Version (void);
// Destructor.
void set_version (CORBA::Octet maj, CORBA::Octet min);
// Explicitly set the major and minor version.
TAO_GIOP_Version &operator= (const TAO_GIOP_Version &src);
// Copy operator.
int operator== (const TAO_GIOP_Version &src);
int operator!= (const TAO_GIOP_Version &src);
// Equality operator
};
// @@ Bala: do you see how these names are inconsistent! It is a
// @@ message state factory for GIOP or is it a message state?
class TAO_Export TAO_GIOP_Message_State : public TAO_Message_State_Factory
{
// = TITLE
// Generic definitions for Message States.
//
// = DESCRIPTION
// @@ Bala: please don't write comments in conditional form.
// @@ Don't say what the class could or would do, say what it
// @@ *does*
// @@ Bala: i remain unconvinced as to whether the base class here
// @@ is any useful.
//
// This would represent the state of the incoming message states.
// As the ORB processes incoming messages it need to keep track of
// how much of the message has been read, if there are any
// fragments following this message etc. This class attempts to
// give a generic interface to all the messaging protocols message
// states so that the Transport layer does not really know with
// whom it is interacting with.
public:
TAO_GIOP_Message_State (TAO_ORB_Core *orb_core);
// Ctor
~TAO_GIOP_Message_State (void);
// Dtor
void reset (int reset_contents = 1);
//Reset the message header state and prepare it to receive the next
// event.
CORBA::Boolean header_received (void) const;
// Has the header been received?
int is_complete (void);
// Check if the current message is complete, adjusting the fragments
// if required...
TAO_GIOP_Version giop_version;
// Version info
CORBA::Octet byte_order;
// 0 = big, 1 = little
CORBA::Octet more_fragments;
// (Requests and Replys)
CORBA::Octet message_type;
// MsgType above
CORBA::ULong message_size;
// in byte_order!
CORBA::ULong current_offset;
// How much of the payload has been received
TAO_InputCDR cdr;
// This is the InputCDR that will be used to decode the message.
ACE_Message_Block* fragments_begin;
ACE_Message_Block* fragments_end;
// The fragments are collected in a chain of message blocks (using
// the cont() field). When the complete message is received the
// chain is reassembled into <cdr>
CORBA::Octet first_fragment_byte_order;
// The byte order for the the first fragment
// @@ The current implementation cannot handle fragments with
// different byte orders, this should not be a major problem
// because:
// 1) It is unlikely that we are going to receive fragments.
// 2) The spec *seems* to allow different byte_orders, but it is
// unlikely that any ORB will do that.
// 3) Even if we allowed that at this layer the CDR classes are
// not prepared to handle that.
TAO_GIOP_Version first_fragment_giop_version;
// The GIOP version for the first fragment
// @@ Same as above, all GIOP versions must match.
CORBA::Octet first_fragment_message_type;
// If the messages are chained this represents the message type for
// the *complete* message (remember that the last message will be
// fragment and the upper level needs to know if it is a request,
// locate request or what).
private:
int append_fragment (ACE_Message_Block* current);
// Append <current> to the list of fragments
// Also resets the state, because the current message was consumed.
};
#if defined (__ACE_INLINE__)
# include "tao/GIOP_Message_State.i"
#endif /* __ACE_INLINE__ */
#include "ace/post.h"
#endif /*TAO_GIOP_MESSAGE_STATE_H*/
|
