org.jacorb.orb.giop

Class GIOPConnection

public abstract class GIOPConnection extends OutputStream

GIOPConnection.java Created: Sun Aug 12 21:30:48 2002 Configuration parameters:
jacorb.debug.dump_incoming_messages=[on|off], default=off
jacorb.connection.client.connect_timeout=N, default=0
jacorb.connection.statistics_providers={classnames}, default=(empty)

Version: $Id: GIOPConnection.java,v 1.66 2007/02/06 19:27:28 andre.spiegel Exp $

Author: Nicolas Noffke

Field Summary
protected ConnectionListener	connection_listener
protected Object	connect_sync
protected boolean	discard_messages
protected boolean	do_close
protected Logger	logger
protected Object	pendingUndecidedSync
protected Profile	profile Profile describing the remote endpoint of this connection.
protected StatisticsProvider	statistics_provider
protected StatisticsProviderAdapter	statistics_provider_adapter
protected Connection	transport

Constructor Summary
	GIOPConnection(Profile profile, Connection transport, RequestListener request_listener, ReplyListener reply_listener, StatisticsProvider statistics_provider)

Method Summary
static int	allocate_cubby_id()
void	close()
void	configure(Configuration configuration)
void	decPendingMessages()
void	flush()
protected RequestListener	getRequestListener() Get the value of request_listener.
StatisticsProvider	getStatisticsProvider() Get the statistics provider for transport usage statistics that can be used in conjunction with the SelectionStrategy.
StatisticsProvider	getStatisticsProvider(int no) Return the StatissticsProvider, given the cardinality number
protected StatisticsProviderAdapter	getStatisticsProviderAdapter() Get an instance of StatisticsProvider derivative, for updating the transport usage statistics.
int	getTCS()
int	getTCSW()
Connection	getTransport()
protected void	getWriteLock()
Object	get_cubby(int id)
boolean	hasPendingMessages()
void	incPendingMessages()
boolean	isSSL()
boolean	isTCSNegotiated()
void	markTCSNegotiated()
protected abstract void	readTimedOut() Called by this.getMessage() to signal that the attempt to read a message resulted in a timeout.
void	receiveMessages()
protected void	releaseWriteLock()
void	sendReply(MessageOutputStream out)
void	sendRequest(MessageOutputStream out, boolean expect_reply)
void	setCodeSets(int TCS, int TCSW)
void	setConnectionListener(ConnectionListener connection_listener)
void	setReplyListener(ReplyListener listener) Set the value of reply_listener.
void	setRequestListener(RequestListener listener) Set the value of request_listener.
void	set_cubby(int id, Object obj)
protected abstract void	streamClosed() Called by this.getMessage() to signal that the underlying transport was closed while attempting to read a message.
void	write(byte[] fragment, int start, int size) write (a fragment of) the message (passes it on to the wire)
void	write(int value)
void	write(byte[] value)

Field Detail

connection_listener

protected ConnectionListener connection_listener

connect_sync

protected Object connect_sync

discard_messages

protected boolean discard_messages

do_close

protected boolean do_close

logger

protected Logger logger

pendingUndecidedSync

protected Object pendingUndecidedSync

profile

protected final Profile profile

Profile describing the remote endpoint of this connection.

statistics_provider

protected StatisticsProvider statistics_provider

statistics_provider_adapter

protected StatisticsProviderAdapter statistics_provider_adapter

transport

protected Connection transport

Constructor Detail

GIOPConnection

public GIOPConnection(Profile profile, Connection transport, RequestListener request_listener, ReplyListener reply_listener, StatisticsProvider statistics_provider)

Method Detail

allocate_cubby_id

public static int allocate_cubby_id()

close

public void close()

configure

public void configure(Configuration configuration)

decPendingMessages

public final void decPendingMessages()

flush

public final void flush()

getRequestListener

protected final RequestListener getRequestListener()

Get the value of request_listener.

Returns: value of request_listener.

getStatisticsProvider

public final StatisticsProvider getStatisticsProvider()

Get the statistics provider for transport usage statistics that can be used in conjunction with the SelectionStrategy. This is a special-case provider, usually supplied by, and known to, the concrete SelectionStrategy. To actually update the usage stats use getStatisticsProviderAdapter()

getStatisticsProvider

public StatisticsProvider getStatisticsProvider(int no)

Return the StatissticsProvider, given the cardinality number

Parameters: no

Returns:

Parameters: listener Value to assign to reply_listener.

setRequestListener

public final void setRequestListener(RequestListener listener)

Set the value of request_listener.

Parameters: listener Value to assign to request_listener.