blob: 3f262373f547c1b60b5c989be13397d01badec86 (
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
164
165
166
167
168
|
// -*- C++ -*-
//=============================================================================
/**
* @file GIOP_Message_State.h
*
* $Id$
*
* GIOP utility definitions
*
*
* @author Chris Cleeland <cleeland@cs.wustl.edu>
* @author Carlos O' Ryan <coryan@uci.edu>
* @author modified by Balachandran Natarajan <bala@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_GIOP_MESSAGE_STATE_H
#define TAO_GIOP_MESSAGE_STATE_H
#include "ace/pre.h"
#include "tao/GIOP_Message_Version.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class TAO_ORB_Core;
class TAO_GIOP_Message_Base;
/**
* @class TAO_GIOP_Message_State
*
* @brief Generic definitions for Message States.
*
* This helps to establish the state of the incoming messages.
*/
class TAO_Export TAO_GIOP_Message_State
{
public:
/// Ctor
TAO_GIOP_Message_State (TAO_ORB_Core *orb_core,
TAO_GIOP_Message_Base *base);
/// Parse the message header.
int parse_message_header (ACE_Message_Block &incoming);
/// Return the message size
CORBA::ULong message_size (void) const;
/// Return the message size
CORBA::ULong payload_size (void) const;
/// Return the byte order information
CORBA::Octet byte_order (void) const;
/// Reset the state..
void reset (void);
private:
friend class TAO_GIOP_Message_Base;
/// Parse the message header.
int parse_message_header_i (ACE_Message_Block &incoming);
/// Checks for the magic word 'GIOP' in the start of the incoing
/// stream
int parse_magic_bytes (char *buf);
/// Extracts the version information from the incoming
/// stream. Performs a check for whether the version information is
/// right and sets the information in the <state>
int get_version_info (char *buf);
/// Extracts the byte order information from the incoming
/// stream. Performs a check for whether the byte order information
/// right and sets the information in the <state>
int get_byte_order_info (char *buf);
/// Gets the size of the payload and set the size in the <state>
void get_payload_size (char *buf);
/// Parses the GIOP FRAGMENT_HEADER information from the incoming
/// stream.
int parse_fragment_header (char *buf,
size_t length);
/// Read the unsigned long from the buffer. The <buf> should just
/// point to the next 4 bytes data that represent the ULong
CORBA::ULong read_ulong (char *buf);
private:
// GIOP version information..
TAO_GIOP_Message_Version giop_version_;
/// 0 = big, 1 = little
CORBA::Octet byte_order_;
/// MsgType above
CORBA::Octet message_type_;
/// in byte_order!
CORBA::ULong message_size_;
/// Request Id from the Fragment header
CORBA::ULong request_id_;
/**
* 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 the main message block that is sent
* along
*/
// ACE_Message_Block fragmented_messages;
/**
* 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.
*/
// CORBA::Octet first_fragment_byte_order;
/// The GIOP version for the first fragment
/// @@ Same as above, all GIOP versions must match.
// TAO_GIOP_Message_Version first_fragment_giop_version;
/**
* 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).
*/
// CORBA::Octet first_fragment_message_type;
/// (Requests and Replys)
CORBA::Octet more_fragments_;
/// Missing data
CORBA::ULong missing_data_;
};
const size_t TAO_GIOP_MESSAGE_HEADER_LEN = 12;
const size_t TAO_GIOP_MESSAGE_SIZE_OFFSET = 8;
const size_t TAO_GIOP_MESSAGE_FLAGS_OFFSET = 6;
const size_t TAO_GIOP_MESSAGE_TYPE_OFFSET = 7;
const size_t TAO_GIOP_VERSION_MINOR_OFFSET = 5;
const size_t TAO_GIOP_VERSION_MAJOR_OFFSET = 4;
const size_t TAO_GIOP_MESSAGE_FRAGMENT_HEADER = 4;
#if defined (__ACE_INLINE__)
# include "tao/GIOP_Message_State.inl"
#endif /* __ACE_INLINE__ */
#include "ace/post.h"
#endif /*TAO_GIOP_MESSAGE_STATE_H*/
|
