Uses of Annotation Type
com.sun.corba.ee.spi.trace.Transport

Packages that use Transport

Package	Description
com.sun.corba.ee.impl.encoding
com.sun.corba.ee.impl.legacy.connection
com.sun.corba.ee.impl.plugin.hwlb
com.sun.corba.ee.impl.protocol
com.sun.corba.ee.impl.protocol.giopmsgheaders
com.sun.corba.ee.impl.transport
com.sun.corba.ee.impl.transport.connection
com.sun.corba.ee.spi.orb
com.sun.corba.ee.spi.protocol

Uses of Transport in com.sun.corba.ee.impl.encoding

Classes in com.sun.corba.ee.impl.encoding with annotations of type Transport

Modifier and Type	Class	Description
class	BufferManagerReadStream
class	CDRInputObject

Methods in com.sun.corba.ee.impl.encoding with annotations of type Transport

Modifier and Type	Method	Description
void	BufferManagerReadStream.close(ByteBuffer byteBuffer)
void	BufferManagerReadStream.processFragment(ByteBuffer byteBuffer, FragmentMessage msg)
ByteBuffer	BufferManagerReadStream.underflow(ByteBuffer byteBuffer)
void	CDRInputObject.unmarshalHeader()	Unmarshal the extended GIOP header NOTE: May be fragmented, so should not be called by the ReaderThread.

Uses of Transport in com.sun.corba.ee.impl.legacy.connection

Classes in com.sun.corba.ee.impl.legacy.connection with annotations of type Transport

Modifier and Type	Class	Description
class	SocketFactoryAcceptorImpl
class	SocketFactoryConnectionImpl

Methods in com.sun.corba.ee.impl.legacy.connection with annotations of type Transport

Modifier and Type	Method	Description
private void	SocketFactoryConnectionImpl.connectionCreated(Socket socket)
boolean	SocketFactoryAcceptorImpl.initialize()

Uses of Transport in com.sun.corba.ee.impl.plugin.hwlb

Classes in com.sun.corba.ee.impl.plugin.hwlb with annotations of type Transport

Modifier and Type	Class	Description
class	NoConnectionCacheImpl	Install this in an ORB using the property ORBConstants.USER_CONFIGURATOR_PREFIX + "corba.lb.NoConnectionCacheImpl" = "dummy"
private static class	NoConnectionCacheImpl.NCCConnectionCacheImpl
private static class	NoConnectionCacheImpl.NCCConnectionImpl
private static class	NoConnectionCacheImpl.NCCContactInfoImpl

Methods in com.sun.corba.ee.impl.plugin.hwlb with annotations of type Transport

Modifier and Type	Method	Description
void	NoConnectionCacheImpl.NCCConnectionImpl.close()
private void	NoConnectionCacheImpl.NCCConnectionImpl.constructedNCCConnectionImpl(String str)
Connection	NoConnectionCacheImpl.NCCContactInfoImpl.createConnection()
void	NoConnectionCacheImpl.NCCConnectionCacheImpl.put(ContactInfo contactInfo, Connection conn)
void	NoConnectionCacheImpl.NCCConnectionCacheImpl.remove(ContactInfo contactInfo)
boolean	NoConnectionCacheImpl.NCCContactInfoImpl.shouldCacheConnection()

Uses of Transport in com.sun.corba.ee.impl.protocol

Classes in com.sun.corba.ee.impl.protocol with annotations of type Transport

Modifier and Type	Class	Description
class	MessageMediatorImpl
class	MessageParserImpl	An implementation of a MessageParser that knows how to parse bytes into a GIOP protocol data unit.

Methods in com.sun.corba.ee.impl.protocol with annotations of type Transport

