Methods Summary |
---|
public void | accept()Accept a connection request.
This is called either when the selector gets an accept event
for this Acceptor or by a
{@link com.sun.corba.se.pept.transport.ListenerThread ListenerThread}.
It results in a
{@link com.sun.corba.se.pept.transport.Connection Connection}
being created.
|
public void | close()Close the Acceptor .
|
public com.sun.corba.se.pept.encoding.InputObject | createInputObject(com.sun.corba.se.pept.broker.Broker broker, com.sun.corba.se.pept.protocol.MessageMediator messageMediator)Used to get a
{@link com.sun.corba.se.pept.encoding.InputObject InputObject}
for the specific encoding represented by this
Acceptor .
|
public com.sun.corba.se.pept.protocol.MessageMediator | createMessageMediator(com.sun.corba.se.pept.broker.Broker xbroker, com.sun.corba.se.pept.transport.Connection xconnection)Used to get a
{@link com.sun.corba.se.pept.protocol.MessageMeidator MessageMediator}
to hold internal data for a message received using the specific
encoding, protocol, transport combination represented by this
Acceptor .
|
public com.sun.corba.se.pept.encoding.OutputObject | createOutputObject(com.sun.corba.se.pept.broker.Broker broker, com.sun.corba.se.pept.protocol.MessageMediator messageMediator)Used to get a
{@link com.sun.corba.se.pept.encoding.OutputObject OutputObject}
for the specific encoding represented by this
Acceptor .
|
public com.sun.corba.se.pept.protocol.MessageMediator | finishCreatingMessageMediator(com.sun.corba.se.pept.broker.Broker broker, com.sun.corba.se.pept.transport.Connection xconnection, com.sun.corba.se.pept.protocol.MessageMediator messageMediator)Used to finish creating a
{@link com.sun.corba.se.pept.protocol.MessageMeidator MessageMediator}
to with internal data for a message received using the specific
encoding, protocol, transport combination represented by this
Acceptor .
|
public InboundConnectionCache | getConnectionCache()Get the
{@link com.sun.corba.se.pept.transport.Inbound.ConnectionCache InboundConnectionCache}
used by this Acceptor
PEPt uses separate caches for each type of Acceptor
as given by {@link #getConnectionCacheType}.
{@link #setConnectionCache} and {@link #getConnectionCache} support
an optimzation to avoid hashing to find that cache.
|
public java.lang.String | getConnectionCacheType()PEPt uses separate caches for each type of Acceptor
as given by getConnectionCacheType .
|
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 boolean | initialize()Used to initialize an Acceptor .
For example, initialization may mean to create a
{@link java.nio.channels.ServerSocketChannel ServerSocketChannel}.
Note: this must be prepared to be be called multiple times.
|
public boolean | initialized()Used to determine if an Acceptor has been initialized.
|
public void | setConnectionCache(InboundConnectionCache connectionCache)Set the
{@link com.sun.corba.se.pept.transport.Inbound.ConnectionCache InboundConnectionCache}
to be used by this Acceptor .
PEPt uses separate caches for each type of Acceptor
as given by {@link #getConnectionCacheType}.
{@link #setConnectionCache} and {@link #getConnectionCache} support
an optimzation to avoid hashing to find that cache.
|
public boolean | shouldRegisterAcceptEvent()Used to determine if the Acceptor should register
with
{@link com.sun.corba.se.pept.transport.Selector Selector}
to handle accept events.
For example, this may be false in the case of Solaris Doors
which do not actively listen.
|