org.apache.coyote.http11

Class Http11NioProtocol

public class Http11NioProtocol extends Object implements ProtocolHandler, MBeanRegistration

Abstract the protocol implementation, including threading, etc. Processor is single threaded and specific to stream-based protocols, will not fit Jk protocols like JNI.

Author: Remy Maucherat Costin Manolache Filip Hanik

Field Summary
protected Hashtable	attributes
protected String	domain
protected NioEndpoint	ep
protected static Log	log
protected MBeanServer	mserver
protected ObjectName	oname
protected int	processorCache
protected boolean	secure
protected static StringManager	sm The string manager for this package.
protected JSSEImplementation	sslImplementation

Constructor Summary
	Http11NioProtocol()

Method Summary
void	destroy()
int	getAcceptorThreadPriority()
Adapter	getAdapter()
InetAddress	getAddress()
String	getAlgorithm()
Object	getAttribute(String key)
Iterator	getAttributeNames()
int	getBacklog()
String	getCiphers()
String	getClientAuth()
String	getClientauth()
String	getCompressableMimeType()
String	getCompression()
int	getCompressionMinSize()
boolean	getDisableUploadTimeout()
String	getDomain()
Executor	getExecutor()
boolean	getKeepAlive() Return the Keep-Alive policy for the connection.
String	getKeyAlias()
String	getKeypass()
String	getKeystore()
String	getKeystoreFile()
String	getKeystorePass()
String	getKeystoreType()
String	getKeytype()
int	getMaxHttpHeaderSize()
int	getMaxKeepAliveRequests()
int	getMaxSavePostSize()
int	getMaxThreads()
String	getName()
String	getNoCompressionUserAgents()
ObjectName	getObjectName()
int	getOomParachute()
int	getPollerThreadCount()
int	getPollerThreadPriority()
int	getPort()
int	getProcessorCache()
String	getProperty(String name) Get a property
String	getProtocol()
String	getRestrictedUserAgents()
boolean	getSecure()
long	getSelectorTimeout()
String	getServer()
int	getSocketBuffer()
int	getSocketCloseDelay()
int	getSoLinger()
int	getSoTimeout()
String	getSslProtocol()
boolean	getSSLEnabled()
boolean	getTcpNoDelay()
int	getThreadPriority()
int	getTimeout()
String	getTruststoreFile()
String	getTruststorePass()
String	getTruststoreType()
boolean	getUseSendfile()
void	init() Start the protocol
void	pause()
void	postDeregister()
void	postRegister(Boolean registrationDone)
void	preDeregister()
ObjectName	preRegister(MBeanServer server, ObjectName name)
void	resume()
void	setAcceptorThreadPriority(int threadPriority)
void	setAdapter(Adapter adapter) The adapter, used to call the connector
void	setAddress(InetAddress ia)
void	setAlgorithm(String s)
void	setAttribute(String name, Object value) Pass config info
void	setBacklog(int i)
void	setCiphers(String s)
void	setClientAuth(String s)
void	setClientauth(String s)
void	setCompressableMimeType(String valueS)
void	setCompression(String valueS)
void	setCompressionMinSize(int valueI)
void	setDisableUploadTimeout(boolean isDisabled)
void	setExecutor(Executor executor)
void	setKeepAlive(boolean keepAlive) Set the keep-alive policy for this connection.
void	setKeyAlias(String s)
void	setKeypass(String s)
void	setKeystore(String s)
void	setKeystoreFile(String s)
void	setKeystorePass(String s)
void	setKeystoreType(String s)
void	setKeytype(String s)
void	setMaxHttpHeaderSize(int valueI)
void	setMaxKeepAliveRequests(int mkar) Set the maximum number of Keep-Alive requests that we will honor.
void	setMaxSavePostSize(int valueI)
void	setMaxThreads(int maxThreads)
void	setNoCompressionUserAgents(String valueS)
void	setOomParachute(int oomParachute)
void	setPollerThreadCount(int count)
void	setPollerThreadPriority(int threadPriority)
void	setPort(int port)
void	setProcessorCache(int processorCache)
boolean	setProperty(String name, String value) Set a property.
void	setProtocol(String k)
void	setRestrictedUserAgents(String valueS)
void	setSecure(boolean b)
void	setSelectorTimeout(long timeout)
void	setServer(String server)
void	setSocketBuffer(int valueI)
void	setSocketCloseDelay(int d)
void	setSoLinger(int i)
void	setSoTimeout(int i)
void	setSslProtocol(String s)
void	setSSLEnabled(boolean SSLEnabled)
void	setTcpNoDelay(boolean b)
void	setThreadPriority(int threadPriority)
void	setTimeout(int timeouts)
void	setTruststoreFile(String f)
void	setTruststorePass(String p)
void	setTruststoreType(String t)
void	setUseExecutor(boolean useexec)
void	setUseSendfile(boolean useSendfile)
void	start()

