Uses of Class
com.sun.corba.ee.spi.trace.Transport
-
-
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(java.nio.ByteBuffer byteBuffer)
void
BufferManagerReadStream. processFragment(java.nio.ByteBuffer byteBuffer, FragmentMessage msg)
java.nio.ByteBuffer
BufferManagerReadStream. underflow(java.nio.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(java.net.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(java.lang.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 aMessageParser
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.java.nio.ByteBuffer
MessageParserImpl. getNewBufferAndCopyOld(java.nio.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(java.nio.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 class
ReplyMessage_1_2
This implements the GIOP 1.2 Reply header.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, java.util.List<ContactInfo> effectiveTargetIORContactInfoList)
void
AcceptorBase. addToIORTemplate(IORTemplate iorTemplate, Policies policies, java.lang.String codebase)
void
TransportManagerImpl. addToIORTemplate(IORTemplate iorTemplate, Policies policies, java.lang.String codebase, java.lang.String objectAdapterManagerId, ObjectAdapterId objectAdapterId)
protected void
ConnectionImpl. blockingRead()
protected void
ConnectionCacheBase. cacheStatisticsInfo()
TemporarySelectorState
TemporarySelectorStateOpen. cancelKeyAndFlushSelector(java.nio.channels.Selector theSelector, java.nio.channels.SelectionKey theSelectionKey)
void
AcceptorImpl. close()
void
ConnectionImpl. close()
Note:it is possible for this to be called more than oncevoid
ListenerThreadImpl. close()
void
ReaderThreadImpl. close()
void
SelectorImpl. close()
TemporarySelectorState
TemporarySelectorStateClosed. close(java.nio.channels.Selector theSelector)
TemporarySelectorState
TemporarySelectorStateOpen. close(java.nio.channels.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, java.lang.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)
java.net.Socket
AcceptorImpl. getAcceptedSocket()
java.util.Collection<Acceptor>
TransportManagerImpl. getAcceptors(java.lang.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 IIOPProfileTemplate
AcceptorBase. makeIIOPProfileTemplate(Policies policies, java.lang.String codebase)
ContactInfo
ContactInfoListIteratorImpl. next()
protected int
ConnectionImpl. nonBlockingRead()
void
AcceptorBase. processSocket(java.net.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)
java.nio.channels.SelectionKey
TemporarySelectorStateOpen. registerChannel(java.nio.channels.Selector theSelector, java.nio.channels.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(java.nio.channels.Selector theSelector, java.nio.channels.SelectionKey theSelectionKey)
void
ContactInfoListIteratorImpl. reportAddrDispositionRetry(ContactInfo contactInfo, short disposition)
boolean
ContactInfoListIteratorImpl. reportException(ContactInfo contactInfo, java.lang.RuntimeException ex)
void
ContactInfoListIteratorImpl. reportRedirect(ContactInfo contactInfo, IOR forwardedIOR)
void
ContactInfoListIteratorImpl. reportSuccess(ContactInfo contactInfo)
void
ResponseWaitingRoomImpl. responseReceived(CDRInputObject is)
private void
ConnectionImpl. resumeSelectOnMainSelector()
private java.util.List<ContactInfo>
ContactInfoListImpl. rotate(java.util.List<ContactInfo> arg)
void
SelectorImpl. run()
int
TemporarySelectorStateOpen. select(java.nio.channels.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(java.nio.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>
class
InboundConnectionCacheBlockingImpl<C extends Connection>
Manage connections that are initiated from another VM.class
InboundConnectionCacheImpl<C extends Connection>
Manage connections that are initiated from another VM.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 java.nio.ByteBuffer
MessageParser. getNewBufferAndCopyOld(java.nio.ByteBuffer byteBuffer)
-