Package com.sun.corba.se.spi.transport

Interface CorbaConnection

All Superinterfaces:

Connection, Connection

All Known Implementing Classes:

SocketFactoryConnectionImpl, SocketOrChannelConnectionImpl

public interface CorbaConnection
extends Connection, Connection

Author:

Harold Carr

Field Summary

Fields

Modifier and Type	Field	Description
static final int	ABORT
static final int	CLOSE_RECVD
static final int	CLOSE_SENT
static final int	ESTABLISHED
static final int	OPENING

Method Summary

Modifier and Type	Method	Description
MessageMediator	clientReply_1_1_Get()
void	clientReply_1_1_Put(MessageMediator x)
void	clientReply_1_1_Remove()
MessageMediator	clientRequestMapGet(int requestId)
void	closeConnectionResources()	Clean up all connection resources.
void	dprint(String msg)
ORB	getBroker()
CodeBase	getCodeBase()
IOR	getCodeBaseIOR()
CodeSetComponentInfo.CodeSetContext	getCodeSetContext()
int	getNextRequestId()
ResponseWaitingRoom	getResponseWaitingRoom()
SocketChannel	getSocketChannel()
boolean	isPostInitialContexts()
void	purgeCalls(SystemException systemException, boolean die, boolean lockHeld)
ByteBuffer	read(int size, int offset, int length, long max_wait_time)
ByteBuffer	read(ByteBuffer byteBuffer, int offset, int length, long max_wait_time)
void	sendCancelRequest(GIOPVersion giopVersion, int requestId)
void	sendCancelRequestWithLock(GIOPVersion giopVersion, int requestId)
void	sendCloseConnection(GIOPVersion giopVersion)
void	sendMessageError(GIOPVersion giopVersion)
MessageMediator	serverRequest_1_1_Get()
void	serverRequest_1_1_Put(MessageMediator x)
void	serverRequest_1_1_Remove()
CorbaMessageMediator	serverRequestMapGet(int requestId)
void	serverRequestMapPut(int requestId, CorbaMessageMediator messageMediator)
void	serverRequestMapRemove(int requestId)
void	serverRequestProcessingBegins()
void	serverRequestProcessingEnds()
void	setCodeBaseIOR(IOR ior)
void	setCodeSetContext(CodeSetComponentInfo.CodeSetContext csc)
void	setPostInitialContexts()
boolean	shouldReadGiopHeaderOnly()
boolean	shouldUseDirectByteBuffers()
void	write(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, writeUnlock

Methods inherited from interface com.sun.corba.se.spi.legacy.connection.Connection

getSocket

Field Details

OPENING

static final int OPENING

See Also:

• Constant Field Values

ESTABLISHED

static final int ESTABLISHED

See Also:

• Constant Field Values

CLOSE_SENT

static final int CLOSE_SENT

See Also:

• Constant Field Values

CLOSE_RECVD

static final int CLOSE_RECVD

See Also:

• Constant Field Values

ABORT

static final int ABORT

See Also:

• Constant Field Values

Method Details

shouldUseDirectByteBuffers

boolean shouldUseDirectByteBuffers()

shouldReadGiopHeaderOnly

boolean shouldReadGiopHeaderOnly()

read

ByteBuffer read(int size,
 int offset,
 int length,
 long max_wait_time)
         throws IOException

Throws:

IOException

read

ByteBuffer read(ByteBuffer byteBuffer,
 int offset,
 int length,
 long max_wait_time)
         throws IOException

Throws:

IOException

write

void write(ByteBuffer byteBuffer)
    throws IOException

Throws:

IOException

dprint

void dprint(String msg)

getNextRequestId

int getNextRequestId()

getBroker

ORB getBroker()

getCodeSetContext

CodeSetComponentInfo.CodeSetContext getCodeSetContext()

setCodeSetContext

void setCodeSetContext(CodeSetComponentInfo.CodeSetContext csc)

clientRequestMapGet

MessageMediator clientRequestMapGet(int requestId)

clientReply_1_1_Put

void clientReply_1_1_Put(MessageMediator x)

clientReply_1_1_Get

MessageMediator clientReply_1_1_Get()

clientReply_1_1_Remove

void clientReply_1_1_Remove()

serverRequest_1_1_Put

void serverRequest_1_1_Put(MessageMediator x)

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

void purgeCalls(SystemException systemException,
 boolean die,
 boolean lockHeld)

setCodeBaseIOR

void setCodeBaseIOR(IOR ior)

getCodeBaseIOR

IOR getCodeBaseIOR()

getCodeBase

CodeBase getCodeBase()

sendCloseConnection

void sendCloseConnection(GIOPVersion giopVersion)
                  throws IOException

Throws:

IOException

sendMessageError

void sendMessageError(GIOPVersion giopVersion)
               throws IOException

Throws:

IOException

sendCancelRequest

void sendCancelRequest(GIOPVersion giopVersion,
 int requestId)
                throws IOException

Throws:

IOException

sendCancelRequestWithLock

void sendCancelRequestWithLock(GIOPVersion giopVersion,
 int requestId)
                        throws IOException

Throws:

IOException

getResponseWaitingRoom

ResponseWaitingRoom getResponseWaitingRoom()

serverRequestMapPut

void serverRequestMapPut(int requestId,
 CorbaMessageMediator messageMediator)

serverRequestMapGet

CorbaMessageMediator serverRequestMapGet(int requestId)

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.