org.jacorb.orb.giop
public abstract class GIOPConnection extends OutputStream
Version: $Id: GIOPConnection.java,v 1.66 2007/02/06 19:27:28 andre.spiegel Exp $
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) |
Returns: value of request_listener.
Parameters: no
Returns:
Parameters: listener Value to assign to reply_listener.
Parameters: listener Value to assign to request_listener.