Package one.nio.http

Class HttpSession

java.lang.Object

one.nio.net.Session

one.nio.http.HttpSession

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class HttpSession
extends Session

Nested Class Summary

Nested classes/interfaces inherited from class one.nio.net.Session

Session.ArrayQueueItem, Session.QueueItem

Field Summary

Fields

Modifier and Type	Field	Description
protected static Request	FIN
protected byte[]	fragment
protected int	fragmentLength
protected Request	handling
private static int	HTTP_VERSION_LENGTH
private static int	MAX_FRAGMENT_LENGTH
private static int	MAX_HEADERS
private static int	MAX_PIPELINE_LENGTH
private static int	MAX_REQUEST_BODY_LENGTH
protected Request	parsing
protected java.util.LinkedList<Request>	pipeline
protected int	requestBodyOffset
protected HttpServer	server

Fields inherited from class one.nio.net.Session

ACTIVE, closing, CLOSING, EVENT_MASK, events, eventsToListen, IDLE, lastAccessTime, log, queueHead, READABLE, selector, slot, socket, SSL, STALE, wasSelected, WRITEABLE

Constructor Summary

Constructors

Constructor	Description
HttpSession(Socket socket, HttpServer server)

Method Summary

Modifier and Type	Method	Description
int	checkStatus(long currentTime, long keepAlive)
protected int	getMaxRequestBodyLength()
protected void	handleParsedRequest()
protected void	handleSocketClosed()
protected Request	parseRequest(byte[] buffer, int start, int length)
protected int	processHttpBuffer(byte[] buffer, int length)
protected void	processRead(byte[] buffer)
void	sendError(java.lang.String code, java.lang.String message)
void	sendResponse(Response response)
protected int	startParsingRequestBody(java.lang.String contentLengthHeader, byte[] buffer, int offset, int remaining)
protected void	writeResponse(Response response, boolean includeBody)

Methods inherited from class one.nio.net.Session

close, getQueueStats, getRemoteHost, handleException, isSsl, lastAccessTime, listen, process, processWrite, read, readRaw, scheduleClose, socket, write, write, write

Methods inherited from class java.lang.Object

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

Field Detail

MAX_HEADERS

private static final int MAX_HEADERS

See Also:

Constant Field Values

MAX_FRAGMENT_LENGTH

private static final int MAX_FRAGMENT_LENGTH

See Also:

Constant Field Values

MAX_PIPELINE_LENGTH

private static final int MAX_PIPELINE_LENGTH

See Also:

Constant Field Values

MAX_REQUEST_BODY_LENGTH

private static final int MAX_REQUEST_BODY_LENGTH

See Also:

Constant Field Values

HTTP_VERSION_LENGTH

private static final int HTTP_VERSION_LENGTH

See Also:

Constant Field Values

FIN

protected static final Request FIN

server

protected final HttpServer server

pipeline

protected final java.util.LinkedList<Request> pipeline

fragment

protected final byte[] fragment

fragmentLength

protected int fragmentLength

requestBodyOffset

protected int requestBodyOffset

parsing

protected Request parsing

handling

protected volatile Request handling

Constructor Detail

HttpSession

public HttpSession(Socket socket,
                   HttpServer server)

Method Detail

checkStatus

public int checkStatus(long currentTime,
                       long keepAlive)

Overrides:

checkStatus in class Session

processRead

protected void processRead(byte[] buffer)
                    throws java.io.IOException

Overrides:

processRead in class Session

Throws:

java.io.IOException

handleSocketClosed

protected void handleSocketClosed()

getMaxRequestBodyLength

protected int getMaxRequestBodyLength()

startParsingRequestBody

protected int startParsingRequestBody(java.lang.String contentLengthHeader,
                                      byte[] buffer,
                                      int offset,
                                      int remaining)
                               throws java.io.IOException,
                                      HttpException

Throws:

java.io.IOException

HttpException

handleParsedRequest

protected void handleParsedRequest()
                            throws java.io.IOException

Throws:

java.io.IOException

processHttpBuffer

protected int processHttpBuffer(byte[] buffer,
                                int length)
                         throws java.io.IOException,
                                HttpException

Throws:

java.io.IOException

HttpException

parseRequest

protected Request parseRequest(byte[] buffer,
                               int start,
                               int length)
                        throws HttpException

Throws:

HttpException

sendResponse

public void sendResponse(Response response)
                  throws java.io.IOException

Throws:

java.io.IOException

sendError

public void sendError(java.lang.String code,
                      java.lang.String message)
               throws java.io.IOException

Throws:

java.io.IOException

writeResponse

protected void writeResponse(Response response,
                             boolean includeBody)
                      throws java.io.IOException

Throws:

java.io.IOException