org.jacorb.orb.giop

Class ClientConnection

java.lang.Object

org.jacorb.orb.giop.ClientConnection

All Implemented Interfaces:

ConnectionListener, ReplyListener

public class ClientConnection
extends Object
implements ReplyListener, ConnectionListener

Author:

Nicolas Noffke

Constructor Summary

Constructors

Constructor and Description
ClientConnection(GIOPConnection connection, ORB orb, ClientConnectionManager conn_mg, org.omg.ETF.Profile registeredProfile, boolean client_initiated)

Method Summary

Methods

Modifier and Type	Method and Description
long	cacheSASContext(byte[] client_authentication_token)
void	close() called from Delegate/ConnectionManagement etc.
void	closeConnectionReceived(byte[] close_conn, GIOPConnection connection) Received a CloseConnection message.
void	connectionClosed(Throwable exceptionCause) Operations from ConnectionListener used for upcalls from GIOPConnection
boolean	decClients() This method decrements the number of clients.
org.omg.ETF.Profile	get_server_profile()
GIOPConnection	getGIOPConnection()
int	getId()
org.omg.ETF.Profile	getRegisteredProfile() Get the profile that was used for registering with the ClientConnectionManager.
CodeSet	getTCS()
CodeSet	getTCSW()
void	incClients() Increments the number of clients.
boolean	isClientInitiated()
boolean	isClosed() Return the state of the underlying GIOP connection.
boolean	isListenPointListSent() Used as part of the configuration of a bidirectional connection Not only returns the value of the listen point list sent flag, it also sets the value.
boolean	isTCSNegotiated()
void	locateReplyReceived(byte[] reply, GIOPConnection connection)
int	numClients() Returns the number of clients currently using this connection.
long	purgeSASContext(long client_context_id)
void	replyReceived(byte[] reply, GIOPConnection connection) Operations from ReplyListener
void	sendRequest(MessageOutputStream outputStream, boolean response_expected)
void	sendRequest(MessageOutputStream outputStream, ReplyPlaceholder placeholder, int request_id, boolean response_expected) The request_id parameter is only used, if response_expected.
void	setCodeSet(ParsedIOR pior)
void	streamClosed(Throwable exceptionCause) the transport has been removed underneath the GIOP layer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClientConnection

public ClientConnection(GIOPConnection connection,
                ORB orb,
                ClientConnectionManager conn_mg,
                org.omg.ETF.Profile registeredProfile,
                boolean client_initiated)

Method Detail

getGIOPConnection

public final GIOPConnection getGIOPConnection()

getRegisteredProfile

public org.omg.ETF.Profile getRegisteredProfile()

Get the profile that was used for registering with the ClientConnectionManager. In case of BiDirIIOP it is NOT equal to the transports profile.

setCodeSet

public void setCodeSet(ParsedIOR pior)

isTCSNegotiated

public boolean isTCSNegotiated()

getTCS

public CodeSet getTCS()

getTCSW

public CodeSet getTCSW()

getId

public int getId()

incClients

public void incClients()

Increments the number of clients.

decClients

public boolean decClients()

This method decrements the number of clients.

Returns:

a boolean value, true if client_count is zero.

numClients

public int numClients()

Returns the number of clients currently using this connection.

isClientInitiated

public boolean isClientInitiated()

isListenPointListSent

public boolean isListenPointListSent()

Used as part of the configuration of a bidirectional connection Not only returns the value of the listen point list sent flag, it also sets the value. This is effectively a one-shot method that ensures only the first caller gets the opportunity to send a listen point list as part of a BiDirIIOP context.

sendRequest

public void sendRequest(MessageOutputStream outputStream,
               ReplyPlaceholder placeholder,
               int request_id,
               boolean response_expected)

The request_id parameter is only used, if response_expected.

sendRequest

public void sendRequest(MessageOutputStream outputStream,
               boolean response_expected)

close

public void close()

called from Delegate/ConnectionManagement etc.

isClosed

public boolean isClosed()

Return the state of the underlying GIOP connection.

replyReceived

public void replyReceived(byte[] reply,
                 GIOPConnection connection)

Operations from ReplyListener

Specified by:

replyReceived in interface ReplyListener

locateReplyReceived

public void locateReplyReceived(byte[] reply,
                       GIOPConnection connection)

Specified by:

locateReplyReceived in interface ReplyListener

closeConnectionReceived

public void closeConnectionReceived(byte[] close_conn,
                           GIOPConnection connection)

Received a CloseConnection message. Remarshal all pending messages. The close mechanism will be invoked separately by the actual closing of the Transport and will trigger the remarshaling.

Specified by:

closeConnectionReceived in interface ReplyListener

connectionClosed

public void connectionClosed(Throwable exceptionCause)

Operations from ConnectionListener used for upcalls from GIOPConnection

Specified by:

connectionClosed in interface ConnectionListener

streamClosed

public void streamClosed(Throwable exceptionCause)

the transport has been removed underneath the GIOP layer

Specified by:

streamClosed in interface ConnectionListener

get_server_profile

public org.omg.ETF.Profile get_server_profile()

cacheSASContext

public long cacheSASContext(byte[] client_authentication_token)

purgeSASContext

public long purgeSASContext(long client_context_id)