public abstract class GIOPConnection extends OutputStream
Modifier and Type | Class and Description |
---|---|
class |
GIOPConnection.ConnectionReset |
Modifier and Type | Field and Description |
---|---|
protected Object |
connect_sync |
protected ConnectionListener |
connection_listener |
protected boolean |
discard_messages |
protected boolean |
do_close |
protected Throwable |
exceptionCache |
protected Map<Integer,ByteArrayOutputStream> |
fragments
Fragmented message support.
|
protected Map<Integer,Integer> |
fragmentsSize |
protected org.slf4j.Logger |
logger |
protected ORB |
orb |
protected Object |
pendingUndecidedSync |
protected org.omg.ETF.Profile |
profile
Profile describing the remote endpoint of this connection.
|
protected StatisticsProvider |
statistics_provider |
protected org.jacorb.orb.giop.StatisticsProviderAdapter |
statistics_provider_adapter |
protected org.omg.ETF.Connection |
transport |
Constructor and Description |
---|
GIOPConnection(org.omg.ETF.Profile profile,
org.omg.ETF.Connection transport,
RequestListener request_listener,
ReplyListener reply_listener,
StatisticsProvider statistics_provider) |
Modifier and Type | Method and Description |
---|---|
static int |
allocate_cubby_id() |
void |
close() |
void |
configure(Configuration configuration) |
void |
decPendingMessages() |
void |
flush() |
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.
|
CodeSet |
getTCS() |
CodeSet |
getTCSW() |
org.omg.ETF.Connection |
getTransport() |
protected boolean |
getWriteLock(long timeout) |
boolean |
hasPendingMessages() |
void |
incPendingMessages() |
protected void |
init_write_monitor(int timeout) |
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,
Object obj) |
void |
setCodeSets(CodeSet TCS,
CodeSet TCSW) |
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) |
protected final org.omg.ETF.Profile profile
protected org.omg.ETF.Connection transport
protected ConnectionListener connection_listener
protected Object connect_sync
protected org.slf4j.Logger logger
protected final Map<Integer,ByteArrayOutputStream> fragments
protected boolean discard_messages
protected Object pendingUndecidedSync
protected boolean do_close
protected StatisticsProvider statistics_provider
protected org.jacorb.orb.giop.StatisticsProviderAdapter statistics_provider_adapter
protected ORB orb
protected Throwable exceptionCache
public GIOPConnection(org.omg.ETF.Profile profile, org.omg.ETF.Connection transport, RequestListener request_listener, ReplyListener reply_listener, StatisticsProvider statistics_provider)
public void configure(Configuration configuration) throws ConfigurationException
ConfigurationException
protected void init_write_monitor(int timeout)
public final void setCodeSets(int TCS, int TCSW)
public final CodeSet getTCS()
public final CodeSet 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 org.omg.ETF.Connection getTransport()
protected abstract void readTimedOut()
protected abstract void streamClosed()
public final void receiveMessages()
protected final boolean getWriteLock(long timeout)
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 OutputStream
public final void write(int value) throws IOException
write
in class OutputStream
IOException
public final void write(byte[] value) throws IOException
write
in class OutputStream
IOException
public final void flush() throws IOException
flush
in interface Flushable
flush
in class OutputStream
IOException
public final void sendRequest(MessageOutputStream out, boolean expect_reply) throws IOException
IOException
public final void sendReply(MessageOutputStream out) throws IOException
IOException
public final boolean isSSL()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in class 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 Object get_cubby(int id)
public void set_cubby(int id, Object obj)
Copyright © 2017 JacORB. All rights reserved.