|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.io.OutputStream
org.jacorb.orb.giop.GIOPConnection
public abstract class GIOPConnection
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)
Field Summary | |
---|---|
protected java.lang.Object |
connect_sync
|
protected ConnectionListener |
connection_listener
|
protected boolean |
discard_messages
|
protected boolean |
do_close
|
protected org.apache.avalon.framework.logger.Logger |
logger
|
protected java.lang.Object |
pendingUndecidedSync
|
protected Profile |
profile
Profile describing the remote endpoint of this connection. |
protected StatisticsProvider |
statistics_provider
|
protected org.jacorb.orb.giop.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(org.apache.avalon.framework.configuration.Configuration configuration)
|
void |
decPendingMessages()
|
void |
flush()
|
java.lang.Object |
get_cubby(int id)
|
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 org.jacorb.orb.giop.StatisticsProviderAdapter |
getStatisticsProviderAdapter()
Get an instance of StatisticsProvider derivative, for updating the transport usage statistics. |
int |
getTCS()
|
int |
getTCSW()
|
Connection |
getTransport()
|
protected void |
getWriteLock()
|
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 |
set_cubby(int id,
java.lang.Object obj)
|
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. |
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[] value)
|
void |
write(byte[] fragment,
int start,
int size)
write (a fragment of) the message (passes it on to the wire) |
void |
write(int value)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final Profile profile
protected Connection transport
protected ConnectionListener connection_listener
protected java.lang.Object connect_sync
protected org.apache.avalon.framework.logger.Logger logger
protected boolean discard_messages
protected java.lang.Object pendingUndecidedSync
protected boolean do_close
protected StatisticsProvider statistics_provider
protected org.jacorb.orb.giop.StatisticsProviderAdapter statistics_provider_adapter
Constructor Detail |
---|
public GIOPConnection(Profile profile, Connection transport, RequestListener request_listener, ReplyListener reply_listener, StatisticsProvider statistics_provider)
Method Detail |
---|
public void configure(org.apache.avalon.framework.configuration.Configuration configuration) throws org.apache.avalon.framework.configuration.ConfigurationException
org.apache.avalon.framework.configuration.ConfigurationException
public final void setCodeSets(int TCS, int TCSW)
public final int getTCS()
public final int getTCSW()
public final void markTCSNegotiated()
public final boolean isTCSNegotiated()
protected final RequestListener getRequestListener()
public final void setRequestListener(RequestListener listener)
listener
- Value to assign to request_listener.public final void setReplyListener(ReplyListener listener)
listener
- Value to assign to reply_listener.public final void setConnectionListener(ConnectionListener connection_listener)
public final Connection getTransport()
protected abstract void readTimedOut()
protected abstract void streamClosed()
public final void receiveMessages() throws java.io.IOException
java.io.IOException
protected final void getWriteLock()
protected final void releaseWriteLock()
public final void incPendingMessages()
public final void decPendingMessages()
public final boolean hasPendingMessages()
public final void write(byte[] fragment, int start, int size)
write
in class java.io.OutputStream
public final void write(int value) throws java.io.IOException
write
in class java.io.OutputStream
java.io.IOException
public final void write(byte[] value) throws java.io.IOException
write
in class java.io.OutputStream
java.io.IOException
public final void flush() throws java.io.IOException
flush
in interface java.io.Flushable
flush
in class java.io.OutputStream
java.io.IOException
public final void sendRequest(MessageOutputStream out, boolean expect_reply) throws java.io.IOException
java.io.IOException
public final void sendReply(MessageOutputStream out) throws java.io.IOException
java.io.IOException
public final boolean isSSL()
public void close()
close
in interface java.io.Closeable
close
in class java.io.OutputStream
protected final org.jacorb.orb.giop.StatisticsProviderAdapter getStatisticsProviderAdapter()
public final StatisticsProvider getStatisticsProvider()
public StatisticsProvider getStatisticsProvider(int no)
no
-
public static int allocate_cubby_id()
public java.lang.Object get_cubby(int id)
public void set_cubby(int id, java.lang.Object obj)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |