Java Doc for NioEndpoint.java in  » Sevlet-Container » apache-tomcat-6.0.14 » org » apache » tomcat » util » net » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation 1.  6.0 JDK Core 2.  6.0 JDK Modules 3.  6.0 JDK Modules com.sun 4.  6.0 JDK Modules com.sun.java 5.  6.0 JDK Modules sun 6.  6.0 JDK Platform 7.  Ajax 8.  Apache Harmony Java SE 9.  Aspect oriented 10.  Authentication Authorization 11.  Blogger System 12.  Build 13.  Byte Code 14.  Cache 15.  Chart 16.  Chat 17.  Code Analyzer 18.  Collaboration 19.  Content Management System 20.  Database Client 21.  Database DBMS 22.  Database JDBC Connection Pool 23.  Database ORM 24.  Development 25.  EJB Server geronimo 26.  EJB Server GlassFish 27.  EJB Server JBoss 4.2.1 28.  EJB Server resin 3.1.5 29.  ERP CRM Financial 30.  ESB 31.  Forum 32.  GIS 33.  Graphic Library 34.  Groupware 35.  HTML Parser 36.  IDE 37.  IDE Eclipse 38.  IDE Netbeans 39.  Installer 40.  Internationalization Localization 41.  Inversion of Control 42.  Issue Tracking 43.  J2EE 44.  JBoss 45.  JMS 46.  JMX 47.  Library 48.  Mail Clients 49.  Net 50.  Parser 51.  PDF 52.  Portal 53.  Profiler 54.  Project Management 55.  Report 56.  RSS RDF 57.  Rule Engine 58.  Science 59.  Scripting 60.  Search Engine 61.  Security 62.  Sevlet Container 63.  Source Control 64.  Swing Library 65.  Template Engine 66.  Test Coverage 67.  Testing 68.  UML 69.  Web Crawler 70.  Web Framework 71.  Web Mail 72.  Web Server 73.  Web Services 74.  Web Services apache cxf 2.0.1 75.  Web Services AXIS2 76.  Wiki Engine 77.  Workflow Engines 78.  XML 79.  XML UI Java Java Tutorial Java Open Source Jar File Download Java Articles Java Products Java by API Photoshop Tutorials Maya Tutorials Flash Tutorials 3ds-Max Tutorials Illustrator Tutorials GIMP Tutorials C# / C Sharp C# / CSharp Tutorial C# / CSharp Open Source ASP.Net ASP.NET Tutorial JavaScript DHTML JavaScript Tutorial JavaScript Reference HTML / CSS HTML CSS Reference C / ANSI-C C Tutorial C++ C++ Tutorial Ruby PHP Python Python Tutorial Python Open Source SQL Server / T-SQL SQL Server / T-SQL Tutorial Oracle PL / SQL Oracle PL/SQL Tutorial PostgreSQL SQL / MySQL MySQL Tutorial VB.Net VB.Net Tutorial Flash / Flex / ActionScript VBA / Excel / Access / Word XML XML Tutorial Microsoft Office PowerPoint 2007 Tutorial Microsoft Office Excel 2007 Tutorial Microsoft Office Word 2007 Tutorial

