org.apache.xmlrpc.webserver

Class Connection

java.lang.Object

org.apache.xmlrpc.webserver.Connection

All Implemented Interfaces:

ServerStreamConnection, ThreadPool.InterruptableTask, ThreadPool.Task

public class Connection
extends Object
implements ThreadPool.InterruptableTask, ServerStreamConnection

Handler for a single clients connection. This implementation is able to do HTTP keepalive. In other words, it can serve multiple requests via a single, physical connection.

Constructor Summary

Constructors

Constructor and Description
Connection(WebServer pWebServer, XmlRpcStreamServer pServer, Socket pSocket) Creates a new webserver connection on the given socket.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the connection, and frees resources.
InputStream	newInputStream() Returns the connections input stream.
OutputStream	newOutputStream() Returns the connections output stream.
void	run() Performs the task.
void	setResponseHeader(String pHeader, String pValue) Sets a response header value.
void	shutdown() Interrupts the task.
void	writeError(RequestData pData, Throwable pError, ByteArrayOutputStream pStream) Writes an error response to the output stream.
void	writeErrorHeader(RequestData pData, Throwable pError, int pContentLength) Writes an error responses headers to the output stream.
void	writeResponse(RequestData pData, OutputStream pBuffer) Writes the response header and the response to the output stream.
void	writeResponseHeader(RequestData pData, int pContentLength) Writes the response header to the output stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

Connection

public Connection(WebServer pWebServer,
                  XmlRpcStreamServer pServer,
                  Socket pSocket)
           throws IOException

Creates a new webserver connection on the given socket.

Parameters:

pWebServer - The webserver maintaining this connection.

pServer - The server being used to execute requests.

pSocket - The server socket to handle; the Connection is responsible for closing this socket.

Throws:

IOException

Method Detail

run

public void run()

Description copied from interface: ThreadPool.Task

Performs the task.

Specified by:

run in interface ThreadPool.Task

writeResponse

public void writeResponse(RequestData pData,
                          OutputStream pBuffer)
                   throws IOException

Writes the response header and the response to the output stream.

Parameters:

pData - The request data.

pBuffer - The ByteArrayOutputStream holding the response.

Throws:

IOException - Writing the response failed.

writeResponseHeader

public void writeResponseHeader(RequestData pData,
                                int pContentLength)
                         throws IOException

Writes the response header to the output stream. *

Parameters:

pData - The request data

pContentLength - The content length, if known, or -1.

Throws:

IOException - Writing the response failed.

writeError

public void writeError(RequestData pData,
                       Throwable pError,
                       ByteArrayOutputStream pStream)
                throws IOException

Writes an error response to the output stream.

Parameters:

pData - The request data.

pError - The error being reported.

pStream - The ByteArrayOutputStream with the error response.

Throws:

IOException - Writing the response failed.

writeErrorHeader

public void writeErrorHeader(RequestData pData,
                             Throwable pError,
                             int pContentLength)
                      throws IOException

Writes an error responses headers to the output stream.

Parameters:

pData - The request data.

pError - The error being reported.

pContentLength - The response length, if known, or -1.

Throws:

IOException - Writing the response failed.

setResponseHeader

public void setResponseHeader(String pHeader,
                              String pValue)

Sets a response header value.

newOutputStream

public OutputStream newOutputStream()
                             throws IOException

Description copied from interface: ServerStreamConnection

Returns the connections output stream.

Specified by:

newOutputStream in interface ServerStreamConnection

Throws:

IOException

newInputStream

public InputStream newInputStream()
                           throws IOException

Description copied from interface: ServerStreamConnection

Returns the connections input stream.

Specified by:

newInputStream in interface ServerStreamConnection

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: ServerStreamConnection

Closes the connection, and frees resources.

Specified by:

close in interface ServerStreamConnection

Throws:

IOException

shutdown

public void shutdown()
              throws Throwable

Description copied from interface: ThreadPool.InterruptableTask

Interrupts the task.

Specified by:

shutdown in interface ThreadPool.InterruptableTask

Throws:

Throwable - Shutting down the task failed.