| Methods Summary |
|---|
| public void | destroy()
if(log.isInfoEnabled())
log.info(sm.getString("http11protocol.stop", getName()));
ep.destroy();
if( tpOname!=null )
Registry.getRegistry(null, null).unregisterComponent(tpOname);
if( rgOname != null )
Registry.getRegistry(null, null).unregisterComponent(rgOname);
|
| public int | getAcceptorThreadPriority()
return ep.getAcceptorThreadPriority();
|
| public org.apache.coyote.Adapter | getAdapter()
return adapter;
|
| public java.net.InetAddress | getAddress()
return ep.getAddress();
|
| public java.lang.String | getAlgorithm() return ep.getAlgorithm();
|
| public java.lang.Object | getAttribute(java.lang.String key)
if( log.isTraceEnabled())
log.trace(sm.getString("http11protocol.getattribute", key));
return attributes.get(key);
|
| public java.util.Iterator | getAttributeNames()
return attributes.keySet().iterator();
|
| public int | getBacklog()
return ep.getBacklog();
|
| public java.lang.String | getCiphers() return ep.getCiphers();
|
| public boolean | getClientAuth() return ep.getClientAuth();
|
| public java.lang.String | getCompressableMimeType()
return compressableMimeTypes;
|
| public java.lang.String | getCompression()
return compression;
|
| public int | getCompressionMinSize()
return compressionMinSize;
|
| public boolean | getDisableUploadTimeout()
return disableUploadTimeout;
|
| public java.lang.String | getDomain()
return domain;
|
| public java.util.concurrent.Executor | getExecutor()
return ep.getExecutor();
|
| public boolean | getKeepAlive()Return the Keep-Alive policy for the connection.
return ((maxKeepAliveRequests != 0) && (maxKeepAliveRequests != 1));
|
| public java.lang.String | getKeypass() return getKeystorePass();
|
| public java.lang.String | getKeystore() return getKeystoreFile();
|
| public java.lang.String | getKeystoreFile() return ep.getKeystoreFile();
|
| public java.lang.String | getKeystorePass() return ep.getKeystorePass();
|
| public java.lang.String | getKeystoreType() return ep.getKeystoreType();
|
| public int | getMaxHttpHeaderSize()
return maxHttpHeaderSize;
|
| public int | getMaxKeepAliveRequests()
return maxKeepAliveRequests;
|
| public int | getMaxSavePostSize()
return maxSavePostSize;
|
| public int | getMaxThreads()
return ep.getMaxThreads();
|
| public java.lang.String | getName()
String encodedAddr = "";
if (getAddress() != null) {
encodedAddr = "" + getAddress();
if (encodedAddr.startsWith("/"))
encodedAddr = encodedAddr.substring(1);
encodedAddr = URLEncoder.encode(encodedAddr) + "-";
}
return ("http-" + encodedAddr + ep.getPort());
|
| public java.lang.String | getNoCompressionUserAgents()
return noCompressionUserAgents;
|
| public javax.management.ObjectName | getObjectName()
return oname;
|
| public int | getOomParachute()
return ep.getOomParachute();
|
| public int | getPollerThreadCount()
return ep.getPollerThreadCount();
|
| public int | getPollerThreadPriority()
return ep.getThreadPriority();
|
| public int | getPort()
return ep.getPort();
|
| public int | getProcessorCache()
return processorCache;
|
| public java.lang.String | getProperty(java.lang.String name)Get a property
return (String)getAttribute(name);
|
| public java.lang.String | getProtocol()
return getProperty("protocol");
|
| public java.lang.String | getRestrictedUserAgents()
return restrictedUserAgents;
|
| public boolean | getSSLEnabled() return ep.isSSLEnabled();
|
| public boolean | getSecure()
return secure;
|
| public long | getSelectorTimeout()
return ep.getSelectorTimeout();
|
| public java.lang.String | getServer()
return server;
|
| public int | getSoLinger()
return ep.getSoLinger();
|
| public int | getSoTimeout()
return ep.getSoTimeout();
|
| public int | getSocketBuffer()
return socketBuffer;
|
| public int | getSocketCloseDelay()
return socketCloseDelay;
|
| public java.lang.String | getSslProtocol() return ep.getSslProtocol();
|
| public boolean | getTcpNoDelay()
return ep.getTcpNoDelay();
|
| public int | getThreadPriority()
return ep.getThreadPriority();
|
| public int | getTimeout()
return timeout;
|
| public boolean | getUseSendfile()
return ep.getUseSendfile();
|
| public void | init()Start the protocol
ep.setName(getName());
ep.setHandler(cHandler);
//todo, determine if we even need these
ep.getSocketProperties().setRxBufSize(Math.max(ep.getSocketProperties().getRxBufSize(),getMaxHttpHeaderSize()));
ep.getSocketProperties().setTxBufSize(Math.max(ep.getSocketProperties().getTxBufSize(),getMaxHttpHeaderSize()));
try {
ep.init();
sslImplementation = SSLImplementation.getInstance("org.apache.tomcat.util.net.jsse.JSSEImplementation");
} catch (Exception ex) {
log.error(sm.getString("http11protocol.endpoint.initerror"), ex);
throw ex;
}
if(log.isInfoEnabled())
log.info(sm.getString("http11protocol.init", getName()));
|
| public void | pause()
try {
ep.pause();
} catch (Exception ex) {
log.error(sm.getString("http11protocol.endpoint.pauseerror"), ex);
throw ex;
}
if(log.isInfoEnabled())
log.info(sm.getString("http11protocol.pause", getName()));
|
| public void | postDeregister()
|
| public void | postRegister(java.lang.Boolean registrationDone)
|
| public void | preDeregister()
|
| public javax.management.ObjectName | preRegister(javax.management.MBeanServer server, javax.management.ObjectName name)
oname=name;
mserver=server;
domain=name.getDomain();
return name;
|
| public void | resume()
try {
ep.resume();
} catch (Exception ex) {
log.error(sm.getString("http11protocol.endpoint.resumeerror"), ex);
throw ex;
}
if(log.isInfoEnabled())
log.info(sm.getString("http11protocol.resume", getName()));
|
| public void | setAcceptorThreadPriority(int threadPriority)
ep.setAcceptorThreadPriority(threadPriority);
setAttribute("acceptorThreadPriority", "" + threadPriority);
|
| public void | setAdapter(org.apache.coyote.Adapter adapter)The adapter, used to call the connector
this.adapter=adapter;
|
| public void | setAddress(java.net.InetAddress ia)
ep.setAddress( ia );
setAttribute("address", "" + ia);
|
| public void | setAlgorithm(java.lang.String s) ep.setAlgorithm(s);
|
| public void | setAttribute(java.lang.String name, java.lang.Object value)Pass config info
if( log.isTraceEnabled())
log.trace(sm.getString("http11protocol.setattribute", name, value));
attributes.put(name, value);
|
| public void | setBacklog(int i)
ep.setBacklog(i);
setAttribute("backlog", "" + i);
|
| public void | setCiphers(java.lang.String s) ep.setCiphers(s);
|
| public void | setClientAuth(boolean b) ep.setClientAuth(b);
|
| public void | setCompressableMimeType(java.lang.String valueS)
compressableMimeTypes = valueS;
setAttribute("compressableMimeTypes", valueS);
|
| public void | setCompression(java.lang.String valueS)
compression = valueS;
setAttribute("compression", valueS);
|
| public void | setCompressionMinSize(int valueI)
compressionMinSize = valueI;
setAttribute("compressionMinSize", "" + valueI);
|
| public void | setDisableUploadTimeout(boolean isDisabled)
disableUploadTimeout = isDisabled;
|
| public void | setExecutor(java.util.concurrent.Executor executor)
ep.setExecutor(executor);
|
| public void | setKeepAlive(boolean keepAlive)Set the keep-alive policy for this connection.
if (!keepAlive) {
setMaxKeepAliveRequests(1);
}
|
| public void | setKeypass(java.lang.String s) setKeystorePass(s);
|
| public void | setKeystore(java.lang.String s) setKeystoreFile(s);
|
| public void | setKeystoreFile(java.lang.String s) ep.setKeystoreFile(s);
|
| public void | setKeystorePass(java.lang.String s) ep.setKeystorePass(s);
|
| public void | setKeystoreType(java.lang.String s) ep.setKeystoreType(s);
|
| public void | setMaxHttpHeaderSize(int valueI)
maxHttpHeaderSize = valueI;
setAttribute("maxHttpHeaderSize", "" + valueI);
|
| public void | setMaxKeepAliveRequests(int mkar)Set the maximum number of Keep-Alive requests that we will honor.
maxKeepAliveRequests = mkar;
setAttribute("maxKeepAliveRequests", "" + mkar);
|
| public void | setMaxSavePostSize(int valueI)
maxSavePostSize = valueI;
setAttribute("maxSavePostSize", "" + valueI);
|
| public void | setMaxThreads(int maxThreads)
ep.setMaxThreads(maxThreads);
setAttribute("maxThreads", "" + maxThreads);
|
| public void | setNoCompressionUserAgents(java.lang.String valueS)
noCompressionUserAgents = valueS;
setAttribute("noCompressionUserAgents", valueS);
|
| public void | setOomParachute(int oomParachute)
ep.setOomParachute(oomParachute);
setAttribute("oomParachute",oomParachute);
|
| public void | setPollerThreadCount(int count)
// -------------------- Pool setup --------------------
ep.setPollerThreadCount(count);
|
| public void | setPollerThreadPriority(int threadPriority)
ep.setPollerThreadPriority(threadPriority);
setAttribute("pollerThreadPriority", "" + threadPriority);
|
| public void | setPort(int port)
ep.setPort(port);
setAttribute("port", "" + port);
|
| public void | setProcessorCache(int processorCache)
this.processorCache = processorCache;
|
| public void | setProperty(java.lang.String name, java.lang.String value)Set a property.
if ( name!=null && (name.startsWith("socket.") ||name.startsWith("selectorPool.")) ){
ep.setProperty(name, value);
} else {
ep.setProperty(name,value); //make sure we at least try to set all properties
}
setAttribute(name, value);
|
| public void | setProtocol(java.lang.String k)
setSecure(true);
setAttribute("protocol", k);
|
| public void | setRestrictedUserAgents(java.lang.String valueS)
restrictedUserAgents = valueS;
setAttribute("restrictedUserAgents", valueS);
|
| public void | setSSLEnabled(boolean SSLEnabled) ep.setSSLEnabled(SSLEnabled);
|
| public void | setSecure(boolean b)
ep.setSecure(b);
secure=b;
setAttribute("secure", "" + b);
|
| public void | setSelectorTimeout(long timeout)
ep.setSelectorTimeout(timeout);
|
| public void | setServer(java.lang.String server)
this.server = server;
|
| public void | setSoLinger(int i)
ep.setSoLinger( i );
setAttribute("soLinger", "" + i);
|
| public void | setSoTimeout(int i)
ep.setSoTimeout(i);
setAttribute("soTimeout", "" + i);
|
| public void | setSocketBuffer(int valueI)
socketBuffer = valueI;
|
| public void | setSocketCloseDelay(int d)
socketCloseDelay=d;
setAttribute("socketCloseDelay", "" + d);
|
| public void | setSslProtocol(java.lang.String s) ep.setSslProtocol(s);
|
| public void | setTcpNoDelay(boolean b)
ep.setTcpNoDelay( b );
setAttribute("tcpNoDelay", "" + b);
|
| public void | setThreadPriority(int threadPriority)
ep.setThreadPriority(threadPriority);
setAttribute("threadPriority", "" + threadPriority);
|
| public void | setTimeout(int timeouts)
timeout = timeouts;
setAttribute("timeout", "" + timeouts);
|
| public void | setUseExecutor(boolean useexec)
ep.setUseExecutor(useexec);
|
| public void | setUseSendfile(boolean useSendfile)
ep.setUseSendfile(useSendfile);
|
| public void | start()
if( this.domain != null ) {
try {
tpOname=new ObjectName
(domain + ":" + "type=ThreadPool,name=" + getName());
Registry.getRegistry(null, null)
.registerComponent(ep, tpOname, null );
} catch (Exception e) {
log.error("Can't register threadpool" );
}
rgOname=new ObjectName
(domain + ":type=GlobalRequestProcessor,name=" + getName());
Registry.getRegistry(null, null).registerComponent
( cHandler.global, rgOname, null );
}
try {
ep.start();
} catch (Exception ex) {
log.error(sm.getString("http11protocol.endpoint.starterror"), ex);
throw ex;
}
if(log.isInfoEnabled())
log.info(sm.getString("http11protocol.start", getName()));
|