Modifier and Type	Method	Description
private void	MessageMediatorImpl.addMessageMediatorToWorkQueue(MessageMediator messageMediator)
boolean	MessageMediatorImpl.dispatch()	NOTE: This call is the transition from the transport block to the protocol block.
ByteBuffer	MessageParserImpl.getNewBufferAndCopyOld(ByteBuffer byteBuffer)
byte	MessageMediatorImpl.getStreamFormatVersionForReply()	If the RMI-IIOP maximum stream format version service context is present, it indicates the maximum stream format version we could use for the reply.
private byte	MessageMediatorImpl.getStreamFormatVersionForThisRequest(IOR ior, GIOPVersion giopVersion)
void	MessageMediatorImpl.handleInput(CancelRequestMessage header)
void	MessageMediatorImpl.handleInput(FragmentMessage_1_1 header)
void	MessageMediatorImpl.handleInput(FragmentMessage_1_2 header)
void	MessageMediatorImpl.handleInput(LocateReplyMessage_1_0 header)
void	MessageMediatorImpl.handleInput(LocateReplyMessage_1_1 header)
void	MessageMediatorImpl.handleInput(LocateReplyMessage_1_2 header)
void	MessageMediatorImpl.handleInput(LocateRequestMessage_1_0 header)
void	MessageMediatorImpl.handleInput(LocateRequestMessage_1_1 header)
void	MessageMediatorImpl.handleInput(LocateRequestMessage_1_2 header)
void	MessageMediatorImpl.handleInput(Message header)
void	MessageMediatorImpl.handleInput(ReplyMessage_1_0 header)
void	MessageMediatorImpl.handleInput(ReplyMessage_1_1 header)
void	MessageMediatorImpl.handleInput(ReplyMessage_1_2 header)
void	MessageMediatorImpl.handleInput(RequestMessage_1_0 header)
void	MessageMediatorImpl.handleInput(RequestMessage_1_1 header)
void	MessageMediatorImpl.handleInput(RequestMessage_1_2 header)
void	MessageMediatorImpl.handleRequest(LocateRequestMessage msg, MessageMediator messageMediator)
void	MessageMediatorImpl.handleRequest(RequestMessage msg, MessageMediator messageMediator)	/////////////////////////////////////////////////
boolean	MessageMediatorImpl.handleRequest(MessageMediator messageMediator)
Message	MessageParserImpl.parseBytes(ByteBuffer byteBuffer, Connection connection)
private void	MessageMediatorImpl.processCancelRequest(int cancelReqId)
private void	MessageMediatorImpl.releaseByteBufferToPool()
private void	MessageMediatorImpl.resumeOptimizedReadProcessing(Message message)	/////////////////////////////////////////////////
private void	MessageMediatorImpl.setWorkThenPoolOrResumeOptimizedRead(Message header)
private void	MessageMediatorImpl.setWorkThenReadOrResumeOptimizedRead(Message header)

Uses of Transport in com.sun.corba.ee.impl.protocol.giopmsgheaders

Classes in com.sun.corba.ee.impl.protocol.giopmsgheaders with annotations of type Transport

Modifier and Type	Class	Description
final class	ReplyMessage_1_2	This implements the GIOP 1.2 Reply header.
final class	RequestMessage_1_2	This implements the GIOP 1.2 Request header.

Methods in com.sun.corba.ee.impl.protocol.giopmsgheaders with annotations of type Transport

Modifier and Type	Method	Description
void	ReplyMessage_1_2.read(InputStream istream)
void	RequestMessage_1_2.read(InputStream istream)
void	ReplyMessage_1_2.write(OutputStream ostream)
void	RequestMessage_1_2.write(OutputStream ostream)

Uses of Transport in com.sun.corba.ee.impl.transport

Classes in com.sun.corba.ee.impl.transport with annotations of type Transport

Modifier and Type	Class	Description
class	AcceptorBase
class	AcceptorImpl
class	AcceptorLazyImpl	A version of an Acceptor that does not own the ServerSocket.
class	ConnectionCacheBase
class	ConnectionImpl
class	ContactInfoBase
class	ContactInfoListImpl
class	ContactInfoListIteratorImpl
class	EventHandlerBase
class	InboundConnectionCacheImpl
class	ListenerThreadImpl
class	OutboundConnectionCacheImpl
class	ReaderThreadImpl
class	ResponseWaitingRoomImpl
class	SelectorImpl
class	TemporarySelectorStateClosed	An class which models a temporary Selector in a closed state.
class	TemporarySelectorStateOpen	A class which models temporary Selector in an open state.
class	TransportManagerImpl

Methods in com.sun.corba.ee.impl.transport with annotations of type Transport

