water

Class JettyHTTPD

java.lang.Object

water.AbstractHTTPD

water.JettyHTTPD

public class JettyHTTPD
extends AbstractHTTPD

Embedded Jetty instance inside H2O. This is intended to be a singleton per H2O node.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JettyHTTPD.AuthenticationHandler
class	JettyHTTPD.ExtensionHandler1
class	JettyHTTPD.GateHandler
class	JettyHTTPD.LoginHandler

Field Summary

Fields inherited from class water.AbstractHTTPD

_ip, _port, _server

Constructor Summary

Constructors

Constructor and Description
JettyHTTPD() Create bare Jetty object.

Method Summary

Methods

Modifier and Type	Method and Description
void	acceptRequests()
static void	endTransaction()
static java.io.InputStream	extractPartInputStream(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
protected java.lang.RuntimeException	failEx(java.lang.String message)
static java.lang.String	getDecodedUri(javax.servlet.http.HttpServletRequest request)
protected static long	getStartMillis()
static java.lang.String	getUserAgent()
protected void	handle1(java.lang.String target, org.eclipse.jetty.server.Request baseRequest, javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
static void	logRequest(java.lang.String method, javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
protected void	registerHandlers(org.eclipse.jetty.server.handler.HandlerWrapper handlerWrapper, org.eclipse.jetty.servlet.ServletContextHandler context)
static void	sendErrorResponse(javax.servlet.http.HttpServletResponse response, java.lang.Exception e, java.lang.String uri)
static void	sendResponseError(javax.servlet.http.HttpServletResponse response, int sc, java.lang.String msg)
static void	setResponseStatus(javax.servlet.http.HttpServletResponse response, int sc)
static void	startTransaction(java.lang.String userAgent)

Methods inherited from class water.AbstractHTTPD

createServer, getIp, getPort, getScheme, getServer, registerHandlers, setServer, setup, start, startHttp, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

JettyHTTPD

public JettyHTTPD()

Create bare Jetty object.

Method Detail

getStartMillis

protected static long getStartMillis()

startTransaction

public static void startTransaction(java.lang.String userAgent)

endTransaction

public static void endTransaction()

getUserAgent

public static java.lang.String getUserAgent()

Returns:

Thread-local User-Agent for this transaction.

setResponseStatus

public static void setResponseStatus(javax.servlet.http.HttpServletResponse response,
                     int sc)

sendResponseError

public static void sendResponseError(javax.servlet.http.HttpServletResponse response,
                     int sc,
                     java.lang.String msg)
                              throws java.io.IOException

Throws:

java.io.IOException

acceptRequests

public void acceptRequests()

failEx

protected java.lang.RuntimeException failEx(java.lang.String message)

Specified by:

failEx in class AbstractHTTPD

registerHandlers

protected void registerHandlers(org.eclipse.jetty.server.handler.HandlerWrapper handlerWrapper,
                    org.eclipse.jetty.servlet.ServletContextHandler context)

Specified by:

registerHandlers in class AbstractHTTPD

handle1

protected void handle1(java.lang.String target,
           org.eclipse.jetty.server.Request baseRequest,
           javax.servlet.http.HttpServletRequest request,
           javax.servlet.http.HttpServletResponse response)
                throws java.io.IOException,
                       javax.servlet.ServletException

Throws:

java.io.IOException

javax.servlet.ServletException

extractPartInputStream

public static java.io.InputStream extractPartInputStream(javax.servlet.http.HttpServletRequest request,
                                         javax.servlet.http.HttpServletResponse response)
                                                  throws java.io.IOException

Throws:

java.io.IOException

sendErrorResponse

public static void sendErrorResponse(javax.servlet.http.HttpServletResponse response,
                     java.lang.Exception e,
                     java.lang.String uri)

getDecodedUri

public static java.lang.String getDecodedUri(javax.servlet.http.HttpServletRequest request)

logRequest

public static void logRequest(java.lang.String method,
              javax.servlet.http.HttpServletRequest request,
              javax.servlet.http.HttpServletResponse response)