Field Detail

attributes

protected Hashtable attributes

domain

protected String domain

ep

protected NioEndpoint ep

log

protected static Log log

mserver

protected MBeanServer mserver

oname

protected ObjectName oname

processorCache

protected int processorCache

secure

protected boolean secure

sm

protected static StringManager sm

The string manager for this package.

sslImplementation

protected JSSEImplementation sslImplementation

Constructor Detail

Http11NioProtocol

public Http11NioProtocol()

Method Detail

destroy

public void destroy()

getAcceptorThreadPriority

public int getAcceptorThreadPriority()

getAdapter

public Adapter getAdapter()

getAddress

public InetAddress getAddress()

getAlgorithm

public String getAlgorithm()

getAttribute

public Object getAttribute(String key)

getAttributeNames

public Iterator getAttributeNames()

getBacklog

public int getBacklog()

getCiphers

public String getCiphers()

getClientAuth

public String getClientAuth()

getClientauth

public String getClientauth()

getCompressableMimeType

public String getCompressableMimeType()

getCompression

public String getCompression()

getCompressionMinSize

public int getCompressionMinSize()

getDisableUploadTimeout

public boolean getDisableUploadTimeout()

getDomain

public String getDomain()

getExecutor

public Executor getExecutor()

getKeepAlive

public boolean getKeepAlive()

Return the Keep-Alive policy for the connection.

getKeyAlias

public String getKeyAlias()

getKeypass

public String getKeypass()

getKeystore

public String getKeystore()

getKeystoreFile

public String getKeystoreFile()

getKeystorePass

public String getKeystorePass()

getKeystoreType

public String getKeystoreType()

getKeytype

public String getKeytype()

getMaxHttpHeaderSize

public int getMaxHttpHeaderSize()

getMaxKeepAliveRequests

public int getMaxKeepAliveRequests()

getMaxSavePostSize

public int getMaxSavePostSize()

getMaxThreads

public int getMaxThreads()

getName

public String getName()

getNoCompressionUserAgents

public String getNoCompressionUserAgents()

getObjectName

public ObjectName getObjectName()

getOomParachute

public int getOomParachute()

getPollerThreadCount

public int getPollerThreadCount()

getPollerThreadPriority

public int getPollerThreadPriority()

getPort

public int getPort()

getProcessorCache

public int getProcessorCache()

getProperty

public String getProperty(String name)

Get a property

getProtocol

public String getProtocol()

getRestrictedUserAgents

public String getRestrictedUserAgents()

getSecure

public boolean getSecure()

getSelectorTimeout

public long getSelectorTimeout()

getServer

public String getServer()

getSocketBuffer

public int getSocketBuffer()

getSocketCloseDelay

public int getSocketCloseDelay()

getSoLinger

public int getSoLinger()

getSoTimeout

public int getSoTimeout()

getSslProtocol

public String getSslProtocol()

getSSLEnabled

public boolean getSSLEnabled()

getTcpNoDelay

public boolean getTcpNoDelay()

