com.sun.corba.se.impl.orb

Class ParserTable.TestAcceptor2

java.lang.Object

com.sun.corba.se.impl.orb.ParserTable.TestAcceptor2

All Implemented Interfaces:

Acceptor

Enclosing class:

ParserTable

public static final class ParserTable.TestAcceptor2
extends Object
implements Acceptor

Constructor Summary

Constructors

Constructor and Description
TestAcceptor2()

Method Summary

Modifier and Type	Method and Description
void	accept() Accept a connection request.
void	close() Close the Acceptor.
InputObject	createInputObject(Broker broker, MessageMediator messageMediator) Used to get a InputObject for the specific encoding represented by this Acceptor.
MessageMediator	createMessageMediator(Broker xbroker, Connection xconnection) Used to get a MessageMediator to hold internal data for a message received using the specific encoding, protocol, transport combination represented by this Acceptor.
OutputObject	createOutputObject(Broker broker, MessageMediator messageMediator) Used to get a OutputObject for the specific encoding represented by this Acceptor.
boolean	equals(Object other)
MessageMediator	finishCreatingMessageMediator(Broker xbroker, Connection xconnection, MessageMediator messageMediator) Used to finish creating a MessageMediator to with internal data for a message received using the specific encoding, protocol, transport combination represented by this Acceptor.
InboundConnectionCache	getConnectionCache() Get the InboundConnectionCache used by this Acceptor PEPt uses separate caches for each type of Acceptor as given by Acceptor.getConnectionCacheType().
String	getConnectionCacheType() PEPt uses separate caches for each type of Acceptor as given by getConnectionCacheType.
EventHandler	getEventHandler() Get the EventHandler associated with this Acceptor.
int	hashCode()
boolean	initialize() Used to initialize an Acceptor.
boolean	initialized() Used to determine if an Acceptor has been initialized.
void	setConnectionCache(InboundConnectionCache connectionCache) Set the InboundConnectionCache to be used by this Acceptor.
void	setUseSelectThreadForConnections(boolean x)
void	setUseWorkerThreadForConnections(boolean x)
boolean	shouldRegisterAcceptEvent() Used to determine if the Acceptor should register with Selector to handle accept events.
boolean	shouldUseSelectThreadForConnections()
boolean	shouldUseWorkerThreadForConnections()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestAcceptor2

public TestAcceptor2()

Method Detail

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

initialize

public boolean initialize()

Description copied from interface: Acceptor

Used to initialize an Acceptor. For example, initialization may mean to create a ServerSocketChannel. Note: this must be prepared to be be called multiple times.

Specified by:

initialize in interface Acceptor

Returns:

true when it performs initializatin actions (typically the first call.

initialized

public boolean initialized()

Description copied from interface: Acceptor

Used to determine if an Acceptor has been initialized.

Specified by:

initialized in interface Acceptor

Returns:

trueAcceptor has been initialized.

getConnectionCacheType

public String getConnectionCacheType()

Description copied from interface: Acceptor

PEPt uses separate caches for each type of Acceptor as given by getConnectionCacheType.

Specified by:

getConnectionCacheType in interface Acceptor

Returns:

String

setConnectionCache

public void setConnectionCache(InboundConnectionCache connectionCache)

Description copied from interface: Acceptor

Set the InboundConnectionCache to be used by this Acceptor. PEPt uses separate caches for each type of Acceptor as given by Acceptor.getConnectionCacheType(). Acceptor.setConnectionCache(com.sun.corba.se.pept.transport.InboundConnectionCache) and Acceptor.getConnectionCache() support an optimzation to avoid hashing to find that cache.

Specified by:

setConnectionCache in interface Acceptor

getConnectionCache

public InboundConnectionCache getConnectionCache()

Description copied from interface: Acceptor

Get the InboundConnectionCache used by this Acceptor PEPt uses separate caches for each type of Acceptor as given by Acceptor.getConnectionCacheType(). Acceptor.setConnectionCache(com.sun.corba.se.pept.transport.InboundConnectionCache) and Acceptor.getConnectionCache() support an optimzation to avoid hashing to find that cache.

Specified by:

getConnectionCache in interface Acceptor

Returns:

ConnectionCache

shouldRegisterAcceptEvent

public boolean shouldRegisterAcceptEvent()

Description copied from interface: Acceptor

Used to determine if the Acceptor should register with Selector to handle accept events. For example, this may be false in the case of Solaris Doors which do not actively listen.

Specified by:

shouldRegisterAcceptEvent in interface Acceptor

Returns:

true if the Acceptor should be registered with Selector

setUseSelectThreadForConnections

public void setUseSelectThreadForConnections(boolean x)

shouldUseSelectThreadForConnections

public boolean shouldUseSelectThreadForConnections()

setUseWorkerThreadForConnections

public void setUseWorkerThreadForConnections(boolean x)

shouldUseWorkerThreadForConnections

public boolean shouldUseWorkerThreadForConnections()

accept

public void accept()

Description copied from interface: Acceptor

Accept a connection request. This is called either when the selector gets an accept event for this Acceptor or by a ListenerThread. It results in a Connection being created.

Specified by:

accept in interface Acceptor

close

public void close()

Description copied from interface: Acceptor

Close the Acceptor.

Specified by:

close in interface Acceptor

getEventHandler

public EventHandler getEventHandler()

Description copied from interface: Acceptor

Get the EventHandler associated with this Acceptor.

Specified by:

getEventHandler in interface Acceptor

Returns:

EventHandler

createMessageMediator

public MessageMediator createMessageMediator(Broker xbroker,
                                             Connection xconnection)

Description copied from interface: Acceptor

Used to get a MessageMediator to hold internal data for a message received using the specific encoding, protocol, transport combination represented by this Acceptor.

Specified by:

createMessageMediator in interface Acceptor

Returns:

MessageMediator

finishCreatingMessageMediator

public MessageMediator finishCreatingMessageMediator(Broker xbroker,
                                                     Connection xconnection,
                                                     MessageMediator messageMediator)

Description copied from interface: Acceptor

Used to finish creating a MessageMediator to with internal data for a message received using the specific encoding, protocol, transport combination represented by this Acceptor.

Specified by:

finishCreatingMessageMediator in interface Acceptor

Returns:

MessageMediator

createInputObject

public InputObject createInputObject(Broker broker,
                                     MessageMediator messageMediator)

Description copied from interface: Acceptor

Used to get a InputObject for the specific encoding represented by this Acceptor.

Specified by:

createInputObject in interface Acceptor

Returns:

InputObject

createOutputObject

public OutputObject createOutputObject(Broker broker,
                                       MessageMediator messageMediator)

Description copied from interface: Acceptor

Used to get a OutputObject for the specific encoding represented by this Acceptor.

Specified by:

createOutputObject in interface Acceptor

Returns:

OutputObject