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
|
//$Id$
ACE_INLINE
TAO_GIOP_Message_Lite::TAO_GIOP_Message_Lite (TAO_ORB_Core *orb_core)
:cdr_buffer_alloc_ (orb_core->resource_factory ()->output_cdr_buffer_allocator ()),
cdr_dblock_alloc_ (orb_core->resource_factory ()->output_cdr_dblock_allocator ())
{
#if defined (ACE_HAS_PURIFY)
(void) ACE_OS::memset (this->repbuf_,
'\0',
sizeof this->repbuf_);
#endif /* ACE_HAS_PURIFY */
ACE_NEW (this->output_,
TAO_OutputCDR (this->repbuf_,
sizeof this->repbuf_,
TAO_ENCAP_BYTE_ORDER,
this->cdr_buffer_alloc_,
this->cdr_dblock_alloc_,
orb_core->orb_params ()->cdr_memcpy_tradeoff (),
orb_core->to_iso8859 (),
orb_core->to_unicode ()));
}
ACE_INLINE
TAO_GIOP_Message_Lite::~TAO_GIOP_Message_Lite (void)
{
// Explicitly call the destructor of the output CDR first. They need
// the allocators during destruction.
delete this->output_;
// Then call the destructor of our allocators
if (this->cdr_dblock_alloc_ != 0)
this->cdr_dblock_alloc_->remove ();
// delete this->cdr_dblock_alloc_;
if (this->cdr_buffer_alloc_ != 0)
this->cdr_buffer_alloc_->remove ();
// delete this->cdr_buffer_alloc_;
}
ACE_INLINE int
TAO_GIOP_Message_Lite::parse_header (TAO_GIOP_Message_State *state)
{
// Get the read pointer
char *buf = state->cdr.rd_ptr ();
// @@ Bala: i added the following comment, does it make sense?
// In GIOPLite the version, byte order info, etc. are hardcoded, and
// not transmitted over the wire.
state->byte_order = TAO_ENCAP_BYTE_ORDER;
state->giop_version.major = TAO_DEF_GIOP_MAJOR;
state->giop_version.minor = TAO_DEF_GIOP_MINOR;
// Get the message type.
state->message_type = buf[TAO_GIOP_LITE_MESSAGE_TYPE_OFFSET];
state->cdr.reset_byte_order (state->byte_order);
// The first bytes are the length of the message.
state->cdr.read_ulong (state->message_size);
return 0;
}
|
