Package com.orientechnologies.orient.server.network.protocol.http

Class ONetworkProtocolHttpAbstract

java.lang.Object

java.lang.Thread

com.orientechnologies.common.thread.OSoftThread

com.orientechnologies.orient.server.network.protocol.ONetworkProtocol

com.orientechnologies.orient.server.network.protocol.http.ONetworkProtocolHttpAbstract

All Implemented Interfaces:

OService, ONetworkHttpExecutor, Runnable

Direct Known Subclasses:

ONetworkProtocolHttpDb

public abstract class ONetworkProtocolHttpAbstract
extends ONetworkProtocol
implements ONetworkHttpExecutor

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected OUser	account
protected OChannelTextServer	channel
protected OHttpNetworkCommandManager	cmdManager
protected OClientConnection	connection
protected OHttpRequest	request
protected OHttpResponse	response

Fields inherited from class com.orientechnologies.orient.server.network.protocol.ONetworkProtocol

server

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ONetworkProtocolHttpAbstract(OServer server)

Method Summary

Modifier and Type	Method	Description
void	config(OServerNetworkListener iListener, OServer iServer, Socket iSocket, OContextConfiguration iConfiguration)
protected void	connectionClosed()
protected void	connectionError()
protected String	deCompress(byte[] zipBytes)
protected void	execute()
OUser	getAccount()
String[]	getAdditionalResponseHeaders()
OChannel	getChannel()
OHttpNetworkCommandManager	getCommandManager()
static String	getCommandString(String command, String method)
OClientConnection	getConnection()
String	getRemoteAddress()
OHttpRequest	getRequest()
OHttpResponse	getResponse()
String	getResponseCharSet()
String	getSessionID()
protected void	handleError(Throwable e, OHttpRequest iRequest)
protected void	readAllContent(OHttpRequest iRequest)
static void	registerHandlers(Object caller, OServer server, OServerNetworkListener iListener, OHttpNetworkCommandManager cmdManager)
protected void	registerStatelessCommands(OServerNetworkListener iListener)
protected void	sendError(int iCode, String iReason, String iHeaders, String iContentType, String iContent, boolean iKeepAlive)
protected void	sendResponseHeaders(String iContentType, boolean iKeepAlive)
void	sendShutdown()
protected void	sendStatus(int iStatus, String iReason)
protected void	sendTextContent(int iCode, String iReason, String iHeaders, String iContentType, String iContent, boolean iKeepAlive)
void	service()
void	setDatabase(ODatabaseDocumentInternal db)
void	setResponseCharSet(String responseCharSet)
void	shutdown()
protected void	timeout()
protected void	writeLine(String iContent)

Methods inherited from class com.orientechnologies.orient.server.network.protocol.ONetworkProtocol

executor, getListeningAddress, getServer, getType, getVersion

Methods inherited from class com.orientechnologies.common.thread.OSoftThread

afterExecution, beforeExecution, isShutdownFlag, run, setDumpExceptions, softShutdown, startup

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.common.util.OService

getName

Field Details

connection

protected OClientConnection connection

channel

protected OChannelTextServer channel

account

protected OUser account

request

protected OHttpRequest request

response

protected OHttpResponse response

cmdManager

protected OHttpNetworkCommandManager cmdManager

Constructor Details

ONetworkProtocolHttpAbstract

public ONetworkProtocolHttpAbstract(OServer server)

Method Details

config

public void config(OServerNetworkListener iListener,
 OServer iServer,
 Socket iSocket,
 OContextConfiguration iConfiguration)
            throws IOException

Specified by:

config in class ONetworkProtocol

Throws:

IOException

service

public void service()
             throws ONetworkProtocolException,
IOException

Throws:

ONetworkProtocolException

IOException

sendShutdown

public void sendShutdown()

Overrides:

sendShutdown in class OSoftThread

shutdown

public void shutdown()

Specified by:

shutdown in interface OService

Overrides:

shutdown in class OSoftThread

getRequest

public OHttpRequest getRequest()

getResponse

public OHttpResponse getResponse()

getChannel

public OChannel getChannel()

Specified by:

getChannel in class ONetworkProtocol

getAccount

public OUser getAccount()

getSessionID

public String getSessionID()

getResponseCharSet

public String getResponseCharSet()

setResponseCharSet

public void setResponseCharSet(String responseCharSet)

getAdditionalResponseHeaders

public String[] getAdditionalResponseHeaders()

getCommandManager

public OHttpNetworkCommandManager getCommandManager()

handleError

protected void handleError(Throwable e,
 OHttpRequest iRequest)

sendTextContent

protected void sendTextContent(int iCode,
 String iReason,
 String iHeaders,
 String iContentType,
 String iContent,
 boolean iKeepAlive)
                        throws IOException

Throws:

IOException

sendError

protected void sendError(int iCode,
 String iReason,
 String iHeaders,
 String iContentType,
 String iContent,
 boolean iKeepAlive)
                  throws IOException

Throws:

IOException

writeLine

protected void writeLine(String iContent)
                  throws IOException

Throws:

IOException

sendStatus

protected void sendStatus(int iStatus,
 String iReason)
                   throws IOException

Throws:

IOException

sendResponseHeaders

protected void sendResponseHeaders(String iContentType,
 boolean iKeepAlive)
                            throws IOException

Throws:

IOException

readAllContent

protected void readAllContent(OHttpRequest iRequest)
                       throws IOException

Throws:

IOException

execute

protected void execute()
                throws Exception

Specified by:

execute in class OSoftThread

Throws:

Exception

deCompress

protected String deCompress(byte[] zipBytes)

connectionClosed

protected void connectionClosed()

timeout

protected void timeout()

connectionError

protected void connectionError()

registerHandlers

public static void registerHandlers(Object caller,
 OServer server,
 OServerNetworkListener iListener,
 OHttpNetworkCommandManager cmdManager)

registerStatelessCommands

protected void registerStatelessCommands(OServerNetworkListener iListener)

getConnection

public OClientConnection getConnection()

getCommandString

public static String getCommandString(String command,
 String method)

getRemoteAddress

public String getRemoteAddress()

Specified by:

getRemoteAddress in interface ONetworkHttpExecutor

setDatabase

public void setDatabase(ODatabaseDocumentInternal db)

Specified by:

setDatabase in interface ONetworkHttpExecutor