getThreadPriority

public int getThreadPriority()

getTimeout

public int getTimeout()

getTruststoreFile

public String getTruststoreFile()

getTruststorePass

public String getTruststorePass()

getTruststoreType

public String getTruststoreType()

getUseSendfile

public boolean getUseSendfile()

init

public void init()

Start the protocol

pause

public void pause()

postDeregister

public void postDeregister()

postRegister

public void postRegister(Boolean registrationDone)

preDeregister

public void preDeregister()

preRegister

public ObjectName preRegister(MBeanServer server, ObjectName name)

resume

public void resume()

setAcceptorThreadPriority

public void setAcceptorThreadPriority(int threadPriority)

setAdapter

public void setAdapter(Adapter adapter)

The adapter, used to call the connector

setAddress

public void setAddress(InetAddress ia)

setAlgorithm

public void setAlgorithm(String s)

setAttribute

public void setAttribute(String name, Object value)

Pass config info

setBacklog

public void setBacklog(int i)

setCiphers

public void setCiphers(String s)

setClientAuth

public void setClientAuth(String s)

setClientauth

public void setClientauth(String s)

setCompressableMimeType

public void setCompressableMimeType(String valueS)

setCompression

public void setCompression(String valueS)

setCompressionMinSize

public void setCompressionMinSize(int valueI)

setDisableUploadTimeout

public void setDisableUploadTimeout(boolean isDisabled)

setExecutor

public void setExecutor(Executor executor)

setKeepAlive

public void setKeepAlive(boolean keepAlive)

Set the keep-alive policy for this connection.

setKeyAlias

public void setKeyAlias(String s)

setKeypass

public void setKeypass(String s)

setKeystore

public void setKeystore(String s)

setKeystoreFile

public void setKeystoreFile(String s)

setKeystorePass

public void setKeystorePass(String s)

setKeystoreType

public void setKeystoreType(String s)

setKeytype

public void setKeytype(String s)

setMaxHttpHeaderSize

public void setMaxHttpHeaderSize(int valueI)

setMaxKeepAliveRequests

public void setMaxKeepAliveRequests(int mkar)

Set the maximum number of Keep-Alive requests that we will honor.

setMaxSavePostSize

public void setMaxSavePostSize(int valueI)

setMaxThreads

public void setMaxThreads(int maxThreads)

setNoCompressionUserAgents

public void setNoCompressionUserAgents(String valueS)

setOomParachute

public void setOomParachute(int oomParachute)

setPollerThreadCount

public void setPollerThreadCount(int count)

setPollerThreadPriority

public void setPollerThreadPriority(int threadPriority)

setPort

public void setPort(int port)

setProcessorCache

public void setProcessorCache(int processorCache)

setProperty

public boolean setProperty(String name, String value)

Set a property.

setProtocol

public void setProtocol(String k)

setRestrictedUserAgents

public void setRestrictedUserAgents(String valueS)

setSecure

public void setSecure(boolean b)

setSelectorTimeout

public void setSelectorTimeout(long timeout)

setServer

public void setServer(String server)

setSocketBuffer

public void setSocketBuffer(int valueI)

setSocketCloseDelay

public void setSocketCloseDelay(int d)

setSoLinger

public void setSoLinger(int i)

setSoTimeout

public void setSoTimeout(int i)

setSslProtocol

public void setSslProtocol(String s)

setSSLEnabled

public void setSSLEnabled(boolean SSLEnabled)

setTcpNoDelay

public void setTcpNoDelay(boolean b)

setThreadPriority

public void setThreadPriority(int threadPriority)

setTimeout

public void setTimeout(int timeouts)

setTruststoreFile

public void setTruststoreFile(String f)

setTruststorePass

public void setTruststorePass(String p)

setTruststoreType

public void setTruststoreType(String t)

setUseExecutor

public void setUseExecutor(boolean useexec)

setUseSendfile

public void setUseSendfile(boolean useSendfile)

start

public void start()