38 |
|
|
39 |
package gnu.CORBA; |
package gnu.CORBA; |
40 |
|
|
41 |
import gnu.CORBA.CDR.cdrBufInput; |
import gnu.CORBA.CDR.BufferredCdrInput; |
42 |
import gnu.CORBA.CDR.cdrBufOutput; |
import gnu.CORBA.CDR.BufferedCdrOutput; |
43 |
import gnu.CORBA.GIOP.MessageHeader; |
import gnu.CORBA.GIOP.MessageHeader; |
44 |
import gnu.CORBA.GIOP.ReplyHeader; |
import gnu.CORBA.GIOP.ReplyHeader; |
45 |
import gnu.CORBA.GIOP.RequestHeader; |
import gnu.CORBA.GIOP.RequestHeader; |
346 |
// correctly. |
// correctly. |
347 |
if (ior.Internet.version.until_inclusive(1, 1)) |
if (ior.Internet.version.until_inclusive(1, 1)) |
348 |
{ |
{ |
349 |
cdrBufOutput measure = new cdrBufOutput(); |
BufferedCdrOutput measure = new BufferedCdrOutput(); |
350 |
measure.setOffset(12); |
measure.setOffset(12); |
351 |
if (m_rqh == null) |
if (m_rqh == null) |
352 |
m_rqh = new gnu.CORBA.GIOP.v1_0.RequestHeader(); |
m_rqh = new gnu.CORBA.GIOP.v1_0.RequestHeader(); |
744 |
m_interceptor.send_request(m_info); |
m_interceptor.send_request(m_info); |
745 |
|
|
746 |
// Prepare the submission. |
// Prepare the submission. |
747 |
cdrBufOutput request_part = new cdrBufOutput(); |
BufferedCdrOutput request_part = new BufferedCdrOutput(); |
748 |
|
|
749 |
request_part.setOffset(header.getHeaderSize()); |
request_part.setOffset(header.getHeaderSize()); |
750 |
request_part.setVersion(header.version); |
request_part.setVersion(header.version); |
941 |
if (m_rph == null) |
if (m_rph == null) |
942 |
m_rph = response.header.create_reply_header(); |
m_rph = response.header.create_reply_header(); |
943 |
|
|
944 |
cdrBufInput input = response.getStream(); |
BufferredCdrInput input = response.getStream(); |
945 |
input.setOrb(orb); |
input.setOrb(orb); |
946 |
|
|
947 |
m_rph.read(input); |
m_rph.read(input); |
1072 |
/** |
/** |
1073 |
* Read exception id without changing the stream pointer position. |
* Read exception id without changing the stream pointer position. |
1074 |
*/ |
*/ |
1075 |
void readExceptionId(cdrBufInput input) |
void readExceptionId(BufferredCdrInput input) |
1076 |
{ |
{ |
1077 |
input.mark(2048); |
input.mark(2048); |
1078 |
m_exception_id = input.read_string(); |
m_exception_id = input.read_string(); |
1088 |
* @throws MARSHAL if the attempt to write the parameters has failde. |
* @throws MARSHAL if the attempt to write the parameters has failde. |
1089 |
*/ |
*/ |
1090 |
protected void write_parameter_buffer(MessageHeader header, |
protected void write_parameter_buffer(MessageHeader header, |
1091 |
cdrBufOutput request_part |
BufferedCdrOutput request_part |
1092 |
) throws MARSHAL |
) throws MARSHAL |
1093 |
{ |
{ |
1094 |
try |
try |
1116 |
* @throws MARSHAL if the attempt to write the parameters has failde. |
* @throws MARSHAL if the attempt to write the parameters has failde. |
1117 |
*/ |
*/ |
1118 |
protected void write_parameters(MessageHeader header, |
protected void write_parameters(MessageHeader header, |
1119 |
cdrBufOutput request_part |
BufferedCdrOutput request_part |
1120 |
) throws MARSHAL |
) throws MARSHAL |
1121 |
{ |
{ |
1122 |
// Align after 1.2, but only once. |
// Align after 1.2, but only once. |
1167 |
*/ |
*/ |
1168 |
public TaggedProfile effective_profile() |
public TaggedProfile effective_profile() |
1169 |
{ |
{ |
1170 |
cdrBufOutput buf = new cdrBufOutput(512); |
BufferedCdrOutput buf = new BufferedCdrOutput(512); |
1171 |
buf.setOrb(orb); |
buf.setOrb(orb); |
1172 |
ior.Internet.write(buf); |
ior.Internet.write(buf); |
1173 |
|
|
1194 |
if (id == TAG_CODE_SETS.value) |
if (id == TAG_CODE_SETS.value) |
1195 |
{ |
{ |
1196 |
// Codesets are encoded separately. |
// Codesets are encoded separately. |
1197 |
cdrBufOutput buf = new cdrBufOutput(512); |
BufferedCdrOutput buf = new BufferedCdrOutput(512); |
1198 |
buf.setOrb(orb); |
buf.setOrb(orb); |
1199 |
ior.Internet.CodeSets.write(buf); |
ior.Internet.CodeSets.write(buf); |
1200 |
|
|