com.sun.corba.se.spi.transport

Interface CorbaConnection

All Superinterfaces:

Connection

public interface CorbaConnection
extends Connection, Connection

Field Summary

Fields

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

Method Summary

Methods

Modifier and Type	Method and Description
MessageMediator	clientReply_1_1_Get()
void	clientReply_1_1_Put(MessageMediator x)
void	clientReply_1_1_Remove()
MessageMediator	clientRequestMapGet(int requestId)
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(ByteBuffer byteBuffer, int offset, int length, long max_wait_time)
ByteBuffer	read(int size, 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 Detail

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 Detail

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()