blob: a3119f47c4e4f1abf6921be891ed98c053baf265 (
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
|
//$Id$
ACE_INLINE CORBA::Boolean
TAO_GIOP_Message_Lite::
write_locate_request_header (CORBA::ULong request_id,
TAO_Target_Specification &spec,
TAO_OutputCDR &msg)
{
msg << request_id;
// In this case we cannot recognise anything other than the Object
// key as the address disposition variable. But we do a sanity check
// anyway.
const TAO_ObjectKey *key = spec.object_key ();
if (key)
{
// Put in the object key
msg << *key;
}
else
{
if (TAO_debug_level)
ACE_DEBUG ((LM_DEBUG,
ASYS_TEXT ("(%N |%l) Unable to handle this request \n")));
return 0;
}
return 1;
}
ACE_INLINE int
TAO_GIOP_Message_Lite::parse_header (TAO_GIOP_Message_State *state)
{
// Get the read pointer
char *buf = state->cdr.rd_ptr ();
state->byte_order = TAO_ENCAP_BYTE_ORDER;
state->giop_version.major = TAO_DEF_GIOP_MAJOR;
state->giop_version.minor = TAO_DEF_GIOP_MINOR;
state->message_type = buf[TAO_GIOP_LITE_MESSAGE_TYPE_OFFSET];
state->cdr.reset_byte_order (state->byte_order);
state->cdr.read_ulong (state->message_size);
return 0;
}
ACE_INLINE CORBA::Boolean
TAO_GIOP_Message_Lite::
make_reply (CORBA::ULong request_id,
TAO_OutputCDR &output)
{
// Write the GIOP header first
this->write_protocol_header (TAO_PLUGGABLE_MESSAGE_REPLY,
output);
// create and write a dummy context
// We dont really need this. But for some reason the reply is not
// parsable on the receiving side?
// @@Bala, look in to this
IOP::ServiceContextList resp_ctx;
resp_ctx.length (0);
output << resp_ctx;
// Write the request ID
output.write_ulong (request_id);
return 0;
}
|
