| Methods Summary |
|---|
| public com.sun.corba.se.pept.encoding.InputObject | createInputObject(com.sun.corba.se.pept.broker.Broker broker, com.sun.corba.se.pept.protocol.MessageMediator messageMediator)
// REVISIT: Duplicate of acceptor code.
CorbaMessageMediator corbaMessageMediator = (CorbaMessageMediator)
messageMediator;
return new CDRInputObject((ORB)broker,
(CorbaConnection)messageMediator.getConnection(),
corbaMessageMediator.getDispatchBuffer(),
corbaMessageMediator.getDispatchHeader());
|
| public com.sun.corba.se.pept.protocol.MessageMediator | createMessageMediator(com.sun.corba.se.pept.broker.Broker broker, com.sun.corba.se.pept.transport.ContactInfo contactInfo, com.sun.corba.se.pept.transport.Connection connection, java.lang.String methodName, boolean isOneWay)
// REVISIT: Would like version, ior, requestid, etc., decisions
// to be in client subcontract. Cannot pass these to this
// factory method because it breaks generic abstraction.
// Maybe set methods on mediator called from subcontract
// after creation?
CorbaMessageMediator messageMediator =
new CorbaMessageMediatorImpl(
(ORB) broker,
contactInfo,
connection,
GIOPVersion.chooseRequestVersion( (ORB)broker,
effectiveTargetIOR),
effectiveTargetIOR,
((CorbaConnection)connection).getNextRequestId(),
getAddressingDisposition(),
methodName,
isOneWay);
return messageMediator;
|
| public com.sun.corba.se.pept.protocol.MessageMediator | createMessageMediator(com.sun.corba.se.pept.broker.Broker broker, com.sun.corba.se.pept.transport.Connection conn)
ORB orb = (ORB) broker;
CorbaConnection connection = (CorbaConnection) conn;
if (orb.transportDebugFlag) {
if (connection.shouldReadGiopHeaderOnly()) {
dprint(
".createMessageMediator: waiting for message header on connection: "
+ connection);
} else {
dprint(
".createMessageMediator: waiting for message on connection: "
+ connection);
}
}
Message msg = null;
if (connection.shouldReadGiopHeaderOnly()) {
// read giop header only
msg = MessageBase.readGIOPHeader(orb, connection);
} else {
// read entire giop message
msg = MessageBase.readGIOPMessage(orb, connection);
}
ByteBuffer byteBuffer = msg.getByteBuffer();
msg.setByteBuffer(null);
CorbaMessageMediator messageMediator =
new CorbaMessageMediatorImpl(orb, connection, msg, byteBuffer);
return messageMediator;
|
| public com.sun.corba.se.pept.encoding.OutputObject | createOutputObject(com.sun.corba.se.pept.protocol.MessageMediator messageMediator)
CorbaMessageMediator corbaMessageMediator = (CorbaMessageMediator)
messageMediator;
OutputObject outputObject =
new CDROutputObject(orb, messageMediator,
corbaMessageMediator.getRequestHeader(),
corbaMessageMediator.getStreamFormatVersion());
messageMediator.setOutputObject(outputObject);
return outputObject;
|
| protected void | dprint(java.lang.String msg)
ORBUtility.dprint("CorbaContactInfoBase", msg);
|
| public com.sun.corba.se.pept.protocol.MessageMediator | finishCreatingMessageMediator(com.sun.corba.se.pept.broker.Broker broker, com.sun.corba.se.pept.transport.Connection conn, com.sun.corba.se.pept.protocol.MessageMediator messageMediator)
ORB orb = (ORB) broker;
CorbaConnection connection = (CorbaConnection) conn;
CorbaMessageMediator corbaMessageMediator =
(CorbaMessageMediator)messageMediator;
if (orb.transportDebugFlag) {
dprint(
".finishCreatingMessageMediator: waiting for message body on connection: "
+ connection);
}
Message msg = corbaMessageMediator.getDispatchHeader();
msg.setByteBuffer(corbaMessageMediator.getDispatchBuffer());
// read giop body only
msg = MessageBase.readGIOPBody(orb, connection, msg);
ByteBuffer byteBuffer = msg.getByteBuffer();
msg.setByteBuffer(null);
corbaMessageMediator.setDispatchHeader(msg);
corbaMessageMediator.setDispatchBuffer(byteBuffer);
return corbaMessageMediator;
|
| public short | getAddressingDisposition()
return addressingDisposition;
|
| public com.sun.corba.se.pept.broker.Broker | getBroker()
return orb;
|
| public com.sun.corba.se.pept.protocol.ClientRequestDispatcher | getClientRequestDispatcher()
int scid =
getEffectiveProfile().getObjectKeyTemplate().getSubcontractId() ;
RequestDispatcherRegistry scr = orb.getRequestDispatcherRegistry() ;
return scr.getClientRequestDispatcher( scid ) ;
|
| public com.sun.corba.se.pept.transport.OutboundConnectionCache | getConnectionCache()
return connectionCache;
|
| public com.sun.corba.se.pept.transport.ContactInfoList | getContactInfoList()
return contactInfoList;
|
| public com.sun.corba.se.spi.ior.iiop.IIOPProfile | getEffectiveProfile()
return effectiveTargetIOR.getProfile();
|
| public com.sun.corba.se.spi.ior.IOR | getEffectiveTargetIOR()
return effectiveTargetIOR ;
|
| public com.sun.corba.se.spi.ior.IOR | getTargetIOR()
return contactInfoList.getTargetIOR();
|
| public void | setAddressingDisposition(short addressingDisposition)
this.addressingDisposition = addressingDisposition;
|
| public void | setConnectionCache(com.sun.corba.se.pept.transport.OutboundConnectionCache connectionCache)
this.connectionCache = connectionCache;
|
| public java.lang.String | toString()
return
"CorbaContactInfoBase["
+ "]";
|
