|
|||||||||||
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 java.lang.Object |
pendingUndecidedSync
|
protected Profile |
profile
|
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 |
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()
|
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()
|
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 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 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 |