Methods Summary |
---|
public void | close()Close the Connection .
|
public Acceptor | getAcceptor()Get the
{@link com.sun.corba.se.pept.transport.Acceptor Acceptor}
that created this Connection .
|
public ConnectionCache | getConnectionCache()
|
public ContactInfo | getContactInfo()Get the
{@link com.sun.corba.se.pept.transport.ContactInfo ContactInfo}
that created this Connection .
|
public com.sun.corba.se.pept.transport.EventHandler | getEventHandler()Get the
{@link com.sun.corba.se.pept.transport.EventHandler EventHandler}
associated with this Acceptor .
|
public long | getTimeStamp()Timestamps are used for connection management, in particular, for
reclaiming idle Connection s.
|
public boolean | isBusy()Indicates if the Connection is in the process of
sending or receiving a message.
|
public boolean | isServer()Indicates whether a
{@link com.sun.corba.se.pept.transport.ContactInfo ContactInfo}
or a
{@link com.sun.corba.se.pept.transport.Acceptor Acceptor}
created the
Connection .
|
public boolean | read()Called to read incoming messages.
|
public void | registerWaiter(com.sun.corba.se.pept.protocol.MessageMediator messageMediator)Register an invocation's
{@link com.sun.corba.se.pept.protocol.MessageMediator MessageMediator}
with the Connection .
This is useful in protocols which support fragmentation.
|
public void | sendWithoutLock(com.sun.corba.se.pept.encoding.OutputObject outputObject)
|
public void | setConnectionCache(ConnectionCache connectionCache)
|
public void | setState(java.lang.String state)The "state" of the Connection .
param state
|
public void | setTimeStamp(long time)Timestamps are used for connection management, in particular, for
reclaiming idle Connection s.
|
public boolean | shouldRegisterReadEvent()Used to determine if the Connection should register
with the
{@link com.sun.corba.se.pept.transport.TransportManager
TransportManager}
{@link com.sun.corba.se.pept.transport.Selector Selector}
to handle read events.
For example, an HTTP transport would not register since the requesting
thread would just block on read when waiting for the reply.
|
public boolean | shouldRegisterServerReadEvent()Used to determine if the Connection should register
with the
{@link com.sun.corba.se.pept.transport.TransportManager
TransportManager}
{@link com.sun.corba.se.pept.transport.Selector Selector}
to handle read events.
For example, an HTTP transport would not register since the requesting
thread would just block on read when waiting for the reply.
|
public void | unregisterWaiter(com.sun.corba.se.pept.protocol.MessageMediator messageMediator)Unregister an invocation's
{@link com.sun.corba.se.pept.protocol.MessageMediator MessageMediator}
with the Connection .
|
public com.sun.corba.se.pept.encoding.InputObject | waitForResponse(com.sun.corba.se.pept.protocol.MessageMediator messageMediator)If a message expect's a response then this method is called.
This method might block on a read (e.g., HTTP), put the calling
thread to sleep while another thread read's the response (e.g., GIOP),
or it may use the calling thread to perform the server-side work
(e.g., Solaris Doors).
|
public void | writeLock()Grab a write lock on the Connection .
If another thread already has a write lock then the calling
thread will block until the lock is released. The calling
thread must call
{@link #writeUnlock}
when it is done.
|
public void | writeUnlock()Release a write lock on the Connection .
|