org.apache.tomcat.util.net
Class NioEndpoint.Worker

java.lang.Object
  org.apache.tomcat.util.net.NioEndpoint.Worker

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

NioEndpoint

protected class NioEndpoint.Worker
extends java.lang.Object
implements java.lang.Runnable

Server processor class.

thread

protected java.lang.Thread thread

available

protected boolean available

socket

protected java.lang.Object socket

status

protected SocketStatus status

NioEndpoint.Worker

protected NioEndpoint.Worker()

assign

protected void assign(java.lang.Object socket)

Process an incoming TCP/IP connection on the specified socket. Any exception that occurs during processing must be logged and swallowed. NOTE: This method is called from our Connector's thread. We must assign it to our own thread so that multiple simultaneous requests can be handled.

Parameters:

socket - TCP socket to process

assign

protected void assign(java.lang.Object socket,
                      SocketStatus status)

await

protected java.lang.Object await()

Await a newly assigned Socket from our Connector, or null if we are supposed to shut down.

run

public void run()

The background thread that listens for incoming TCP/IP connections and hands them off to an appropriate processor.

Specified by:

run in interface java.lang.Runnable

start

public void start()

Start the background processing thread.