Package com.sun.corba.se.spi.transport
Interface CorbaConnection
- All Superinterfaces:
Connection,Connection
- All Known Implementing Classes:
SocketFactoryConnectionImpl,SocketOrChannelConnectionImpl
- Author:
- Harold Carr
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final intstatic final intstatic final int -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidclientRequestMapGet(int requestId) voidClean up all connection resources.voidintbooleanvoidpurgeCalls(SystemException systemException, boolean die, boolean lockHeld) read(int size, int offset, int length, long max_wait_time) read(ByteBuffer byteBuffer, int offset, int length, long max_wait_time) voidsendCancelRequest(GIOPVersion giopVersion, int requestId) voidsendCancelRequestWithLock(GIOPVersion giopVersion, int requestId) voidsendCloseConnection(GIOPVersion giopVersion) voidsendMessageError(GIOPVersion giopVersion) voidvoidserverRequestMapGet(int requestId) voidserverRequestMapPut(int requestId, CorbaMessageMediator messageMediator) voidserverRequestMapRemove(int requestId) voidvoidvoidsetCodeBaseIOR(IOR ior) voidvoidbooleanbooleanvoidwrite(ByteBuffer byteBuffer) Methods inherited from interface com.sun.corba.se.pept.transport.Connection
close, getAcceptor, getConnectionCache, getContactInfo, getEventHandler, getTimeStamp, isBusy, isServer, read, registerWaiter, sendWithoutLock, setConnectionCache, setState, setTimeStamp, shouldRegisterReadEvent, shouldRegisterServerReadEvent, unregisterWaiter, waitForResponse, writeLock, writeUnlockMethods inherited from interface com.sun.corba.se.spi.legacy.connection.Connection
getSocket
-
Field Details
-
OPENING
static final int OPENING- See Also:
-
ESTABLISHED
static final int ESTABLISHED- See Also:
-
CLOSE_SENT
static final int CLOSE_SENT- See Also:
-
CLOSE_RECVD
static final int CLOSE_RECVD- See Also:
-
ABORT
static final int ABORT- See Also:
-
-
Method Details
-
shouldUseDirectByteBuffers
boolean shouldUseDirectByteBuffers() -
shouldReadGiopHeaderOnly
boolean shouldReadGiopHeaderOnly() -
read
- Throws:
IOException
-
read
ByteBuffer read(ByteBuffer byteBuffer, int offset, int length, long max_wait_time) throws IOException - Throws:
IOException
-
write
- Throws:
IOException
-
dprint
-
getNextRequestId
int getNextRequestId() -
getBroker
ORB getBroker() -
getCodeSetContext
CodeSetComponentInfo.CodeSetContext getCodeSetContext() -
setCodeSetContext
-
clientRequestMapGet
-
clientReply_1_1_Put
-
clientReply_1_1_Get
MessageMediator clientReply_1_1_Get() -
clientReply_1_1_Remove
void clientReply_1_1_Remove() -
serverRequest_1_1_Put
-
serverRequest_1_1_Get
MessageMediator serverRequest_1_1_Get() -
serverRequest_1_1_Remove
void serverRequest_1_1_Remove() -
isPostInitialContexts
boolean isPostInitialContexts() -
setPostInitialContexts
void setPostInitialContexts() -
purgeCalls
-
setCodeBaseIOR
-
getCodeBaseIOR
IOR getCodeBaseIOR() -
getCodeBase
CodeBase getCodeBase() -
sendCloseConnection
- Throws:
IOException
-
sendMessageError
- Throws:
IOException
-
sendCancelRequest
- Throws:
IOException
-
sendCancelRequestWithLock
- Throws:
IOException
-
getResponseWaitingRoom
ResponseWaitingRoom getResponseWaitingRoom() -
serverRequestMapPut
-
serverRequestMapGet
-
serverRequestMapRemove
void serverRequestMapRemove(int requestId) -
getSocketChannel
SocketChannel getSocketChannel() -
serverRequestProcessingBegins
void serverRequestProcessingBegins() -
serverRequestProcessingEnds
void serverRequestProcessingEnds() -
closeConnectionResources
void closeConnectionResources()Clean up all connection resources. Used when shutting down an ORB.
-