Package com.sun.corba.se.impl.transport

Class SocketOrChannelAcceptorImpl

java.lang.Object

com.sun.corba.se.impl.transport.EventHandlerBase

com.sun.corba.se.impl.transport.SocketOrChannelAcceptorImpl

All Implemented Interfaces:

Acceptor, EventHandler, LegacyServerSocketEndPointInfo, Work, CorbaAcceptor, SocketInfo, SocketOrChannelAcceptor

Direct Known Subclasses:

SocketFactoryAcceptorImpl

public class SocketOrChannelAcceptorImpl
extends EventHandlerBase
implements CorbaAcceptor, SocketOrChannelAcceptor, Work, SocketInfo, LegacyServerSocketEndPointInfo

Author:

Harold Carr

Field Summary

Fields

Modifier and Type	Field	Description
protected InboundConnectionCache	connectionCache
protected long	enqueueTime
protected String	hostname
protected boolean	initialized
protected int	locatorPort
protected String	name
protected int	port
protected ServerSocket	serverSocket
protected ServerSocketChannel	serverSocketChannel
protected String	type
protected ORBUtilSystemException	wrapper

Fields inherited from class com.sun.corba.se.impl.transport.EventHandlerBase

orb, selectionKey, useSelectThreadToWait, useWorkerThreadForEvent, work

Fields inherited from interface com.sun.corba.se.spi.legacy.connection.LegacyServerSocketEndPointInfo

BOOT_NAMING, DEFAULT_ENDPOINT, NO_NAME

Fields inherited from interface com.sun.corba.se.spi.transport.SocketInfo

IIOP_CLEAR_TEXT

Constructor Summary

Constructors

Constructor	Description
SocketOrChannelAcceptorImpl(ORB orb)
SocketOrChannelAcceptorImpl(ORB orb, int port)
SocketOrChannelAcceptorImpl(ORB orb, int port, String name, String type)

Method Summary

