water

Class JettyHTTPD

java.lang.Object

water.JettyHTTPD

public class JettyHTTPD
extends java.lang.Object

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.GateHandler

Constructor Summary

Constructors

Constructor and Description
JettyHTTPD() Create bare Jetty object.

Method Summary

Methods

Modifier and Type	Method and Description
void	acceptRequests()
protected void	createServer(org.eclipse.jetty.server.Connector connector)
static void	endTransaction()
static java.io.InputStream	extractPartInputStream(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
static java.lang.String	getDecodedUri(javax.servlet.http.HttpServletRequest request)
java.lang.String	getIp()
int	getPort()
java.lang.String	getScheme()
org.eclipse.jetty.server.Server	getServer()
protected static long	getStartMillis()
static java.lang.String	getUserAgent()
static void	logRequest(java.lang.String method, javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
void	registerHandlers(org.eclipse.jetty.server.handler.HandlerWrapper handlerWrapper) Hook up Jetty handlers.
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)
void	setServer(org.eclipse.jetty.server.Server value)
void	setup(java.lang.String ip, int port)
void	start(java.lang.String ip, int port) Choose a Port and IP address and start the Jetty server.
protected void	startHttp()
static void	startTransaction(java.lang.String userAgent)
void	stop() Stop Jetty server after it has been started.
static boolean	validKeyName(java.lang.String name)

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

getScheme

public java.lang.String getScheme()

Returns:

URI scheme

getPort

public int getPort()

Returns:

Port number

getIp

public java.lang.String getIp()

Returns:

IP address

getServer

public org.eclipse.jetty.server.Server getServer()

Returns:

Server object

setServer

public void setServer(org.eclipse.jetty.server.Server value)

setup

public void setup(java.lang.String ip,
         int port)

start

public void start(java.lang.String ip,
         int port)
           throws java.lang.Exception

Choose a Port and IP address and start the Jetty server.

Throws:

java.lang.Exception

acceptRequests

public void acceptRequests()

createServer

protected void createServer(org.eclipse.jetty.server.Connector connector)
                     throws java.lang.Exception

Throws:

java.lang.Exception

startHttp

protected void startHttp()
                  throws java.lang.Exception

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Stop Jetty server after it has been started. This is unlikely to ever be called by H2O until H2O supports graceful shutdown.

Throws:

java.lang.Exception

registerHandlers

public void registerHandlers(org.eclipse.jetty.server.handler.HandlerWrapper handlerWrapper)

Hook up Jetty handlers. Do this before start() is called.

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

validKeyName

public static boolean validKeyName(java.lang.String name)

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)