|
||||||||||||
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
GIOPConnection.java Created: Sun Aug 12 21:30:48 2002
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 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. |
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 v)
Set the value of reply_listener. |
void |
setRequestListener(RequestListener v)
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[] b)
|
void |
write(byte[] fragment,
int start,
int size)
write (a fragment of) the message (passes it on to the wire) |
void |
write(int i)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected 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
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 v)
v
- Value to assign to request_listener.public final void setReplyListener(ReplyListener v)
v
- 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)
public final void write(int i) throws java.io.IOException
java.io.IOException
public final void write(byte[] b) throws java.io.IOException
java.io.IOException
public final void flush() throws java.io.IOException
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()
public final StatisticsProvider getStatisticsProvider()
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 |