Package 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 java.lang.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 Description Connection(WebServer pWebServer, XmlRpcStreamServer pServer, java.net.Socket pSocket)
Creates a new webserver connection on the given socket.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Closes the connection, and frees resources.java.io.InputStream
newInputStream()
Returns the connections input stream.java.io.OutputStream
newOutputStream()
Returns the connections output stream.void
run()
Performs the task.void
setResponseHeader(java.lang.String pHeader, java.lang.String pValue)
Sets a response header value.void
shutdown()
Interrupts the task.void
writeError(RequestData pData, java.lang.Throwable pError, java.io.ByteArrayOutputStream pStream)
Writes an error response to the output stream.void
writeErrorHeader(RequestData pData, java.lang.Throwable pError, int pContentLength)
Writes an error responses headers to the output stream.void
writeResponse(RequestData pData, java.io.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.
-
-
-
Constructor Detail
-
Connection
public Connection(WebServer pWebServer, XmlRpcStreamServer pServer, java.net.Socket pSocket) throws java.io.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; theConnection
is responsible for closing this socket.- Throws:
java.io.IOException
-
-
Method Detail
-
run
public void run()
Description copied from interface:ThreadPool.Task
Performs the task.- Specified by:
run
in interfaceThreadPool.Task
-
writeResponse
public void writeResponse(RequestData pData, java.io.OutputStream pBuffer) throws java.io.IOException
Writes the response header and the response to the output stream.- Parameters:
pData
- The request data.pBuffer
- TheByteArrayOutputStream
holding the response.- Throws:
java.io.IOException
- Writing the response failed.
-
writeResponseHeader
public void writeResponseHeader(RequestData pData, int pContentLength) throws java.io.IOException
Writes the response header to the output stream. *- Parameters:
pData
- The request datapContentLength
- The content length, if known, or -1.- Throws:
java.io.IOException
- Writing the response failed.
-
writeError
public void writeError(RequestData pData, java.lang.Throwable pError, java.io.ByteArrayOutputStream pStream) throws java.io.IOException
Writes an error response to the output stream.- Parameters:
pData
- The request data.pError
- The error being reported.pStream
- TheByteArrayOutputStream
with the error response.- Throws:
java.io.IOException
- Writing the response failed.
-
writeErrorHeader
public void writeErrorHeader(RequestData pData, java.lang.Throwable pError, int pContentLength) throws java.io.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:
java.io.IOException
- Writing the response failed.
-
setResponseHeader
public void setResponseHeader(java.lang.String pHeader, java.lang.String pValue)
Sets a response header value.
-
newOutputStream
public java.io.OutputStream newOutputStream() throws java.io.IOException
Description copied from interface:ServerStreamConnection
Returns the connections output stream.- Specified by:
newOutputStream
in interfaceServerStreamConnection
- Throws:
java.io.IOException
-
newInputStream
public java.io.InputStream newInputStream() throws java.io.IOException
Description copied from interface:ServerStreamConnection
Returns the connections input stream.- Specified by:
newInputStream
in interfaceServerStreamConnection
- Throws:
java.io.IOException
-
close
public void close() throws java.io.IOException
Description copied from interface:ServerStreamConnection
Closes the connection, and frees resources.- Specified by:
close
in interfaceServerStreamConnection
- Throws:
java.io.IOException
-
shutdown
public void shutdown() throws java.lang.Throwable
Description copied from interface:ThreadPool.InterruptableTask
Interrupts the task.- Specified by:
shutdown
in interfaceThreadPool.InterruptableTask
- Throws:
java.lang.Throwable
- Shutting down the task failed.
-
-