Modifier and Type	Method	Description
void	accept()	Accept a connection request.
void	addToIORTemplate(IORTemplate iorTemplate, Policies policies, String codebase)
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 broker, Connection connection)	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.
void	doWork()	This method denotes the actual work that is done by the work item.
protected void	dprint(String msg)
protected void	dprint(String msg, Throwable t)
MessageMediator	finishCreatingMessageMediator(Broker broker, Connection connection, 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.
Acceptor	getAcceptor()
SelectableChannel	getChannel()
Connection	getConnection()
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.
long	getEnqueueTime()	This methods gets the time in millis in the work item, when this work item was enqueued in the work queue.
EventHandler	getEventHandler()	Get the EventHandler associated with this Acceptor.
String	getHost()
String	getHostName()	Get the host name of this end point.
int	getInterestOps()
int	getLocatorPort()	The ORBD's proxy port of this end point.
String	getMonitoringName()
String	getName()	This method will return the name of the work item.
String	getObjectAdapterId()
String	getObjectAdapterManagerId()
int	getPort()
ServerSocket	getServerSocket()
String	getType()	e.g.: "CLEAR_TEXT", "SSL", ...
boolean	initialize()	Used to initialize an Acceptor.
boolean	initialized()	Used to determine if an Acceptor has been initialized.
protected void	internalInitialize()
void	setConnectionCache(InboundConnectionCache connectionCache)	Set the InboundConnectionCache to be used by this Acceptor.
void	setEnqueueTime(long timeInMillis)	This methods sets the time in millis in the work item, when this work item was enqueued in the work queue.
void	setLocatorPort(int port)
boolean	shouldRegisterAcceptEvent()	Used to determine if the Acceptor should register with Selector to handle accept events.
String	toString()
protected String	toStringName()

Methods inherited from class com.sun.corba.se.impl.transport.EventHandlerBase

getSelectionKey, getWork, handleEvent, setSelectionKey, setUseSelectThreadToWait, setUseWorkerThreadForEvent, setWork, shouldUseSelectThreadToWait, shouldUseWorkerThreadForEvent

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serverSocketChannel

protected ServerSocketChannel serverSocketChannel

serverSocket

protected ServerSocket serverSocket

port

protected int port

enqueueTime

protected long enqueueTime

initialized

protected boolean initialized

wrapper

protected ORBUtilSystemException wrapper

connectionCache

protected InboundConnectionCache connectionCache

type

protected String type

name

protected String name

hostname

protected String hostname

locatorPort

protected int locatorPort

Constructor Details

SocketOrChannelAcceptorImpl

public SocketOrChannelAcceptorImpl(ORB orb)

SocketOrChannelAcceptorImpl

public SocketOrChannelAcceptorImpl(ORB orb,
 int port)

SocketOrChannelAcceptorImpl

public SocketOrChannelAcceptorImpl(ORB orb,
 int port,
 String name,
 String type)

Method Details

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.

internalInitialize

protected void internalInitialize()
                           throws Exception

Throws:

Exception

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:

true</code. if the Acceptor 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

Parameters:

connectionCache - .

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

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

getObjectAdapterId

public String getObjectAdapterId()

Specified by:

getObjectAdapterId in interface CorbaAcceptor

getObjectAdapterManagerId

public String getObjectAdapterManagerId()

Specified by:

getObjectAdapterManagerId in interface CorbaAcceptor

addToIORTemplate

public void addToIORTemplate(IORTemplate iorTemplate,
 Policies policies,
 String codebase)

Specified by:

addToIORTemplate in interface CorbaAcceptor

getMonitoringName

public String getMonitoringName()

Specified by:

getMonitoringName in interface CorbaAcceptor

getChannel

public SelectableChannel getChannel()

Specified by:

getChannel in interface EventHandler

getInterestOps

public int getInterestOps()

Specified by:

getInterestOps in interface EventHandler

getAcceptor

public Acceptor getAcceptor()

Specified by:

getAcceptor in interface EventHandler

getConnection

public Connection getConnection()

Specified by:

getConnection in interface EventHandler

doWork

public void doWork()

Description copied from interface: Work

This method denotes the actual work that is done by the work item.

Specified by:

doWork in interface Work

setEnqueueTime

public void setEnqueueTime(long timeInMillis)

Description copied from interface: Work

This methods sets the time in millis in the work item, when this work item was enqueued in the work queue.

Specified by:

setEnqueueTime in interface Work

getEnqueueTime

public long getEnqueueTime()

Description copied from interface: Work

This methods gets the time in millis in the work item, when this work item was enqueued in the work queue.

Specified by:

getEnqueueTime in interface Work

createMessageMediator

public MessageMediator createMessageMediator(Broker broker,
 Connection connection)

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 broker,
 Connection connection,
 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

getServerSocket

public ServerSocket getServerSocket()

Specified by:

getServerSocket in interface SocketOrChannelAcceptor

toString

public String toString()

Overrides:

toString in class Object

toStringName

protected String toStringName()

dprint

protected void dprint(String msg)

dprint

protected void dprint(String msg,
 Throwable t)

getType

public String getType()

Description copied from interface: LegacyServerSocketEndPointInfo

e.g.: "CLEAR_TEXT", "SSL", ...

Specified by:

getType in interface LegacyServerSocketEndPointInfo

Specified by:

getType in interface SocketInfo

getHostName

public String getHostName()

Description copied from interface: LegacyServerSocketEndPointInfo

Get the host name of this end point. Subcontracts must use this instead of InetAddress.getHostName() because this would take into account the value of the ORBServerHost property.

Specified by:

getHostName in interface LegacyServerSocketEndPointInfo

getHost

public String getHost()

Specified by:

getHost in interface SocketInfo

getPort

public int getPort()

Specified by:

getPort in interface LegacyServerSocketEndPointInfo

Specified by:

getPort in interface SocketInfo

getLocatorPort

public int getLocatorPort()

Description copied from interface: LegacyServerSocketEndPointInfo

The ORBD's proxy port of this end point. Note: Pre-ORT "port-exchange" model.

Specified by:

getLocatorPort in interface LegacyServerSocketEndPointInfo

setLocatorPort

public void setLocatorPort(int port)

Specified by:

setLocatorPort in interface LegacyServerSocketEndPointInfo

getName

public String getName()

Description copied from interface: Work

This method will return the name of the work item.

Specified by:

getName in interface LegacyServerSocketEndPointInfo

Specified by:

getName in interface Work