Java Source Code / Java Documentation » Sevlet Container » apache tomcat 6.0.14 » org.apache.tomcat.util.net   Source Cross Reference   Class Diagram   Java Document (Java Doc)   java.lang.Object    org.apache.tomcat.util.net.NioEndpoint NioEndpoint public class NioEndpoint (Code) NIO tailored thread pool, providing the following services: Socket acceptor thread Socket poller thread Worker threads pool When switching to Java 5, there's an opportunity to use the virtual machine's thread pool. author:    Mladen Turk author:    Remy Maucherat author:    Filip Hanik Inner Class :protected class Acceptor implements Runnable Inner Class :public class PollerEvent implements Runnable Inner Class :public class Poller implements Runnable Inner Class :public static class KeyAttachment Inner Class :protected class Worker implements Runnable Inner Class :public class NioBufferHandler implements ApplicationBufferHandler Inner Class :public interface Handler Inner Class :public class WorkerStack Inner Class :protected class SocketProcessor implements Runnable Inner Class :public static class TaskQueue extends LinkedBlockingQueue Inner Class :class TaskThreadFactory implements ThreadFactory Inner Class :public static class SendfileData Field Summary final public static  String CERTIFICATE_KEY      The Request attribute key for the client certificate chain. final public static  String CIPHER_SUITE_KEY      The Request attribute key for the cipher suite. final public static  String KEY_SIZE_KEY      The Request attribute key for the key size. final public static  int OP_REGISTER      final public static  String SESSION_ID_KEY      The Request attribute key for the session id. protected  boolean SSLEnabled      SSL engine. protected  int acceptorThreadCount      Acceptor thread count. protected  int acceptorThreadPriority      Priority of the acceptor threads. protected  InetAddress address      Address for the server socket. protected  String algorithm      protected  int backlog      Allows the server developer to specify the backlog that should be used for server sockets. protected  String ciphers      protected  String[] ciphersarr      protected  boolean clientAuth      protected  int curThreads      Current worker threads count. protected  int curThreadsBusy      Current worker threads busy count. protected  boolean daemon      The default is true - the created threads will be in daemon mode. protected  ConcurrentLinkedQueue<PollerEvent> eventCache      protected  Executor executor      External Executor based thread pool. protected  Handler handler      Handling of accepted sockets. protected  boolean initialized      Track the initialization state of the endpoint. protected  ConcurrentLinkedQueue<KeyAttachment> keyCache      protected  String keystoreFile      protected  String keystorePass      protected  String keystoreType       long lastParachuteCheck      Keep track of OOM warning messages. protected static  Log log      protected  int maxThreads      Maximum amount of worker threads. protected  String name      Name of the thread pool, which will be used for naming child threads. protected  ConcurrentLinkedQueue<NioChannel> nioChannels      protected  int oomParachute      The size of the OOM parachute. protected  byte[] oomParachuteData      The oom parachute, when an OOM error happens, will release the data, giving the JVM instantly a chunk of data to be able to recover with. final protected static  String oomParachuteMsg      protected volatile  boolean paused      Will be set to true whenever the endpoint is paused. protected  int pollerRoundRobin      protected  int pollerThreadCount      Poller thread count. protected  int pollerThreadPriority      Priority of the poller threads. protected  Poller[] pollers      The socket poller. protected  int port      Server socket port. protected  ConcurrentLinkedQueue<SocketProcessor> processorCache      protected volatile  boolean running      Running state of the endpoint. protected  boolean secure      protected  NioSelectorPool selectorPool      protected  long selectorTimeout      protected  int sequence      Sequence number used to generate thread names. protected  ServerSocketChannel serverSock      Server socket "pointer". protected static  StringManager sm      protected  SocketProperties socketProperties      protected  SSLContext sslContext      protected  String sslEnabledProtocols      protected  String[] sslEnabledProtocolsarr      protected  String sslProtocol      protected  int threadPriority      Priority of the worker threads. protected  boolean useComet      Allow comet request handling. protected  boolean useExecutor      protected  boolean useSendfile      protected  WorkerStack workers      Available workers. Method Summary protected  void checkParachute()      protected  SSLEngine createSSLEngine()      protected  Worker createWorkerThread()      Create (or allocate) and return an available processor for use in processing a specific HTTP request, if possible. public  void destroy()      Deallocate NIO memory pools, and close server socket. public  int getAcceptorThreadCount()      public  int getAcceptorThreadPriority()      public  InetAddress getAddress()      public  String getAlgorithm()      public  int getBacklog()      public  String getCiphers()      public  boolean getClientAuth()      public  Poller getCometPoller0()      The socket poller used for Comet support. public  int getCurrentThreadCount()      Return the amount of threads that are managed by the pool. public  int getCurrentThreadsBusy()      Return the amount of threads currently busy. public  boolean getDaemon()      public  Executor getExecutor()      public  Handler getHandler()      public  int getKeepAliveCount()      Number of keepalive sockets. public  String getKeystore()      public  String getKeystoreFile()      public  String getKeystorePass()      public  String getKeystoreType()      public  int getMaxSpareThreads()      Dummy maxSpareThreads property. public  int getMaxThreads()      public  int getMinSpareThreads()      Dummy minSpareThreads property. public  String getName()      public  int getOomParachute()      public  byte[] getOomParachuteData()      public  Poller getPoller0()      public  int getPollerThreadCount()      public  int getPollerThreadPriority()      public  int getPort()      public  int getReadBufSize()      public  SSLContext getSSLContext()      public  boolean getSecure()      public  NioSelectorPool getSelectorPool()      public  long getSelectorTimeout()      protected  int getSequence()      Get a sequence number used for thread naming. public  int getSoLinger()      Socket linger. public  int getSoTimeout()      Socket timeout. public  SocketProperties getSocketProperties()      public  String getSslProtocol()      public  boolean getTcpNoDelay()      Socket TCP no delay. public  int getThreadPriority()      public  boolean getUseComet()      public  boolean getUseExecutor()      public  boolean getUseSendfile()      protected  Worker getWorkerThread()      Return a new worker thread, and block while to worker is available. public  int getWriteBufSize()      public  void init()      Initialize the endpoint. public  boolean isPaused()      Return the state of the endpoint. public  boolean isRunning()      Return the state of the endpoint. public  boolean isSSLEnabled()      protected  boolean isWorkerAvailable()      Returns true if a worker thread is available for processing. protected  Worker newWorkerThread()      Create and return a new processor suitable for processing HTTP requests and returning the corresponding responses. public  void pause()      Pause the endpoint, which will make it stop accepting new sockets. protected  boolean processSocket(NioChannel socket)      Process given socket. protected  boolean processSocket(NioChannel socket, SocketStatus status)      Process given socket for an event. protected  boolean processSocket(NioChannel socket, SocketStatus status, boolean dispatch)      protected  boolean reclaimParachute(boolean force)      protected  void recycleWorkerThread(Worker workerThread)      Recycle the specified Processor so that it can be used again. protected  void releaseCaches()      public  void resume()      Resume the endpoint, which will make it start accepting new sockets again. public  void setAcceptorThreadCount(int acceptorThreadCount)      public  void setAcceptorThreadPriority(int acceptorThreadPriority)      public  void setAddress(InetAddress address)      public  void setAlgorithm(String s)      public  void setBacklog(int backlog)      public  void setCiphers(String s)      public  void setClientAuth(boolean b)      public  void setDaemon(boolean b)      public  void setExecutor(Executor executor)      public  void setHandler(Handler handler)      public  void setKeystore(String s)      public  void setKeystoreFile(String s)      public  void setKeystorePass(String s)      public  void setKeystoreType(String s)      public  void setMaxThreads(int maxThreads)      public  void setName(String name)      public  void setOomParachute(int oomParachute)      public  void setOomParachuteData(byte[] oomParachuteData)      public  void setPollerThreadCount(int pollerThreadCount)      public  void setPollerThreadPriority(int pollerThreadPriority)      public  void setPort(int port)      public  void setProperty(String name, String value)      public  void setSSLContext(SSLContext c)      public  void setSSLEnabled(boolean SSLEnabled)      public  void setSecure(boolean b)      public  void setSelectorPool(NioSelectorPool selectorPool)      public  void setSelectorTimeout(long timeout)      public  void setSoLinger(int soLinger)      public  void setSoTimeout(int soTimeout)      protected  boolean setSocketOptions(SocketChannel socket)      Process the specified connection. public  void setSocketProperties(SocketProperties socketProperties)      public  void setSslEnabledProtocols(String s)      public  void setSslProtocol(String s)      public  void setTcpNoDelay(boolean tcpNoDelay)      public  void setThreadPriority(int threadPriority)      public  void setUseComet(boolean useComet)      public  void setUseExecutor(boolean useexec)      public  void setUseSendfile(boolean useSendfile)      public  void start()      Start the NIO endpoint, creating acceptor, poller threads. public  void stop()      Stop the endpoint. protected  void unlockAccept()      Unlock the server socket accept using a bogus connection. Field Detail CERTIFICATE_KEY final public static String CERTIFICATE_KEY(Code) The Request attribute key for the client certificate chain. CIPHER_SUITE_KEY final public static String CIPHER_SUITE_KEY(Code) The Request attribute key for the cipher suite. KEY_SIZE_KEY final public static String KEY_SIZE_KEY(Code) The Request attribute key for the key size. OP_REGISTER final public static int OP_REGISTER(Code) SESSION_ID_KEY final public static String SESSION_ID_KEY(Code) The Request attribute key for the session id. This one is a Tomcat extension to the Servlet spec. SSLEnabled protected boolean SSLEnabled(Code) SSL engine. acceptorThreadCount protected int acceptorThreadCount(Code) Acceptor thread count. acceptorThreadPriority protected int acceptorThreadPriority(Code) Priority of the acceptor threads. address protected InetAddress address(Code) Address for the server socket. algorithm protected String algorithm(Code) backlog protected int backlog(Code) Allows the server developer to specify the backlog that should be used for server sockets. By default, this value is 100. ciphers protected String ciphers(Code) ciphersarr protected String[] ciphersarr(Code) clientAuth protected boolean clientAuth(Code) curThreads protected int curThreads(Code) Current worker threads count. curThreadsBusy protected int curThreadsBusy(Code) Current worker threads busy count. daemon protected boolean daemon(Code) The default is true - the created threads will be in daemon mode. If set to false, the control thread will not be daemon - and will keep the process alive. eventCache protected ConcurrentLinkedQueue<PollerEvent> eventCache(Code) Cache for poller events executor protected Executor executor(Code) External Executor based thread pool. handler protected Handler handler(Code) Handling of accepted sockets. initialized protected boolean initialized(Code) Track the initialization state of the endpoint. keyCache protected ConcurrentLinkedQueue<KeyAttachment> keyCache(Code) Cache for key attachment objects keystoreFile protected String keystoreFile(Code) keystorePass protected String keystorePass(Code) keystoreType protected String keystoreType(Code) lastParachuteCheck long lastParachuteCheck(Code) Keep track of OOM warning messages. log protected static Log log(Code) maxThreads protected int maxThreads(Code) Maximum amount of worker threads. name protected String name(Code) Name of the thread pool, which will be used for naming child threads. nioChannels protected ConcurrentLinkedQueue<NioChannel> nioChannels(Code) Bytebuffer cache, each channel holds a set of buffers (two, except for SSL holds four) oomParachute protected int oomParachute(Code) The size of the OOM parachute. oomParachuteData protected byte[] oomParachuteData(Code) The oom parachute, when an OOM error happens, will release the data, giving the JVM instantly a chunk of data to be able to recover with. oomParachuteMsg final protected static String oomParachuteMsg(Code) Make sure this string has already been allocated paused protected volatile boolean paused(Code) Will be set to true whenever the endpoint is paused. pollerRoundRobin protected int pollerRoundRobin(Code) pollerThreadCount protected int pollerThreadCount(Code) Poller thread count. pollerThreadPriority protected int pollerThreadPriority(Code) Priority of the poller threads. pollers protected Poller[] pollers(Code) The socket poller. port protected int port(Code) Server socket port. processorCache protected ConcurrentLinkedQueue<SocketProcessor> processorCache(Code) Cache for SocketProcessor objects running protected volatile boolean running(Code) Running state of the endpoint. secure protected boolean secure(Code) selectorPool protected NioSelectorPool selectorPool(Code) selectorTimeout protected long selectorTimeout(Code) sequence protected int sequence(Code) Sequence number used to generate thread names. serverSock protected ServerSocketChannel serverSock(Code) Server socket "pointer". sm protected static StringManager sm(Code) socketProperties protected SocketProperties socketProperties(Code) sslContext protected SSLContext sslContext(Code) sslEnabledProtocols protected String sslEnabledProtocols(Code) sslEnabledProtocolsarr protected String[] sslEnabledProtocolsarr(Code) sslProtocol protected String sslProtocol(Code) threadPriority protected int threadPriority(Code) Priority of the worker threads. useComet protected boolean useComet(Code) Allow comet request handling. useExecutor protected boolean useExecutor(Code) useSendfile protected boolean useSendfile(Code) use send file workers protected WorkerStack workers(Code) Available workers. Method Detail checkParachute protected void checkParachute()(Code) createSSLEngine protected SSLEngine createSSLEngine()(Code) createWorkerThread protected Worker createWorkerThread()(Code) Create (or allocate) and return an available processor for use in processing a specific HTTP request, if possible. If the maximum allowed processors have already been created and are in use, return null instead. destroy public void destroy() throws Exception(Code) Deallocate NIO memory pools, and close server socket. getAcceptorThreadCount public int getAcceptorThreadCount()(Code) getAcceptorThreadPriority public int getAcceptorThreadPriority()(Code) getAddress public InetAddress getAddress()(Code) getAlgorithm public String getAlgorithm()(Code) getBacklog public int getBacklog()(Code) getCiphers public String getCiphers()(Code) getClientAuth public boolean getClientAuth()(Code) getCometPoller0 public Poller getCometPoller0()(Code) The socket poller used for Comet support. getCurrentThreadCount public int getCurrentThreadCount()(Code) Return the amount of threads that are managed by the pool. the amount of threads that are managed by the pool getCurrentThreadsBusy public int getCurrentThreadsBusy()(Code) Return the amount of threads currently busy. the amount of threads currently busy getDaemon public boolean getDaemon()(Code) getExecutor public Executor getExecutor()(Code) getHandler public Handler getHandler()(Code) getKeepAliveCount public int getKeepAliveCount()(Code) Number of keepalive sockets. getKeystore public String getKeystore()(Code) getKeystoreFile public String getKeystoreFile()(Code) getKeystorePass public String getKeystorePass()(Code) getKeystoreType public String getKeystoreType()(Code) getMaxSpareThreads public int getMaxSpareThreads()(Code) Dummy maxSpareThreads property. getMaxThreads public int getMaxThreads()(Code) getMinSpareThreads public int getMinSpareThreads()(Code) Dummy minSpareThreads property. getName public String getName()(Code) getOomParachute public int getOomParachute()(Code) getOomParachuteData public byte[] getOomParachuteData()(Code) getPoller0 public Poller getPoller0()(Code) getPollerThreadCount public int getPollerThreadCount()(Code) getPollerThreadPriority public int getPollerThreadPriority()(Code) getPort public int getPort()(Code) getReadBufSize public int getReadBufSize()(Code) getSSLContext public SSLContext getSSLContext()(Code) getSecure public boolean getSecure()(Code) getSelectorPool public NioSelectorPool getSelectorPool()(Code) getSelectorTimeout public long getSelectorTimeout()(Code) getSequence protected int getSequence()(Code) Get a sequence number used for thread naming. getSoLinger public int getSoLinger()(Code) Socket linger. getSoTimeout public int getSoTimeout()(Code) Socket timeout. getSocketProperties public SocketProperties getSocketProperties()(Code) getSslProtocol public String getSslProtocol()(Code) getTcpNoDelay public boolean getTcpNoDelay()(Code) Socket TCP no delay. getThreadPriority public int getThreadPriority()(Code) getUseComet public boolean getUseComet()(Code) getUseExecutor public boolean getUseExecutor()(Code) getUseSendfile public boolean getUseSendfile()(Code) getWorkerThread protected Worker getWorkerThread()(Code) Return a new worker thread, and block while to worker is available. getWriteBufSize public int getWriteBufSize()(Code) init public void init() throws Exception(Code) Initialize the endpoint. isPaused public boolean isPaused()(Code) Return the state of the endpoint. true if the endpoint is paused, false otherwise isRunning public boolean isRunning()(Code) Return the state of the endpoint. true if the endpoint is running, false otherwise isSSLEnabled public boolean isSSLEnabled()(Code) isWorkerAvailable protected boolean isWorkerAvailable()(Code) Returns true if a worker thread is available for processing. boolean newWorkerThread protected Worker newWorkerThread()(Code) Create and return a new processor suitable for processing HTTP requests and returning the corresponding responses. pause public void pause()(Code) Pause the endpoint, which will make it stop accepting new sockets. processSocket protected boolean processSocket(NioChannel socket)(Code) Process given socket. processSocket protected boolean processSocket(NioChannel socket, SocketStatus status)(Code) Process given socket for an event. processSocket protected boolean processSocket(NioChannel socket, SocketStatus status, boolean dispatch)(Code) reclaimParachute protected boolean reclaimParachute(boolean force)(Code) recycleWorkerThread protected void recycleWorkerThread(Worker workerThread)(Code) Recycle the specified Processor so that it can be used again. Parameters:   workerThread - The processor to be recycled releaseCaches protected void releaseCaches()(Code) resume public void resume()(Code) Resume the endpoint, which will make it start accepting new sockets again. setAcceptorThreadCount public void setAcceptorThreadCount(int acceptorThreadCount)(Code) setAcceptorThreadPriority public void setAcceptorThreadPriority(int acceptorThreadPriority)(Code) setAddress public void setAddress(InetAddress address)(Code) setAlgorithm public void setAlgorithm(String s)(Code) setBacklog public void setBacklog(int backlog)(Code) setCiphers public void setCiphers(String s)(Code) setClientAuth public void setClientAuth(boolean b)(Code) setDaemon public void setDaemon(boolean b)(Code) setExecutor public void setExecutor(Executor executor)(Code) setHandler public void setHandler(Handler handler)(Code) setKeystore public void setKeystore(String s)(Code) setKeystoreFile public void setKeystoreFile(String s)(Code) setKeystorePass public void setKeystorePass(String s)(Code) setKeystoreType public void setKeystoreType(String s)(Code) setMaxThreads public void setMaxThreads(int maxThreads)(Code) setName public void setName(String name)(Code) setOomParachute public void setOomParachute(int oomParachute)(Code) setOomParachuteData public void setOomParachuteData(byte[] oomParachuteData)(Code) setPollerThreadCount public void setPollerThreadCount(int pollerThreadCount)(Code) setPollerThreadPriority public void setPollerThreadPriority(int pollerThreadPriority)(Code) setPort public void setPort(int port)(Code) setProperty public void setProperty(String name, String value)(Code) Generic properties, introspected setSSLContext public void setSSLContext(SSLContext c)(Code) setSSLEnabled public void setSSLEnabled(boolean SSLEnabled)(Code) setSecure public void setSecure(boolean b)(Code) setSelectorPool public void setSelectorPool(NioSelectorPool selectorPool)(Code) setSelectorTimeout public void setSelectorTimeout(long timeout)(Code) setSoLinger public void setSoLinger(int soLinger)(Code) setSoTimeout public void setSoTimeout(int soTimeout)(Code) setSocketOptions protected boolean setSocketOptions(SocketChannel socket)(Code) Process the specified connection. setSocketProperties public void setSocketProperties(SocketProperties socketProperties)(Code) setSslEnabledProtocols public void setSslEnabledProtocols(String s)(Code) setSslProtocol public void setSslProtocol(String s)(Code) setTcpNoDelay public void setTcpNoDelay(boolean tcpNoDelay)(Code) setThreadPriority public void setThreadPriority(int threadPriority)(Code) setUseComet public void setUseComet(boolean useComet)(Code) setUseExecutor public void setUseExecutor(boolean useexec)(Code) setUseSendfile public void setUseSendfile(boolean useSendfile)(Code) start public void start() throws Exception(Code) Start the NIO endpoint, creating acceptor, poller threads. stop public void stop()(Code) Stop the endpoint. This will cause all processing threads to stop. unlockAccept protected void unlockAccept()(Code) Unlock the server socket accept using a bogus connection. Methods inherited from java.lang.Object native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc) public boolean equals(Object obj)(Code)(Java Doc) protected void finalize() throws Throwable(Code)(Java Doc) final native public Class getClass()(Code)(Java Doc) native public int hashCode()(Code)(Java Doc) final native public void notify()(Code)(Java Doc) final native public void notifyAll()(Code)(Java Doc) public String toString()(Code)(Java Doc) final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc) final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc) final public void wait() throws InterruptedException(Code)(Java Doc)