Modifier and Type	Method	Description
private void	ConnectionImpl.addMessageMediatorToWorkQueue(MessageMediator messageMediator)
private void	ContactInfoListImpl.addRemoteContactInfos(IOR effectiveTargetIOR, List<ContactInfo> effectiveTargetIORContactInfoList)
void	AcceptorBase.addToIORTemplate(IORTemplate iorTemplate, Policies policies, String codebase)
void	TransportManagerImpl.addToIORTemplate(IORTemplate iorTemplate, Policies policies, String codebase, String objectAdapterManagerId, ObjectAdapterId objectAdapterId)
protected void	ConnectionImpl.blockingRead()
protected void	ConnectionCacheBase.cacheStatisticsInfo()
TemporarySelectorState	TemporarySelectorStateOpen.cancelKeyAndFlushSelector(Selector theSelector, SelectionKey theSelectionKey)
void	AcceptorImpl.close()
void	ConnectionImpl.close()	Note:it is possible for this to be called more than once
void	ListenerThreadImpl.close()
void	ReaderThreadImpl.close()
void	SelectorImpl.close()
TemporarySelectorState	TemporarySelectorStateClosed.close(Selector theSelector)
TemporarySelectorState	TemporarySelectorStateOpen.close(Selector theSelector)
void	TransportManagerImpl.close()
void	ConnectionImpl.closeConnectionResources()
protected void	ConnectionImpl.closeSocketAndTemporarySelectors()
protected void	ConnectionImpl.closeTemporarySelectors()
private void	ContactInfoListImpl.createContactInfoList()	/////////////////////////////////////////////////
private void	SelectorImpl.createListenerThread(EventHandler eventHandler)
MessageMediator	ContactInfoBase.createMessageMediator(ORB broker, ContactInfo contactInfo, Connection connection, String methodName, boolean isOneWay)
CDROutputObject	ContactInfoBase.createOutputObject(MessageMediator messageMediator)
private void	SelectorImpl.createReaderThread(EventHandler eventHandler)
private void	SelectorImpl.destroyListenerThread(EventHandler eventHandler)
private void	SelectorImpl.destroyReaderThread(EventHandler eventHandler)
protected void	ConnectionImpl.doOptimizedReadStrategy()
void	AcceptorImpl.doWork()
void	ConnectionImpl.doWork()
void	ListenerThreadImpl.doWork()
void	ReaderThreadImpl.doWork()
protected void	ConnectionCacheBase.dprintCreation()
private void	SelectorImpl.enableInterestOps()
Connection	OutboundConnectionCacheImpl.get(ContactInfo contactInfo)
Socket	AcceptorImpl.getAcceptedSocket()
Collection<Acceptor>	TransportManagerImpl.getAcceptors(String objectAdapterManagerId, ObjectAdapterId objectAdapterId)
protected TemporarySelector	ConnectionImpl.getTemporaryReadSelector()
private void	SelectorImpl.handleDeferredRegistrations()
void	EventHandlerBase.handleEvent()
boolean	ContactInfoListIteratorImpl.hasNext()	/////////////////////////////////////////////////
boolean	AcceptorImpl.initialize()
boolean	AcceptorLazyImpl.initialize()
protected final IIOPProfileTemplate	AcceptorBase.makeIIOPProfileTemplate(Policies policies, String codebase)
ContactInfo	ContactInfoListIteratorImpl.next()
protected int	ConnectionImpl.nonBlockingRead()
void	AcceptorBase.processSocket(Socket socket)
void	ConnectionImpl.purgeCalls(SystemException systemException, boolean die, boolean lockHeld)	Wake up the outstanding requests on the connection, and hand them COMM_FAILURE exception with a given minor code.
void	InboundConnectionCacheImpl.put(Acceptor acceptor, Connection connection)
void	OutboundConnectionCacheImpl.put(ContactInfo contactInfo, Connection connection)
boolean	ConnectionCacheBase.reclaim()	Discarding least recently used Connections that are not busy This method must be synchronized since one WorkerThread could be reclaming connections inside the synchronized backingStore block and a second WorkerThread (or a SelectorThread) could have already executed the if (numberOfConnections <= ....
void	TransportManagerImpl.registerAcceptor(Acceptor acceptor)
SelectionKey	TemporarySelectorStateOpen.registerChannel(Selector theSelector, SelectableChannel theSelectableChannel, int theOps)
void	SelectorImpl.registerForEvent(EventHandler eventHandler)
void	SelectorImpl.registerInterestOps(EventHandler eventHandler)
void	ResponseWaitingRoomImpl.registerWaiter(MessageMediator messageMediator)
void	InboundConnectionCacheImpl.remove(Connection connection)
void	OutboundConnectionCacheImpl.remove(ContactInfo contactInfo)
TemporarySelectorState	TemporarySelectorStateOpen.removeSelectedKey(Selector theSelector, SelectionKey theSelectionKey)
void	ContactInfoListIteratorImpl.reportAddrDispositionRetry(ContactInfo contactInfo, short disposition)	/////////////////////////////////////////////////
boolean	ContactInfoListIteratorImpl.reportException(ContactInfo contactInfo, RuntimeException ex)
void	ContactInfoListIteratorImpl.reportRedirect(ContactInfo contactInfo, IOR forwardedIOR)
void	ContactInfoListIteratorImpl.reportSuccess(ContactInfo contactInfo)
void	ResponseWaitingRoomImpl.responseReceived(CDRInputObject is)
private void	ConnectionImpl.resumeSelectOnMainSelector()
private List<ContactInfo>	ContactInfoListImpl.rotate(List<ContactInfo> arg)
void	SelectorImpl.run()
int	TemporarySelectorStateOpen.select(Selector theSelector, long theTimeout)
void	ContactInfoListImpl.setEffectiveTargetIOR(IOR newIOR)
void	ResponseWaitingRoomImpl.signalExceptionToAllWaiters(SystemException systemException)	///////////////////////////////////////////////
private void	SelectorImpl.startSelector()
void	TransportManagerImpl.unregisterAcceptor(Acceptor acceptor)
void	SelectorImpl.unregisterForEvent(EventHandler eventHandler)
void	ResponseWaitingRoomImpl.unregisterWaiter(MessageMediator mediator)
CDRInputObject	ResponseWaitingRoomImpl.waitForResponse(MessageMediator messageMediator)
void	ConnectionImpl.write(ByteBuffer byteBuffer)
void	ConnectionImpl.writeLock()	Sets the writeLock for this connection.
void	ConnectionImpl.writeUnlock()

Uses of Transport in com.sun.corba.ee.impl.transport.connection

Classes in com.sun.corba.ee.impl.transport.connection with annotations of type Transport

Modifier and Type	Class	Description
class	ConnectionCacheBase<C extends Connection>
final class	InboundConnectionCacheBlockingImpl<C extends Connection>	Manage connections that are initiated from another VM.
final class	InboundConnectionCacheImpl<C extends Connection>	Manage connections that are initiated from another VM.
final class	OutboundConnectionCacheBlockingImpl<C extends Connection>
class	OutboundConnectionState<C extends Connection>

Methods in com.sun.corba.ee.impl.transport.connection with annotations of type Transport

Modifier and Type	Method	Description
void	OutboundConnectionState.acquire()
void	InboundConnectionCacheBlockingImpl.close(C conn)	Close a connection, regardless of whether the connection is busy or not.
void	OutboundConnectionCacheBlockingImpl.close(C conn)	Close a connection, regardless of whether the connection is busy or not.
void	OutboundConnectionState.close()
private void	OutboundConnectionCacheBlockingImpl.decrementTotalBusy()
private void	OutboundConnectionCacheBlockingImpl.decrementTotalIdle()
C	OutboundConnectionCacheBlockingImpl.get(ContactInfo<C> cinfo, ConnectionFinder<C> finder)
private OutboundConnectionState<C>	OutboundConnectionCacheBlockingImpl.getConnectionState(ContactInfo<C> cinfo, OutboundCacheEntry<C> entry, C conn)
private OutboundCacheEntry<C>	OutboundConnectionCacheBlockingImpl.getEntry(ContactInfo<C> cinfo)
protected boolean	ConnectionCacheBase.reclaim()	Reclaim some idle cached connections.
private boolean	OutboundConnectionCacheBlockingImpl.reclaimOrClose(OutboundConnectionState<C> cs, C conn)
void	OutboundConnectionCacheBlockingImpl.release(C conn, int numResponsesExpected)
int	OutboundConnectionState.release(int numResponsesExpected)
private void	OutboundConnectionState.removeFromReclaim()
void	InboundConnectionCacheBlockingImpl.requestProcessed(C conn, int numResponsesExpected)
void	InboundConnectionCacheImpl.requestProcessed(C conn, int numResponsesExpected)
void	InboundConnectionCacheBlockingImpl.requestReceived(C conn)
void	OutboundConnectionCacheBlockingImpl.responseReceived(C conn)	Decrement the number of expected responses.
boolean	OutboundConnectionState.responseReceived()
void	InboundConnectionCacheBlockingImpl.responseSent(C conn)	Decrement the number of expected responses.
void	InboundConnectionCacheImpl.responseSent(C conn)	Decrement the number of expected responses.
private C	OutboundConnectionCacheBlockingImpl.tryNewConnection(OutboundCacheEntry<C> entry, ContactInfo<C> cinfo)

Uses of Transport in com.sun.corba.ee.spi.orb

Fields in com.sun.corba.ee.spi.orb with annotations of type Transport

Modifier and Type	Field	Description
boolean	ORB.transportDebugFlag

Uses of Transport in com.sun.corba.ee.spi.protocol

Methods in com.sun.corba.ee.spi.protocol with annotations of type Transport

Modifier and Type	Method	Description
ByteBuffer	MessageParser.getNewBufferAndCopyOld(ByteBuffer byteBuffer)