org.apache.tomcat.util.net

Class JIoEndpoint.Worker

java.lang.Object

org.apache.tomcat.util.net.JIoEndpoint.Worker

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

JIoEndpoint

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

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	available
protected java.net.Socket	socket
protected SocketStatus	status
protected java.lang.Thread	thread

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JIoEndpoint.Worker()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	assign(java.net.Socket socket) Process an incoming TCP/IP connection on the specified socket.
protected void	assign(java.net.Socket socket, SocketStatus status)
void	run() The background thread that listens for incoming TCP/IP connections and hands them off to an appropriate processor.
void	start() Start the background processing thread.

Methods inherited from class java.lang.Object

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

Field Detail

thread

protected java.lang.Thread thread

available

protected boolean available

socket

protected java.net.Socket socket

status

protected SocketStatus status

Constructor Detail

JIoEndpoint.Worker

protected JIoEndpoint.Worker()

Method Detail

assign

protected void assign(java.net.Socket 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.net.Socket socket,
          SocketStatus status)

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.