Uses of Annotation Type
com.sun.corba.ee.spi.trace.Transport
Packages that use Transport
Package
Description
-
Uses of Transport in com.sun.corba.ee.impl.encoding
Classes in com.sun.corba.ee.impl.encoding with annotations of type TransportMethods in com.sun.corba.ee.impl.encoding with annotations of type TransportModifier and TypeMethodDescriptionvoid
BufferManagerReadStream.close
(ByteBuffer byteBuffer) void
BufferManagerReadStream.processFragment
(ByteBuffer byteBuffer, FragmentMessage msg) 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 TransportModifier and TypeClassDescriptionclass
class
Methods in com.sun.corba.ee.impl.legacy.connection with annotations of type TransportModifier and TypeMethodDescriptionprivate 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 TransportModifier and TypeClassDescriptionclass
Install this in an ORB using the property ORBConstants.USER_CONFIGURATOR_PREFIX + "corba.lb.NoConnectionCacheImpl" = "dummy"private static class
private static class
private static class
Methods in com.sun.corba.ee.impl.plugin.hwlb with annotations of type TransportModifier and TypeMethodDescriptionvoid
NoConnectionCacheImpl.NCCConnectionImpl.close()
private void
NoConnectionCacheImpl.NCCConnectionImpl.constructedNCCConnectionImpl
(String str) 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 TransportModifier and TypeClassDescriptionclass
class
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 TransportModifier and TypeMethodDescriptionprivate void
MessageMediatorImpl.addMessageMediatorToWorkQueue
(MessageMediator messageMediator) boolean
MessageMediatorImpl.dispatch()
NOTE: This call is the transition from the transport block to the protocol block.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) 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 TransportModifier and TypeClassDescriptionfinal class
This implements the GIOP 1.2 Reply header.final class
This implements the GIOP 1.2 Request header.Methods in com.sun.corba.ee.impl.protocol.giopmsgheaders with annotations of type TransportModifier and TypeMethodDescriptionvoid
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 TransportModifier and TypeClassDescriptionclass
class
class
A version of an Acceptor that does not own the ServerSocket.class
class
class
class
class
class
class
class
class
class
class
class
class
An class which models a temporary Selector in a closed state.class
A class which models temporary Selector in an open state.class
Methods in com.sun.corba.ee.impl.transport with annotations of type TransportModifier and TypeMethodDescriptionprivate 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()
TemporarySelectorStateOpen.cancelKeyAndFlushSelector
(Selector theSelector, 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()
void
TransportManagerImpl.close()
void
ConnectionImpl.closeConnectionResources()
protected void
ConnectionImpl.closeSocketAndTemporarySelectors()
protected void
ConnectionImpl.closeTemporarySelectors()
private void
ContactInfoListImpl.createContactInfoList()
private void
SelectorImpl.createListenerThread
(EventHandler eventHandler) ContactInfoBase.createMessageMediator
(ORB broker, ContactInfo contactInfo, Connection connection, String methodName, boolean isOneWay) 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()
OutboundConnectionCacheImpl.get
(ContactInfo contactInfo) AcceptorImpl.getAcceptedSocket()
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) 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) 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) 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
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) 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 TransportModifier and TypeClassDescriptionclass
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 TransportModifier and TypeMethodDescriptionvoid
OutboundConnectionState.acquire()
void
Close a connection, regardless of whether the connection is busy or not.void
Close a connection, regardless of whether the connection is busy or not.void
OutboundConnectionState.close()
private void
OutboundConnectionCacheBlockingImpl.decrementTotalBusy()
private void
OutboundConnectionCacheBlockingImpl.decrementTotalIdle()
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
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 -
Uses of Transport in com.sun.corba.ee.spi.protocol
Methods in com.sun.corba.ee.spi.protocol with annotations of type Transport